Linux 网络编程

套接字(Socket):

通过网络实现跨机通信

作用:一种文件描述符传输层的文件描述符

整个编程中,需要着重注意htonl/htons、ntohl/ntohs、inet_addr等

TCP的C/S实现


循环服务器模型

TCP服务器实现过程

1.创建套接字:

初始化结构体struct sockaddr_in

2.给套接字绑定ip地址和端口号:bind函数

#include <netinet/in.h>

3.将套接字文件描述符,从主动变为被动文件描述符(做监听准备——listen函数)

4.accept函数:被动监听客户的连接并响应        【实现三次握手(无客户端连接,则会阻塞)】

5.服务器调用read(recv)和write(send)函数————SIGPIPE忽略

recv的返回值等于0的时候,证明客户端已经关闭

6.注意事项:

        字节序转换:

发送数据:将主机端序转为网络端序

接收数据:将网络端序转为主机端序

7.调用close或者shutdown关闭TCP连接

close:

缺点1:一次性将读写都关闭——只想关写(读),打开写(读),就实现不了

缺点2:如果多个文件猫述符指向了同一个连接时。如果只close关闭了其中某个文件猫述符时只要其它的fd还打开着,那么连接不会被断开。直到所有的描述符都被close后才断开连接
出现多个描述指向同一个连接的原因可能两个:
1.通过dup方式复制出其它描述符
2.子进程维承了这个描述符,所以子进程的描述符也指向了连接

shutdown:

可以全关掉

  • shutdown(套接字描述符)会关闭整个套接字的发送和接收功能,不管是否有连接建立。
  • shutdown(一个连接描述符)只会关闭与该连接相关的发送和接收功能,不会影响其他连接或套接字描述符。
  • close(套接字描述符)会完全关闭套接字描述符,释放与之相关的资源,并将描述符标记为无效。
  • close(一个连接描述符)的概念上并不存在,连接描述符通常是由套接字描述符派生出来的,因此关闭连接描述符时实际上是关闭了套接字描述符。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h> //*******//
#include <netinet/in.h> //*******//
#include <arpa/inet.h>  //*******//
#include <unistd.h>
#include <signal.h>
int sockfd;
void my_exit(int sig)
{shutdown(sockfd, SHUT_RDWR);close(sockfd);printf("shutdown socket done\n");exit(0);
}
void handle(int sig) // SIGPIPE的信号处理函数————以观察是否产生了SIGPIPE信号
{if (sig == SIGPIPE){printf("SIGPIPE is going\n");}
}int main(int argc, char **argv)
{signal(SIGINT, my_exit);signal(SIGPIPE, handle);signal(SIGPIPE, SIG_IGN);// 1.sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){perror("socked is error");exit(-1);}printf("socket success\n");// setsockopt函数int i;setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &i, sizeof(i));// 2.struct sockaddr_in sockaddr_in1;sockaddr_in1.sin_family = AF_INET; // IPV4// “5555”可以用宏定义sockaddr_in1.sin_port = htons(4443);                         // 正确的做法是使用htons函数将主机字节序转换为网络字节序————htons而非htonl因为端口号是16位sockaddr_in1.sin_addr.s_addr = inet_addr("192.168.106.128"); //*****//if (bind(sockfd, (struct sockaddr *)&sockaddr_in1, sizeof(sockaddr_in1)) < 0){perror("bind error");exit(-1);}printf("bind success\n");// 3.if (listen(sockfd, 20) < 0){perror("listen error");exit(-1);}printf("listen success\n");// 4.struct sockaddr_in addr2;int len_addr2 = sizeof(addr2);while (1){// 强制类型转换int sock_fd1 = accept(sockfd, (struct sockaddr *)&addr2, &len_addr2); // 每来一个客户端的连接请求,就会生成一个描述符,只要知道这个描述符,就能通过此通信if (sock_fd1 < 0){perror("accept error");exit(-1);}printf("client ip = %s ,port = %d\n", inet_ntoa(addr2.sin_addr), ntohs(addr2.sin_port)); // 1.inet_ntoa把ip地址转换为字符————2.把网络的转换为主机的// 5.char buffer[1024] = {0};int recv_t = recv(sock_fd1, buffer, sizeof(buffer) - 1, 0);printf("recv_t : %d   ", recv_t);if (recv_t < 0){perror("recv error");exit(-1);}else if (recv_t == 0) // recv的返回值为零的时候,证明客户端关闭了!{printf("client is closed\n");}else{printf("recv :%s\n", buffer);while (1){memset(buffer, 0, sizeof(buffer));scanf("%s", buffer);// int w_t = send(sock_fd1, buffer, strlen(buffer), 0);int w_t = send(sock_fd1, buffer, strlen(buffer), MSG_NOSIGNAL); // MSG_NOSIGNAL:表示此操作不愿被SIGPIPE信号断开;或注册信号处理函数if (w_t < 0){perror("send data error");exit(-1);}}}shutdown(sock_fd1, SHUT_RDWR);}return 0;
}
8.setsockopt函数

