0724，select +tcp 聊天室喵
创始人
2024-12-03 10:05:36
0次
目录
TCP协议喵
723__01：使用select实现一个基于UDP的一对一即时聊天程序。
001:
002: TIMEWAI OR BUG
721作业：
01：在一对一聊天的基础上，使用select实现一对多的回显服务。（回显服务即接收到客户端发送的数据后，再回复给客户端）
一对一的喵：
一对多的服务器喵：
02：使用select编写聊天室程序：客户端和服务端使用tcp通信；服务端可以处理新客户端的连接和转发消息；客户端可以连入服务端并发送消息。
TCP协议喵
struct sockaddr struct sockaddr_in --> struct in_addr struct hostent htonl() htons() ntohl() ntohs() int inet_aton(const char* cp,struct in_addr * inp); in_addr_t inet_addr(const char* cp); const char* inet_ntop(int af,const void* src,char* dst,socklen_t size); struct hostent * gethostbyname(const char* name); client :socket——connect——recv/send——close (one fd) server:socket——bind——listen——accept——recv/send——close (listendfd) (peerfd) int socket (int domain,int type,int protocol); int bind (int sockfd,const struct sockaddr* addr ,socklen_t addrlen); int listen (int sockfd,int backlog); int connect (int sockfd,const struct sockaddr*addr, socklen_t addrlen); int accept (int sockfd,struct sockaddr* addr, socklen_t addrlen); ssize_t recv ( int sockfd,void* buf,size_t buf,int flags); ssize_t send( int sockfd,void* buf,size_t buf,int flags); int setsockopt(int sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on)); int level ,int opname,const void* optval,socklen_t optlen靓仔不想抄代码了呜呜，好困
————————client : socket connect while(1) close ————————server : socket bind listen accept send //send是阻塞式函数 close //第一次send可以正常执行，此时因为连接已经断开了，服务器会收到一个RST报文 //第二次send时，服务器会收到一个SIGPIPE信号 ，该信号的默认处理方式是终结进程。 //总结：client的连接关闭，会导致服务器进程奔溃，是一个不能接受的情况，因为服务器要服务其他的客户端。 ————————client : socket connect recv close ————————server : socket bind listen accept send sleep() send //服务器往一个已经断开了的连接上继续发送数据，会造成什么影响？ close //数据在发送时是字节流，不是一个个的数据包 //数据之间是没有边界的概念 =》 TCP粘包问题 ————————client : socket connect recv recv close ————————server : socket bind listen accept send send close //recv的返回值为0的情况 ————————client : socket connect recv recv close ————————server : socket bind listen accept send close 723__01：使用select实现一个基于UDP的一对一即时聊天程序。
001:
#include #define IP "192.168.235.128" #define PORT1 8080 #define PORT2 8081 struct sockaddr* addr_create(const char* ip,int port ){ struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in)); memset(addr,0,sizeof(*addr)); addr->sin_family=AF_INET; addr->sin_port=htons(port); addr->sin_addr.s_addr=inet_addr(ip); return (struct sockaddr*)addr; } int main() { struct sockaddr* addr=addr_create(IP,PORT1); struct sockaddr* addr1=addr_create(IP,PORT2); int sockfd=socket(AF_INET,SOCK_DGRAM,0); if(sockfd==-1){error(1,errno,"socket");} //addr1暴露一下？ int err=bind(sockfd,addr1,sizeof(*addr)); if(err==-1){error(1,errno,"bind");} int epfd=epoll_create1(0); struct epoll_event epev; epev.events=EPOLLIN; epev.data.fd=sockfd; epoll_ctl(epfd,EPOLL_CTL_ADD,sockfd,&epev); epev.data.fd=STDIN_FILENO;//标准输入的文件描述符，通常为 0 epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&epev); struct epoll_event epev_arr[2]; char buff[4096]; while(1){ int num=epoll_wait(epfd,epev_arr,2,-1); for(int i=0;i 002: TIMEWAI OR BUG
#include #define IP "192.168.235.128" #define IP1 "42.194.149.92" #define PORT1 8082 #define PORT2 13332 struct sockaddr* addr_create(const char* ip,int port ){ struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in)); memset(addr,0,sizeof(*addr)); addr->sin_family=AF_INET; addr->sin_port=htons(port); addr->sin_addr.s_addr=inet_addr(ip); return (struct sockaddr*)addr; } int main() { struct sockaddr* addr=addr_create(IP,PORT1); struct sockaddr* addr1=addr_create(IP1,PORT2); int sockfd=socket(AF_INET,SOCK_DGRAM,0); if(sockfd==-1){error(1,errno,"socket");} //addr暴露一下 /* int err=bind(sockfd,addr,sizeof(*addr)); */ /* if(err==-1){error(1,errno,"bind");} */ int epfd=epoll_create1(0); struct epoll_event epev; epev.events=EPOLLIN; epev.data.fd=sockfd; epoll_ctl(epfd,EPOLL_CTL_ADD,sockfd,&epev); epev.data.fd=STDIN_FILENO;//标准输入的文件描述符，通常为 0 epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&epev); struct epoll_event epev_arr[2]; char buff[4096]; while(1){ int num=epoll_wait(epfd,epev_arr,2,-1); for(int i=0;i 721作业：
01：在一对一聊天的基础上，使用select实现一对多的回显服务。（回显服务即接收到客户端发送的数据后，再回复给客户端）
一对一的喵：
//client.c #include #define IP1 "192.168.235.128" #define IP2 "42.194.149.92" #define PORT1 8080 #define PORT2 13332 struct sockaddr* addr_create(const char* ip,int port ){ struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in)); memset(addr,0,sizeof(*addr)); addr->sin_family=AF_INET; addr->sin_port=htons(port); addr->sin_addr.s_addr=inet_addr(ip); return (struct sockaddr*)addr; } int main() { int sofd=socket(AF_INET,SOCK_STREAM,0); if(sofd==-1){error(1,errno,"socket");} struct sockaddr* addr=addr_create(IP1,PORT1); int err=connect(sofd,addr,sizeof(*addr)); if(err==-1){error(1,errno,"connect");} printf("connect sucess\n"); fd_set set; FD_ZERO(&set); char buff[100]={0}; while(1){ FD_SET(STDIN_FILENO,&set); FD_SET(sofd,&set); select(sofd+1,&set,NULL,NULL,NULL); if(FD_ISSET(STDIN_FILENO,&set)){ memset(buff,0,sizeof(buff)); err=read(STDIN_FILENO,buff,sizeof(buff)); if(strcmp(buff,"byby\n")==0){break;} send(sofd,buff,err-1,0); } if(FD_ISSET(sofd,&set)){ memset(buff,0,sizeof(buff)); err=recv(sofd,buff,sizeof(buff),0); if(err==0){printf("byebye\n");break;} printf("ret: %d,recv:%s \n",err,buff); } } close(sofd); return 0; } //server.c #include #define IP1 "192.168.235.128" #define IP2 "42.194.149.92" #define PORT1 8080 #define PORT2 13332 struct sockaddr* addr_create(const char* ip,int port ){ struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in)); memset(addr,0,sizeof(*addr)); addr->sin_family=AF_INET; addr->sin_port=htons(port); addr->sin_addr.s_addr=inet_addr(ip); return (struct sockaddr*)addr; } int main() { int sofd=socket(AF_INET,SOCK_STREAM,0); if(sofd==-1){error(1,errno,"socket");} struct sockaddr* addr=addr_create(IP1,PORT1); int err=bind(sofd,addr,sizeof(*addr)); if(err==-1){error(1,errno,"bimd");} printf("bind sucess\n"); /* struct sockaddr_in* addrin=(struct sockaddr_in*)addr; */ /* printf("%s,%d\n",inet_ntoa(addr->sin_addr), */ /* sizeof((struct sockaddr_in*)addr.sin.port)); */ err=listen(sofd,1); if(err==-1){error(1,errno,"listen");} struct sockaddr_in addr2; socklen_t len=sizeof(addr2); int peerfd=accept(sofd,(struct sockaddr*)&addr2,&len); printf("client :%s:%d has connect\n",inet_ntoa(addr2.sin_addr), ntohs(addr2.sin_port)); // sofd--->peerfd fd_set set; FD_ZERO(&set); char buff[100]={0}; while(1){ FD_SET(STDIN_FILENO,&set); FD_SET(peerfd,&set); select(peerfd+1,&set,NULL,NULL,NULL); if(FD_ISSET(STDIN_FILENO,&set)){ memset(buff,0,sizeof(buff)); err=read(STDIN_FILENO,buff,sizeof(buff)); if(strcmp(buff,"byby\n")==0){break;} send(peerfd,buff,err-1,0); } if(FD_ISSET(peerfd,&set)){ memset(buff,0,sizeof(buff)); err=recv(peerfd,buff,sizeof(buff),0); if(err==0){printf("byebye\n");break;} printf("ret: %d,recv:%s \n",err,buff); } } close(sofd); return 0; } 一对多的服务器喵：
#include #define IP1 "192.168.235.128" #define IP2 "42.194.149.92" #define PORT1 8080 #define PORT2 13332 struct sockaddr* addr_create(const char* ip,int port ){ struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in)); memset(addr,0,sizeof(*addr)); addr->sin_family=AF_INET; addr->sin_port=htons(port); addr->sin_addr.s_addr=inet_addr(ip); return (struct sockaddr*)addr; } int main() { int sofd=socket(AF_INET,SOCK_STREAM,0); if(sofd==-1){error(1,errno,"socket");} struct sockaddr* addr=addr_create(IP1,PORT1); int err=bind(sofd,addr,sizeof(*addr)); if(err==-1){error(1,errno,"bimd");} printf("bind sucess\n"); /* struct sockaddr_in* addrin=(struct sockaddr_in*)addr; */ /* printf("%s,%d\n",inet_ntoa(addr->sin_addr), */ /* sizeof((struct sockaddr_in*)addr.sin.port)); */ err=listen(sofd,1); if(err==-1){error(1,errno,"listen");} struct sockaddr_in addr2; socklen_t len=sizeof(addr2); int peerfd=accept(sofd,(struct sockaddr*)&addr2,&len); printf("client :%s:%d has connect\n",inet_ntoa(addr2.sin_addr), ntohs(addr2.sin_port)); // sofd--->peerfd fd_set set; FD_ZERO(&set); char buff[100]={0}; while(1){ FD_SET(STDIN_FILENO,&set); FD_SET(peerfd,&set); select(peerfd+1,&set,NULL,NULL,NULL); if(FD_ISSET(STDIN_FILENO,&set)){ memset(buff,0,sizeof(buff)); err=read(STDIN_FILENO,buff,sizeof(buff)); if(strcmp(buff,"byby\n")==0){break;} send(peerfd,buff,err-1,0); } if(FD_ISSET(peerfd,&set)){ memset(buff,0,sizeof(buff)); err=recv(peerfd,buff,sizeof(buff),0); if(err==0){printf("byebye\n");break;} printf("ret: %d,recv:%s \n",err,buff); } } close(sofd); return 0; } 02：使用select编写聊天室程序：客户端和服务端使用tcp通信；服务端可以处理新客户端的连接和转发消息；客户端可以连入服务端并发送消息。
//server.c #include #define IP1 "192.168.235.128" #define IP2 "42.194.149.92" #define PORT1 8080 #define PORT2 13332 //聊天室服务端 typedef struct conn_s{ int netfd; int isalive; }conn_t; struct sockaddr* addr_create(const char* ip,int port ){ struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in)); memset(addr,0,sizeof(*addr)); addr->sin_family=AF_INET; addr->sin_port=htons(port); addr->sin_addr.s_addr=inet_addr(ip); return (struct sockaddr*)addr; } int main(int argc,char* argv[]) { struct sockaddr* addr=addr_create(IP1,PORT1); int sofd=socket(AF_INET,SOCK_STREAM,0); if(sofd==-1){error(1,errno,"socket");} bind(sofd,(struct sockaddr *)&addr,sizeof(addr)); listen(sofd,10); //用于管理文件描述符集合，用于指示哪些文件描述符正在监听的 I/O 事件已经发生 fd_set set;//select 监听的集合 FD_ZERO(&set); FD_SET(sofd,&set); conn_t list[1024]; memset(list,0,sizeof(list)); int index; while(1){ fd_set temp_set;//构建此次的监听合计 memcpy(&temp_set,&set,sizeof(set));//cp ser temp_set select (10,&temp_set,NULL,NULL,NULL); if(FD_ISSET(sofd,&temp_set)){ int netfd=accept(sofd,NULL,NULL); list[index].isalive=1; list[index].netfd=netfd; FD_SET(netfd,&set);//增加监听 index++; } for(int i=0;isend client for(int j=0;j 722作业 ：
01：使用epoll的流程是怎么样，每一步操作会涉及哪些数据结构？
02：select有哪些缺陷，epoll为什么比较高效？
03：epoll中的水平触发和边缘触发的区别是什么？使用边缘触发时，要注意什么呢？
04：采用TCP协议，通过epoll实现多客户端的回显服务，从而理解epoll的实现流程。
（epoll监听新连接的请求和回显已经建立好连接的消息）
05：使用epoll编写聊天室程序：客户端和服务端使用tcp通信；服务端可以处理新客户端的连接和转发消息；客户端可以连入服务端并发送消息。一个客户端10s未发送消息直接踢出
HTTP协议：
作业：
01：HTTP请求报文和响应报文由哪些部分组成？HTTP常用方法有哪些？HTTP常用状态码有哪些？
02：form-data的boundary起什么作用，有什么限制？
03：HTTP请求报文的报文体可以携带哪些类型的数据，分别是什么，各自有什么特点呢？
04：对称加密和非对称加密有什么区别？简要说明一下HTTPS的握手阶段流程。
05：C++代码实现：尝试实现一个静态网页服务端，返回给客户端一张图片 (提示：读取服务器本地的图片文件，再发送给客户端)
相关内容
热门资讯
透视教学！wepoker破解器...
透视教学！wepoker破解器有用吗，wepoker安装教程（一贯是有挂）1、进入游戏-大厅左侧-新...
透视总结!aapoker万能辅...
透视总结!aapoker万能辅助器(透视)俱乐部靠谱(总是真的是有挂)1、不需要AI权限，帮助你快速...
透视新版！wepoker轻量版...
透视新版！wepoker轻量版透视，wepoker透视脚本网页（总是是有挂）；1）wepoker透视...
透视脚本!aapoker辅助器...
透视脚本!aapoker辅助器是真的吗(透视)脚本可以用(确实是真的有挂)运aapoker辅助器是真...
透视肯定！wepoker脚本下...
透视肯定！wepoker脚本下载，we-poker有人玩吗（原来真的有挂）一、we-poker有人玩...
透视app!aapoker透视...
透视app!aapoker透视脚本(透视)万能辅助器(竟然真的有挂)；1、aapoker透视脚本ai...
透视好友房！有没有人wepok...
透视好友房！有没有人wepoker，wepoker作弊视频（一直存在有挂）暗藏猫腻，小编详细说明we...
透视代打!aapoker能控制...
透视代打!aapoker能控制牌吗(透视)辅助(都是真的有挂)1、在aapoker能控制牌吗ai机器...
透视了解！wepoker底牌透...
透视了解！wepoker底牌透视脚本，wepoker怎么挂飞机（本来是真的有挂）；1、超多福利：超高...
透视肯定!aapoker透视脚...
透视肯定!aapoker透视脚本下载(透视)透视插件(果然真的有挂)1、玩家可以在aapoker透视...