linux socket 通信中并发服务器拒绝连接,重置连接,客户端自动关闭问题

stoat

我添加了信号处理及io复用后,测试结果是信号确实会产生,然后程序终止,但是按要求产生信号后,只需提示一下即可,然后程序继续运行,我不知道这个处理函数怎么写,好象handler怎么写也会不到upload函数中让它继续运行呀(现在是捕捉到信号后,不停地打印handler中的printf,然后终止了):

1. 
   
2. 1  void handler(){printf("error caused by signal\n");}
   
3. 2  int upload(){
   
4. 3      int f;//文件标识符
   
5. 4      size_t rsize;//读取长度
   
6. 5      struct stat buffer;//结构,用来取得文件大小
   
7. 6      unsigned char buf[1024+1];//缓冲区
   
8. 7      struct sockaddr_in servaddr;      
   
9. 8      int ret;
   
10. 9      struct timeval timeout;
    
11. 10    fd_set rfd,wfd,efd;
    
12. 11    struct sigaction newact;
    
13.        //初始化套接口,hostname和port是经过参数初始化了的服务器ip和端口
    
14. 12    servaddr.sin_family=AF_INET:
    
15. 13    servaddr.sin_port=htons(port);
    
16. 14    if(inet_pton(AF_INET,hostname,&servaddr.sin_addr)<=0){
    
17. 15         perror("inet_pton");
    
18. 16    }
    
19. 17    fcntl(sockfd,F_SETFD,O_NONBLOCK);
    
20. 18    timeout.tv_sec=2;
    
21. 19    timeout.tv_usec=0;
    
22. 20    newact.sa_flags=0;
    
23. 21    sigemptyset(&newact.sa_mask);  
    
24. 22    sigaddset(&newact.sa_mask,SIGPIPE);
    
25. 23    sigaddset(&newact.sa_mask,SIGSEGV);
    
26. 24    if(sigaction(SIGPIPE,&newact,NULL)<0){
    
27. 25         printf("sigsegv output info\n");
    
28. 26    }
    
29. 27    if(sigaction(SIGSEGV,&newact,NULL)<0){
    
30. 28          printf("sigpipe output info\n");
    
31. 29   }
    
32. 30   while(1){
    
33. 31         stat(filename,&buffer);//取得文件属性
    
34.            //打开文件
    
35. 32         if((f=open("filename",O_RDONLY))<0){
    
36. 33             perror("can't open file");
    
37. 34             continue;
    
38. 35         }
    
39.            //生成套接口
    
40. 36         if(sockfd=socket(AF_INET,SOCK_STREAM,0)<0){
    
41. 37             perror("socket");
    
42. 38             close(f);
    
43. 39             continue;
    
44. 40         }
    
45.            //连接服务器
    
46. 41         if(connect(sockfd,(struct sockaddr *)&seraddr,sizeof(struct sockaddr))<0)        {
    
47. 42             perror("connect");
    
48. 43             close(f);
    
49. 44             close(sockfd);
    
50. 45             continue;
    
51. 46         }
    
52. 47         resize=buffer.st_size;//文件大小           
    
53. 48         FD_ZERO(&rfd);
    
54. 49         FD_ZERO(&wfd);
    
55. 50         FD_ZERO(&efd);
    
56. 51         FD_SET(f,&rfd);
    
57. 52         FD_SET(sockfd,&wfd);
    
58. 53         FD_SET(sockfd,&efd);
    
59. 54         ret=select(sockfd+1,&rfd,&wfd,&efd,&timeout);
    
60. 55         if(ret==0)
    
61. 56             continue;
    
62. 57         if(ret<0){
    
63. 58             perror("select error:");
    
64. 59             exit(-1);
    
65. 60         }
    
66. 61         alarm(3);
    
67. 62         if(FD_ISSET(f,&rfd)&&FD_ISSET(sockfd,&wfd)){
    
68. 63             while(rsize>0){
    
69. 64                 resize -=readn(f,buf,1024);//readn()函数是经过封装了read函数能准确读一定字节文件的函数
    
70. 65                 writen(sockfd,buf,1024);//和readn函数一样封装过write函数
    
71. 66             }
    
72. 67         }
    
73. 68         alarm(0);
    
74. 69         close(f);
    
75. 70         close(sockfd);
    
76. 71     }
    
77. 72 }
    

复制代码

x11

你的newact好像没设置处理函数吧
另外你的handler也不符合处理函数的原型
man sigaction 看看

2. #include <signal.h>
4. int sigaction(int signum, const struct sigaction *act, struct sigaction
5.        *oldact);
7. struct sigaction {
8.     void (*sa_handler)(int);
9.     void (*sa_sigaction)(int, siginfo_t *, void *);
10.     sigset_t sa_mask;
11.     int sa_flags;
12.     void (*sa_restorer)(void);
13. };

复制代码

stoat

问题解决了,在产生信号之前下工夫,当受到fin时continue