主要用在服务器端:

【当有客服端连接到服务器的时候,此时服务器端按下ctrl + c,断开连接,此时需要等待2MSL,才能再次用原来的ip和端口号新建客户端,为了去除这种等待2MSL的】

SO_REUSEADDR允许完全重复的捆绑:当一个IP地址和端口绑定到某个套接口上时,还允许此IP地址和端口捆绑到另一个套接口上

setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&j,sizeof(j));-CSDN博客

9.在socket()和bind()调用之间,使用下列代码——防止客户端关闭时,要等2MSL的时间

TCP客服端的实现过程

client.c#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <signal.h>
#include <unistd.h>int main(int argc, char **argv)
{if (argc != 3){perror("input error");exit(-1);}int socket_fd = socket(AF_INET, SOCK_STREAM, 0);if (socket_fd < 0){perror("socket error");exit(-1);}struct sockaddr_in addr_in1;addr_in1.sin_family = AF_INET;addr_in1.sin_addr.s_addr = inet_addr(argv[1]);addr_in1.sin_port = htons(atoi(argv[2]));if (connect(socket_fd, (struct sockaddr *)&addr_in1, sizeof(addr_in1)) == 0){printf("connect ok\n");}else{printf("connect error\n");}while (1){char buffer[1024];memset(buffer, 0, sizeof(buffer));scanf("%s", buffer);write(socket_fd, buffer, strlen(buffer) + 1);memset(buffer, 0, sizeof(buffer));read(socket_fd, buffer, sizeof(buffer));printf("%s", buffer);}return 0;
}

UDP的C/S实现

UDP协议没有建立连接特性,所以UDP协议没有自动记录对方IP和端口的特点,每次发
送数据时,必须亲自指定对方的IP和端口,只有这样才能将数据发送给对方。

 

UDP通信过程

1.调用socket创建套接字文件

2.bind绑定固定的ip和端口

