Linux下Socket编程利用多进程实现一台服务器与多台客户端并发通信

---

前言

前些日子同“ Linux应用编程 ”专栏中发布过的TCP及UDP在Linux或Windows下的通信都为单进程下的Socket编程，若还存在一些套接字相关函数模糊不清，读者可移步“Socket编程下tcp通信”和“Socket编程下udp通信”重温学习。
本篇则是对以上俩篇的一个简单提升运用，或者说是对以后多线程/进程工作的简单示例。

相关知识运用：

• PF_INET 和 AF_INET 的区别：在Windows中，AF_INET与PF_INET完全一样，而在Unix/Linux系统中，在不同的版本中这两者有微小差别。对于BSD，是AF，对于POSIX是PF。
• bzero函数与memset函数： 俩函数功能为 置字节字符串s的前n个字节为零且包括‘\0’，但bzero已被标记为遗留函数，这里推荐使用memset函数。
• fork()函数： 返回值为0时为子进程，返回值大于0时为父进程，返回值为其他数时为创建失败。
• atoi函数： 把字符串转换成整型数的一个函数，int atoi(const char *nptr)函数会扫描参数 nptr字符串，会跳过前面的空白字符（例如空格，tab缩进）等，如果 nptr不能转换成 int 或者 nptr为空字符串，那么将返回 0 。且该函数要求被转换的字符串是按十进制数理解的，atoi输入的字符串对应数字存在大小限制（与int类型大小有关），若其过大可能报错-1。
• htons： 是将整型变量从主机字节顺序转变成网络字节顺序， 就是整数在地址空间存储方式变为高位字节存放在内存的低地址处。

---

一、服务器 server

①创建套接字描述符

//创建一个socket文件，也就是打开一个网络通讯端口,类型是IPV4（PF_INET）+TCP（SOCK_STREAM）
int server_socket=socket(PF_INET,SOCK_STREAM,0);

②创建服务器地址结构

struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr)); 
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(atoi(argv[1]));
server_addr.sin_addr.s_addr = INADDR_ANY;

③绑定套接字

bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr));

④监听套接字

listen(server_socket,10);

⑤多进程连接

client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &client_addr_size);
int pid=fork();   //创建子进程
if(pid==0){       //子进程struct sockaddr_in client_in_addr;   // 创建临时客户端地址结构体用于存放开始accept到的客户端数据client_in_addr.sin_addr.s_addr=client_addr.sin_addr.s_addr;client_in_addr.sin_port=client_addr.sin_port;recv_len = recv(client_socket, buf, sizeof(buf), 0);  //接收客户端数据存入缓冲区buf中
}
else if(pid>0){    //父进程close(client_socket);
}
else{       //创建子进程失败，直接退出exit(-1);
}

二、客户端 client

①创建网络通信套接字描述符

int client_socket=socket(AF_INET,SOCK_STREAM,0);

②创建服务器的地址结构体

struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr)); 
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(atoi(argv[2]));
server_addr.sin_addr.s_addr=inet_addr(argv[1]);

③连接服务器

connect(client_socket,(struct sockaddr*)&server_addr,sizeof(server_addr));

④收发数据

write(client_socket, buf, strlen(buf));   //向服务器发送缓冲区buf中的数据
read(client_socket, message, sizeof(message));   //读取服务器发过来的数据并存入缓冲区message中

三、并发通信演示

四、程序源码

若需程序源码可留言邮箱至评论区或直接私信 即可。