reactor模式源码

#include<stdio.h> #include<sys/types.h> #include<stdlib.h> #include<sys/socket.h> #include<netinet/in.h> #include<arpa/inet.h> #include<errno.h> #include<string.h> #include<unistd.h> #define PORT 2090 int max_connections=100; int main() { struct sockaddr_in serAddr; memset(&serAddr,0,sizeof(serAddr)); serAddr.sin_family=AF_INET; serAddr.sin_port=htons(PORT); int result=inet_pton(AF_INET,"192.168.204.145",&serAddr.sin_addr.s_addr); if(result==0) { printf("IP copy error:%s",strerror(errno)); return 0; } char buf[100]="dafs"; int a=0; while(true) { int sock=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP); if(sock==-1) { printf("sock error:%s",strerror(errno)); return 0; } result=connect(sock,(struct sockaddr*)&serAddr,sizeof(serAddr)); if(result<0) { printf("send complete %d\n",a++); printf("connect error:%s\n",strerror(errno)); return 0; } result=send(sock,buf,100,0); if(result>0) { printf("send %d successfully\n",a++); } if(result<0) { printf("send failed\n"); return 0; } close(sock); if(a==1000) break; } }