3.调用sendto和recvfrom函数,发送和接收数据

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <signal.h>
#include <unistd.h>
int main(int argc, char **argv)
{// if (argc != 3)// {//     printf("input error\n");//     exit(-1);// }// 1.int sock_fd = socket(AF_INET, SOCK_DGRAM, 0);if (sock_fd < 0){perror("socket error");exit(-1);}// 2.struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_addr.s_addr = inet_addr("127.0.0.1");addr.sin_port = htons(5554);if (bind(sock_fd, (struct sockaddr *)&addr, sizeof(addr)) < 0){perror("bind error");exit(-1);}// 3.struct sockaddr_in addr2;int addr2_len = sizeof(addr2);addr2.sin_family = AF_INET;addr2.sin_addr.s_addr = inet_addr(argv[1]);addr2.sin_port = htons(atoi(argv[2]));while (1){char buffer[1024];scanf("%s", buffer);int ret = sendto(sock_fd, buffer, strlen(buffer) + 1,0, (struct sockaddr *)&addr2, addr2_len);if (ret < 0){perror("sendto error");exit(-1);}}return 0;
}#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <signal.h>
#include <unistd.h>
int main(int argc, char **argv)
{// 1.int sock_fd = socket(AF_INET, SOCK_DGRAM, 0);if (sock_fd < 0){perror("socket error");exit(-1);}// 2.struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_addr.s_addr = inet_addr("127.0.0.1");addr.sin_port = htons(5555);if (bind(sock_fd, (struct sockaddr *)&addr, sizeof(addr)) < 0){perror("bind error");exit(-1);}// 3.struct sockaddr_in addr2;memset(&addr2, 0, sizeof(addr2));int addr2_len = sizeof(addr2);char buffer[1024] = {0};while (1){int ret = recvfrom(sock_fd, buffer, sizeof(buffer),0, (struct sockaddr *)&addr2, &addr2_len);if (ret < 0){perror("recvfrom error");exit(-1);}printf("from ip = %s ,from port = %d \n", inet_ntoa(addr2.sin_addr), ntohs(addr2.sin_port));printf("recv message = %s \n", buffer);}return 0;
}

运行结果:

广播


一个人发,然后其它所有人都接收,这就是广播。


广播只能在局域网内部有效,广播数据是无法越过路由器的,也就是说路由器就是广播数据的边界。 广播只能在局域网内部有效,广播数据是无法越过路由器的,也就是说路由器就是广播数据的边界。


实现方法:

1.广播的发数据,不需要绑定自己的IP地址

2.ip地址写成广播地址;例如:192.168.1.255

3.接收端的ip地址,不能设置为固定ip,要指定为htons(INADDR_ANY)

4.接收方需要setsockopt函数,设置套接字文件可以重复绑定

   addr1.sin_addr.s_addr = htons(INADDR_ANY);//为什么是htons和htonl!!!!
广播发送:无需bind#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>int main(int argc, char **argv)
{int sock_fd = socket(AF_INET, SOCK_DGRAM, 0);if (sock_fd < 0){perror("socket error");exit(-1);}//*****************************************************************************//int j = 1;setsockopt(sock_fd, SOL_SOCKET, SO_BROADCAST, (void *)&j, sizeof(j));//*****************************************************************************//struct sockaddr_in addr1;addr1.sin_family = AF_INET;addr1.sin_addr.s_addr = inet_addr("127.0.0.255");addr1.sin_port = htons(5555);while (1){char buffer[1024] = {0};scanf("%s", buffer);sendto(sock_fd, buffer, sizeof(buffer),0, (struct sockaddr *)&addr1, sizeof(addr1));}return 0;
}接受广播:#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>int main(int argc, char **argv)
{int sock_fd = socket(AF_INET, SOCK_DGRAM, 0);if (sock_fd < 0){perror("socket error");exit(-1);}int j = 1;setsockopt(sock_fd, SOL_SOCKET, SO_REUSEADDR, &j, sizeof(j));struct sockaddr_in addr1;addr1.sin_family = AF_INET;//*****************************************************************************//addr1.sin_addr.s_addr = htons(INADDR_ANY);//为什么是htons和htonl!!!!//*****************************************************************************//addr1.sin_port = htons(5555);int ret = bind(sock_fd, (struct sockaddr *)&addr1, sizeof(addr1));if (ret < 0){perror("bind error");exit(-1);}struct sockaddr_in addr2;int len = sizeof(addr2);memset(&addr2, 0, sizeof(addr2));char buffer[1024];while (1){memset(buffer, 0, sizeof(buffer));recvfrom(sock_fd, buffer, sizeof(buffer),0, (struct sockaddr *)&addr2, &len);printf("recv %s\n", buffer);}return 0;
}

组播

