1>基于UDP的网络聊天室
Ser.c
#include <myhead.h>
#define SER_IP "10.211.55.9" // 服务器IP
#define SER_PORT 9999struct user
{char usrName[20];struct sockaddr_in cin;
};
int main(int argc, char const *argv[])
{// 1.创建用于监听的套接字int sfd = -1;sfd = socket(AF_INET, SOCK_STREAM, 0);// 参数1:表示使用的是ipv4的通信// 参数2:表示使用tcp通信类型// 参数3:表示前面已经特定了通信协议if (sfd == -1)PRINT_ERR("");printf("sfd = %d\n", sfd);int reuse = 1;if (setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1)PRINT_ERR("");// 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");struct sockaddr_in cin; // 用于接收客户端地址信息结构体socklen_t socklen = sizeof(cin); // 用于接收客户端地址信息的大小int newfd = -1; // 新创建用于通信的套接字文件描述符char sbuf[128] = ""; // 从键盘上输入数据// 1.创建文件描述符容器fd_set readfds, tempfds;// 2.清空容器内容FD_ZERO(&readfds);// 3.将sfd和0号文件描述符放入容器中FD_SET(0, &readfds);FD_SET(sfd, &readfds);int maxfd = sfd; // 存放容器中最大的文件描述符的值struct user User[1024];while (1){tempfds = readfds; // 将要检测的容器复制保存一份int res = select(maxfd + 1, &tempfds, NULL, NULL, NULL);if (res == -1)PRINT_ERR("select error");else if (res == 0){printf("time out\n");return -1;}// 遍历所有的容器中的文件描述符for (int i = 0; i <= maxfd; i++){// 判断当前的文件描述符是否在tempfds中,如果不在,直接下一个循环if (!FD_ISSET(i, &tempfds))continue;// 如果程序执行到此,说明检测的集合中有事件产生if (i == sfd){newfd = accept(i, (struct sockaddr *)&cin, &socklen);if (newfd == -1)PRINT_ERR("");recv(newfd, User[newfd].usrName, sizeof(User[newfd].usrName), 0);printf("%s [%s:%d]登陆成功\n", User[newfd].usrName, inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));// 将客户端文件描述符放入集合中FD_SET(newfd, &readfds);// 更新maxfdif (newfd > maxfd){maxfd = newfd;}// 打包信息bzero(sbuf, sizeof(sbuf));sprintf(sbuf,"-----%s登陆成功-----",User[newfd].usrName);// strcat(sbuf, "-----");// strcat(sbuf, User[newfd].usrName);// strcat(sbuf, "登陆成功-----");// 将消息发给每一个客户端for (int k = 4; k <= maxfd; k++){if (k == i)continue;send(k, sbuf, strlen(sbuf), 0);}}else if (i == 0) // 表示有终端输入事件{// 将消息发送给每一个客户端bzero(sbuf, sizeof(sbuf));fgets(sbuf, sizeof(sbuf), stdin);sbuf[strlen(sbuf) - 1] = 0;char sbuf1[128] = "Sys:";strcat(sbuf1, sbuf);// 将消息发给每一个客户端for (int k = 4; k <= maxfd; k++){send(k, sbuf1, strlen(sbuf1), 0);}}else{// 5、通信套接字与客户端进行数据收发char rbuf[128] = ""; // 数据读取// 清空容器bzero(rbuf, sizeof(rbuf));// 从套接字中读取数据int res = recv(i, rbuf, sizeof(rbuf), 0);if (res == 0){// strcat(rbuf, "-----");// strcat(rbuf, User[i].usrName);// strcat(rbuf, " 已下线-----");sprintf(rbuf,"-----%s已下线-----",User[i].usrName);// 将消息发给每一个客户端for (int k = 4; k <= maxfd; k++){if (k == i)continue;send(k, rbuf, strlen(rbuf), 0);}bzero(User[i].usrName, sizeof(User[i].usrName));// 6、关闭套接字close(i);// 将当前文件描述符从容器中移除FD_CLR(i, &readfds);// 更新maxfdfor (int j = maxfd; j >= 0; j--){if (FD_ISSET(j, &readfds)){maxfd = j;break;}}}else if (strcmp(rbuf, "quit") != 0){printf("%s [%s:%d]chart成功\n", User[i].usrName, inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));char wbuf[128] = "";strcat(wbuf, User[i].usrName);strcat(wbuf, ":");strcat(wbuf, rbuf);// 将消息发给每一个客户端for (int k = 4; k <= maxfd; k++){if (k == i)continue;send(k, wbuf, strlen(wbuf), 0);}}bzero(rbuf, sizeof(rbuf));}}}close(sfd);return 0;
}
Cli.c
#include <myhead.h>
#define SER_IP "10.211.55.9" // 服务器IP
#define SER_PORT 9999struct msgTyp
{char usrName[20];char msgText[1024];
};int main(int argc, const char *argv[])
{struct msgTyp User = {0, 0};printf("请输入姓名>>>");scanf("%s", User.usrName);// 1、创建用于通信的套接字文件描述符int cfd = socket(AF_INET, SOCK_STREAM, 0);if (cfd == -1){perror("socket error");return -1;}printf("cfd = %d\n", cfd); // 3// 2、绑定(非必须)// 3、连接服务器// 3.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地址// 3.2 连接服务器if (connect(cfd, (struct sockaddr *)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}printf("connect success\n");//向服务器发送上线信息send(cfd, User.usrName, strlen(User.usrName), 0);// 使用poll完成客户端的读写操作并发执行// 1、定义一个pollfd数组struct pollfd pfd[2];pfd[0].fd = 0; // 检测0号文件描述符pfd[0].events = POLLIN; // 检测0号文件描述符的读操作pfd[1].fd = cfd; // 检测cfd文件描述符pfd[1].events = POLLIN; // 检测cfd中的读操作// 4、数据收发while (1){int res = poll(pfd, 2, -1); // 阻塞检测集合中是否有事件产生if (res == -1){perror("poll error");return -1;}else if (poll == 0){printf("time out\n");return -1;}// 程序执行至此,表示有事件产生if (pfd[0].revents == POLLIN) // 表示0号文件描述符事件产生{// 清空数据bzero(&User.msgText, sizeof(User.msgText));fgets(User.msgText, sizeof(User.msgText), stdin); // 从终端输入User.msgText[strlen(User.msgText) - 1] = 0;// 将数据发送给服务器send(cfd, User.msgText, strlen(User.msgText), 0);// 判断发送的数据if (strcmp(User.msgText, "quit") == 0){break;}}if (pfd[1].revents == POLLIN) // 表示cfd文件描述符事件产生{// 接收服务器发来的消息// 清空数据bzero(User.msgText, sizeof(User.msgText));recv(cfd, User.msgText, sizeof(User.msgText), 0);printf("%s\n", User.msgText);}}// 5、关闭套接字close(cfd);return 0;
}
结果: