多线程网络编程
上一节我们讲到,当我们的多个客户端区连接同一个服务端的时候就会出现问题,这是因为一个返回值只能接收一个客户端传输的消息,那么我们想要多个客户端同时链接服务端,我们就要有这样一个思路,发过来一个数据我们就建立一个返回值,那么这里肯定是想到使用循环的办法,但是我们循环之间要靠媒介,这里就想到了我们的多线程,每次传输一个数据,我们就建立一个新的线程
那么这样就可以解决我们的问题。
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
int main()
{
int sockfd = socket(AF_INET,SOCK_STREAM,0);//创建套接字
if ( sockfd == -1 )
{
exit(0);
}
struct sockaddr_in saddr, caddr;
memset(&saddr,0,sizeof(saddr));
saddr.sin_family = AF_INET;//地址族
saddr.sin_port = htons(6000);//端口号
saddr.sin_addr.s_addr = inet_addr("127.0.0.1"); //
int res = bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));//指定套接字的 地址(ip port)
if ( res == -1 )
{
printf("bind err\n");
exit(0);
}
listen(sockfd,5);//设置监听队列大小
while( 1 )
{
int len = sizeof(caddr);//caddr客户端的地址
int c = accept(sockfd,(struct sockaddr*)&caddr,&len);
if ( c < 0 )
{
continue;
}
printf("accept c=%d\n",c);
char buff[128] = {0};
int n = recv(c,buff,127,0);//read 接收数据
printf("buff=%s\n",buff);
send(c,"ok",2,0);
close(c);
}
}
这是我们第一次编写网络编程的时候的服务端代码
因为这里用到了线程函数 因此我们编译时要加上 -lpthread
我们通过 accept的返回值来确定是否链接成功 如果链接成功
accept的返回值为零是我们目前唯一判断建立连接不成功的证明
然后它的每一个返回值可以和一个客户端建立连接
那么我们使用多线程想建立一个怎样的模型呢
就是和上次不同的是我们使用线程来实现多个accept
那么我们对服务端的代码的修改如下
这样我们就完成了多线程网络编程的服务端的代码的修改
那么我们建立连接客服端 客户端的代码不用修改
但是要保持和服务器端的ip地址一致
我们可以看到 修改后的服务端成功的和各个客户端建立了连接并且完成了数据传输
接下来我们要介绍并发网络编程的一个机制
我们修改一下服务器端的代码
我们让它每次只接收一个字符
我们编译运行连接客户端
可以看到它输出是一个一个将 hell0输出出来
它第一次明明是输出了五个字符确打印了一个ok
第二次输出三个字符但是打印四个ok
这是为什么呢
这里就涉及到了我们的 recv函数的缓冲区
也就是说我们第一次输出五个字符的时候
缓冲区满了 使用阻塞住 只打出了一个ok
这就是造成这样结果的根源
多进程网络编程
刚刚的问题我们用多进程同样可以实现
那么我们再对刚刚的代码进行一点修改
然后我们编译运行并且与客户端建立通信
我们可以看到成功建立了通信 但是如果我们结束一个客户端
我们看到出现了僵尸进程
因为子进程比父进程先结束
那么按照我们以往的理解 再加入一个wait函数等待父进程结束
其实我们加入之后就会发现 如果只添加wait函数 那么 服务器端就会阻塞无法响应
因为我们单单只有wait函数就会让服务器端阻塞
解决办法是 我们知道子进程结束时会给 父进程一个SIGCHID信号
那么当父进程接收到这个信号时我们设置响应状态为不做响应
那么她就可以不被阻塞并且消除掉僵尸进程的情况