把一些ip设置为一个组,给这些组,发消息(后续在QT里涉及到

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/145529.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Docker安装MS SQL Server并使用Navicat远程连接

思维导航 MS SQL Server简介 Microsoft SQL Server(简称SQL Server)是由微软公司开发的关系数据库管理系统,它是一个功能强大、性能卓越的企业级数据库平台,用于存储和处理大型数据集、支持高效查询和分析等操作。SQL Server 支持广泛的应用程序开发接口(API),包括 T-S…

大规模语言模型--中文 LLaMA和Alpaca

中文LLaMA 尽管 LLaMA 和 Alpaca 在 NLP 领域取得了重大进展&#xff0c; 它们在处理中文语言任务时&#xff0c; 仍存在一些局限性。这 些原始模型在字典中仅包含数百个中文 tokens (可以理解为单词)&#xff0c;导致编码和解码中文文本的效率受到了很大 影响。 之前已经对…

.net 温故知新:Asp.Net Core WebAPI 入门使用及介绍

在Asp.Net Core 上面由于现在前后端分离已经是趋势,所以asp.net core MVC用的没有那么多,主要以WebApi作为学习目标。 一、创建一个WebApi项目 我使用的是VS2022, .Net 7版本。 在创建界面有几项配置: 配置Https启用Docker使用控制器启用OpenAPI支持不使用顶级语句其中配置…

毛玻璃态卡片悬停效果

效果展示 页面结构组成 页面的组成部分主要是卡片。其中卡片的组成部分主要是包括了图片和详情。 卡片的动效是鼠标悬停在卡片上时&#xff0c;图片会移动到左侧&#xff0c;并且图片是毛玻璃效果。所以我们在布局的时候图片会采用绝对布局。而详情则是基础布局。 CSS3 知识…

springboot和vue:八、vue快速入门

vue快速入门 新建一个html文件 导入 vue.js 的 script 脚本文件 <script src"https://unpkg.com/vuenext"></script>在页面中声明一个将要被 vue 所控制的 DOM 区域&#xff0c;既MVVM中的View <div id"app">{{ message }} </div…

HBase高阶(一)基础架构及存储原理

一、HBase介绍 简介 HBase是Hadoop生态系统中的一个分布式、面向列的开源数据库&#xff0c;具有高可伸缩性、高性能和强大的数据处理能力。广泛应用于处理大规模数据集。 HBase是一种稀疏的、分布式、持久的多维排序map 稀疏&#xff1a;对比关系型数据库和非关系型数据库&a…

记录一次阿里云服务器ECS上启动的portainer无法访问的问题

如下图&#xff0c;在阿里云ECS服务器上安装并启动了portainer&#xff0c;但是在自己电脑上访问不了远程的portainer。 最后发现是要在网络安全组里开放9000端口号&#xff0c;具体操作如下&#xff1a; 在云服务器管理控制台点击左侧菜单中的网络与安全-安全组&#xff0c;然…

二值贝叶斯滤波计算4d毫米波聚类目标动静属性

机器人学中有些问题是二值问题&#xff0c;对于这种二值问题的概率评估问题可以用二值贝叶斯滤波器binary Bayes filter来解决的。比如机器人前方有一个门&#xff0c;机器人想判断这个门是开是关。这个二值状态是固定的&#xff0c;并不会随着测量数据变量的改变而改变。就像门…

FPGA的数字钟带校时闹钟报时功能VHDL

名称&#xff1a;基于FPGA的数字钟具有校时闹钟报时功能 软件&#xff1a;Quartus 语言&#xff1a;VHDL 要求&#xff1a; 1、计时功能:这是数字钟设计的基本功能&#xff0c;每秒钟更新一次,并且能在显示屏上显示当前的时间。 2、闹钟功能:如果当前的时间与闹钟设置的时…

数据结构—快速排序(续)

引言&#xff1a;在上一篇中我们详细介绍了快速排序和改进&#xff0c;并给出了其中的一种实现方式-挖坑法 但其实快速排序有多种实现方式&#xff0c;这篇文章再来介绍其中的另外两种-左右指针法和前后指针法。有了上一篇挖坑法的启示&#xff0c;下面的两种实现会容易许多。 …

蓝桥等考Python组别九级005

第一部分&#xff1a;选择题 1、Python L9 &#xff08;15分&#xff09; 运行下面程序&#xff0c;可以输出几行“*”&#xff1f;&#xff08; &#xff09; for i in range(0, 2): for j in range(0, 5): print(*, end ) print() 5234 正确答案&#xff1a;B 2、P…

5自由度雄克机械臂仿真描点

5自由度雄克机械臂仿真描点 任务 建立雄克机械臂的坐标系和D-H参数表&#xff0c;使用Matlab机器人工具箱&#xff08;Robotics Toolbox&#xff09;&#xff0c;用机械臂末端执行器触碰8个红色的目标点。 代码 %% 机器人学 format compact close all clear clc%% DH参数 L…

新型信息基础设施IP追溯:保护隐私与网络安全的平衡

随着信息技术的飞速发展&#xff0c;新型信息基础设施在全球范围内日益普及&#xff0c;互联网已经成为我们社会和经济生活中不可或缺的一部分。然而&#xff0c;随着网络使用的增加&#xff0c;隐私和网络安全问题也引发了广泛关注。在这个背景下&#xff0c;IP&#xff08;In…

Java实现word excel ppt模板渲染与导出及预览 LibreOffice jodconverter

Java Office 一、文档格式转换 文档格式转换是office操作中经常需要进行一个操作&#xff0c;例如将docx文档转换成pdf格式。 java在这方面有许多的操作方式&#xff0c;大致可以分为内部调用&#xff08;无需要安装额外软件&#xff09;&#xff0c;外部调用&#xff08;需…

nodejs+vue活鲜物流监控系统elementui

第3章 系统分析 5 3.1 需求分析 5 3.2 系统可行性分析 5 3.2.1技术可行性&#xff1a;技术背景 5 3.2.2经济可行性 6 3.2.3操作可行性&#xff1a; 6 3.3 项目设计目标与原则 6 3.4系统流程分析 7 3.4.1操作流程 7 3.4.2添加信息流程 8 3.4.3删除信息流程 9 第4章 系统设计 11 …

设计模式7、桥接模式 Bridge

解释说明&#xff1a;将抽象部分与它的实现部分解耦&#xff0c;使得两者都能够独立变化 桥接模式将两个独立变化的维度设计成两个独立的继承等级结构&#xff08;而不会将两者耦合在一起形成多层继承结构&#xff09;&#xff0c;在抽象层将二者建立起一个抽象关联&#xff0c…

施耐德电气:勾勒未来工业愿景,赋能中国市场

9月19日&#xff0c;第23届中国国际工业博览会&#xff08;简称“工博会”&#xff09;在上海隆重召开。作为全球能源管理和自动化领域的数字化转型专家&#xff0c;施耐德电气在工博会现场全方位展现了自身对未来工业的全新视野与深刻见解&#xff0c;不仅展示了其贯通企业设计…

JUC第十二讲:JUC锁: 锁核心类AQS详解

JUC第十二讲&#xff1a;JUC锁: 锁核心类AQS详解 本文是JUC第十二讲&#xff0c;JUC锁: 锁核心类AQS详解。AbstractQueuedSynchronizer抽象类是核心&#xff0c;需要重点掌握。它提供了一个基于FIFO队列&#xff0c;可以用于构建锁或者其他相关同步装置的基础框架。 文章目录 J…

细胞机器人系统中的群体智能

摘要 细胞机器人系统具有“智能”行为能力。本文分析了这种智能的含义。本文根据上述不可思议智能行为的不可预测性来定义机器人智能和机器人系统智能。对不可预测性概念的分析与&#xff08;1&#xff09;统计不可预测、&#xff08;2&#xff09;不可访问、&#xff08;3&am…

sed编辑器

Linux文本三剑客&#xff1a; grep sed awk grep&#xff08;查&#xff09; &#xff0c;按行处理 sed&#xff08;行编辑器&#xff09;&#xff0c;按行处理 sed是一种流编辑器&#xff0c;每一次处理内容&#xff0c;只有确认&#xff0c;才会生效&#xff0c;如果不确认…