网络编程day4

IP多路复用实现TCP服务器并发

#include<myhead.h>

#define  SER_PORT  8888        //服务器端口号
#define SER_IP  "192.168.108.34"   //服务器IP地址 

int main(int argc, const char *argv[])
{
	//1、创建一个用于连接的套接字文件描述符
	int sfd  = socket(AF_INET, SOCK_STREAM, 0);
	if(-1 == sfd)
	{
		perror("socket  error");
		return -1;
	}

	printf("socket 成功 sfd = %d\n", sfd);          //3


	//设置套接字属性：允许端口号快速重用
	int reuse = 1;
	if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse))==-1)
	{
		perror("setsockopt error");
		return -1;
	}
	printf("端口号快速重用成功\n");

	//2、给套接字绑定ip地址和端口号
	//2.1 封装地址信息结构体变量
	struct sockaddr_in sin;        //地址信息结构体变量
	sin.sin_family = AF_INET;      //通信域地址族
	sin.sin_port = htons(SER_PORT);   //端口号网络字节序
	sin.sin_addr.s_addr = inet_addr(SER_IP);  //ip地址网络字节序
	
	//2.2  绑定操作
	if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) ==-1)
	{
		perror("bind  error");
		return -1;
	}
	printf("bind success\n");


	//3、将套接字启动监听
	if(listen(sfd, 128) == -1)
	{
		perror("listen  error");
		return -1;
	}
	printf("listen success\n");

	//4、阻塞等等客户端的连接，如果有新客户端连接，
	//则创建一个用于通信的套接字
	struct sockaddr_in cin;            //用于接受客户端套接字信息
	socklen_t addrlen = sizeof(cin);   //用于接受客户端套接字的长度

	char  wbuf[128] = "";                 //用于服务器发送消息的容器

	
	//创建一个文件描述符容器，将可能产生阻塞任务的文件描述符放到里面
	//1、定义一个用于检测文件描述符的集合容器
	fd_set readsfds;

	//2、清空文件描述符数组中的内容
	FD_ZERO(&readsfds);

	//3、将需要检测的文件描述符放入到集合中
	FD_SET(0, &readsfds);           //将0号文件描述符放入
	FD_SET(sfd, &readsfds);         //讲sfd放入集合中

	//定义一个临时备用容器
	fd_set tempfds;

	int new_fd = -1;            //用于接收客户端请求后创建用于通信套接字
	int maxfd = sfd;            //用于存储文件描述符集合中最大的文件描述符

	//定义一个存储客户端地址信息的结构体数组
	struct sockaddr_in cin_arr[1024];

	while(1)
	{
		//将文件描述符集合中的内容复制给临时容器
		tempfds = readsfds;

		//4、使用select一个阻塞函数检测文件描述符集合中是否有事件产生
		//有任意一个文件描述符的任务到达后，就会解除该阻塞
		int res = select(maxfd+1, &tempfds, NULL,NULL, NULL);
		if(res == -1)
		{
			perror("select error");
			return -1;
		}else if(res == 0)
		{
			printf("time out\n");
			return -1;
		}

		//判断是否为有新的客户端发来连接请求
		if(FD_ISSET(sfd, &tempfds))
		{
			 new_fd = accept(sfd, (struct sockaddr*)&cin, &addrlen);
			if(-1 == new_fd)
			{
				perror("accept error");
				return -1;
			}
			printf("[%s:%d]发来连接，new_fd = %d\n", inet_ntoa(cin.sin_addr),\
					ntohs(cin.sin_port) ,new_fd);

			cin_arr[new_fd] = cin;      //将下标为newfd的结构体数组值赋值

			//将新的用于通信的套接字文件描述符加入到文件描述符集合中
			FD_SET(new_fd, &readsfds);

			//更新maxfd
			if(new_fd > maxfd)
			{
				maxfd = new_fd;
			}

		}

		//判断是否为服务器终端输入
		if(FD_ISSET(0, &tempfds))
		{
			scanf("%s", wbuf);
			printf("触发终端输入事件：%s\n", wbuf);

			//讲消息发送给所有的客户端
			for(int i=4; i<=maxfd; i++)
			{
				send(i, wbuf, strlen(wbuf), 0);
			}

		}


		//判断是否为客户端套接字发来的消息
		//由于客户端可能有多个，所以需要遍历完成
		for(int i=4; i<=maxfd; i++)
		{
			//没有触发事件的文件描述符，直接结束
			if(!FD_ISSET(i, &tempfds))
			{
				continue;
			}

			//从套接字中读取消息
			char rbuf[128] = "";          //存放接受消息的容器
			//int res = read(new_fd, rbuf, sizeof(rbuf)-1);
			int res = recv(i, rbuf, sizeof(rbuf)-1, 0);
			if(res == 0)
			{
				printf("客户端已下线\n");
				close(i);
				//将i文件描述符从集合中删除
				FD_CLR(i, &readsfds);

				//更新最值？
				for(int j=maxfd; j>=0; j--)
				{
					if(FD_ISSET(j,&readsfds))
					{
						maxfd = j;
						break;
					}
				}

				break;
			}
			if(res == -1)
			{
				perror("read error");
				close(i);
				close(sfd);
				return -1;
			}

			//如果程序执行至此，表示数据成功读取下来，病放入rbuf中
			printf("[%s:%d] : %s\n", inet_ntoa(cin_arr[i].sin_addr), ntohs(cin_arr[i].sin_port), rbuf);

			//给当前消息加个笑脸还回去
			strcat(rbuf, "*_*");

			//向套接字中写入消息
			//write(new_fd, rbuf, strlen(rbuf));
			send(i, rbuf, strlen(rbuf), 0);

			printf("发送成功\n");
		}

		



		
	}


	//6、关闭监听套接字
	close(sfd);



	
	return 0;
}