linux epoll 發(fā)送函數(shù)封裝問題請(qǐng)教...

sasinop

大概流程就是：main.c 主文件運(yùn)行后，接受客戶端連接，當(dāng)客戶端發(fā)相應(yīng)命令過來后，在tcp.c 文件中解析后，調(diào)用function.c文件中的處理函數(shù)：Receive_Process（）。
原來我的想法是，在function處理完成后，通過Receive_Process()函數(shù)再把結(jié)果返回，
[code=c]void Receive_Process(int conn_fd,unsigned char*  buff_r,unsigned char*  buff_w)[/code]
如果這樣的話，就沒這些問題了，處理的結(jié)果，我在tcp.c文件中，通過 “unsigned char*  buff_w” 可以拿到，送給PC就完事了。

現(xiàn)在同事要求不這么干，即不通過Receive_Process（）進(jìn)、出方式，把結(jié)果返回。而是要在fuction.c中（當(dāng)然也可能其他文件中可以調(diào)用發(fā)送函數(shù)，把結(jié)果送給PC）把結(jié)果直接送給PC端...


（在另個(gè)帖子里可能沒描述清楚）

主文件：
主要就是網(wǎng)上找到一段代碼，簡(jiǎn)單調(diào)整了一下。

1. 
   
2. #include "tcp.h"
   
3. int main(int argc, char * argv[])   
   
4. {       
   
5.                 tcp_initialize();
   
6.                 epoll_fd_tcp=create_epoll_tcp(MAX_EVENTS_TCP);         
   
7.           while(1)
   
8.           {
   
9.                    do_process_tcp_nowhile();
   
10.                    sleep(1);
    
11.           }         
    
12. }  
    

復(fù)制代碼

處理文件：function.c

1. 
   
2. #include "function.h"
   
3. 
   
4. void Receive_Process(int conn_fd,unsigned char*  buff_r,unsigned char*  buff_w)
   
5. {
   
6.         unsigned char CmdKey;
   
7.         unsigned char length;
   
8.         int len,i;
   
9.   len = buff_r[1];
   
10.         CmdKey = buff_r[2];       
    
11.         printf("packet len is : %02X\n",buff_r[1]);
    
12.         printf("cmdkey is : %02X\n",buff_r[2]);
    
13.         for(i=0;i<len;i++)
    
14.                      buff_r[i]=buff_r[i+1];
    
15.              for(i=0;i<len;i++)
    
16.                      printf("%02X ",buff_r[i]);
    
17.   printf("\n");
    
18. switch(CmdKey)
    
19.         {                               
    
20.                 case 0x02:
    
21.                         //write_spi_arm_to_fpga_array(5,buff_r,buff_w);
    
22.                      [color=#FF0000]  // 根據(jù)命令，與FPGA交互后，將返回結(jié)果送給PC端，下面是模擬的數(shù)據(jù)。[/color]
    
23.                         buff_w[0]=0x08;
    
24.                         buff_w[1]=0x03;
    
25.                         buff_w[2]=0x8c;
    
26.                         buff_w[3]=0x00;
    
27.                         buff_w[4]=0x00;
    
28.                         //send to pc
    
29.                        [color=#FF0000] tcp_send_data_to_pc(5 buff_w);[/color]
    
30.                        // 無發(fā)完成發(fā)送任務(wù)，這個(gè)函數(shù)只能在tcp.c文件中能正常，出了tcp.c文件就不行了。
    
31.                         printf("CMD_GET_VERSION OK \n");               
    
32.                         break;
    
33.                 default:                                               
    
34.                         break;
    
35.         }               
    
36. }
    

復(fù)制代碼

TCP文件： tcp.c

1. 
   
2. #include "tcp.h"
   
3. 
   
4. struct epoll_event events[MAX_EVENTS_TCP];// 事件監(jiān)聽隊(duì)列
   
5. 
   
6. 
   
7. int server_sock_fd_tcp;// 服務(wù)器端套接字   
   
8. int client_sock_fd_tcp;// 客戶端套接字      
   
9. int nfds_tcp;// epoll監(jiān)聽事件發(fā)生的個(gè)數(shù)
   
10. int len_recv_data_tcp;
    
11. struct sockaddr_in host_addr_tcp;   // 服務(wù)器網(wǎng)絡(luò)地址結(jié)構(gòu)體   
    
12. struct sockaddr_in remote_addr_tcp; // 客戶端網(wǎng)絡(luò)地址結(jié)構(gòu)體   
    
13. int sin_size;   
    
14. unsigned char send_data_buffer_size_tcp[BUFFER_SIZE_TCP];  // 數(shù)據(jù)傳送的緩沖區(qū)  
    
15. unsigned char retn_data_buffer_size_tcp[BUFFER_SIZE_TCP];   
    
16. int m=0;
    
17. int len;
    
18. //設(shè)置句柄為非阻塞方式
    
19. int setnonblocking(int sockfd)  
    
20. {  
    
21. if (fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFD, 0)|O_NONBLOCK) == -1)  
    
22. {  
    
23.     return -1;  
    
24. }  
    
25.     return 0;  
    
26. }
    
27. 
    
28. int tcp_send_data_to_pc(int len,char* buffer)
    
29. {       
    
30.                 printf("in while n == %d \n",n);
    
31.                 send(events[n].data.fd,buffer,4,0);               
    
32.                 ev.events = EPOLLIN;
    
33.                 ev.data.fd = events[n].data.fd;
    
34.     epoll_ctl(epoll_fd_tcp, EPOLL_CTL_MOD, ev.data.fd, &ev);
    
35. }
    
36. 
    
37. void tcp_initialize()
    
38. {
    
39.     struct rlimit rt;
    
40.    
    
41.     /* 設(shè)置每個(gè)進(jìn)程允許打開的最大文件數(shù) */  
    
42.     rt.rlim_max = rt.rlim_cur = 1024;  
    
43.     if (setrlimit(RLIMIT_NOFILE, &rt) == -1)   
    
44.                 {  
    
45.         perror("setrlimit");  
    
46.         exit(1);  
    
47.     }  
    
48.     else   
    
49.     {  
    
50.         printf("setrlimit ok! \n");  
    
51.     }  
    
52.    
    
53.     // 創(chuàng)建服務(wù)器端套接字--IPv4協(xié)議，面向連接通信，TCP協(xié)議
    
54.     if((server_sock_fd_tcp=socket(PF_INET,SOCK_STREAM,0))<0)   
    
55.     {     
    
56.         perror("socket");   
    
57.         //return 1;   
    
58.     }
    
59.     else
    
60.     {
    
61.             printf("Tcp server socket ok...\n");
    
62.     }
    
63.            
    
64.             // 設(shè)置 socket屬性，端口可以重用   
    
65.   
    
66.           int opt=SO_REUSEADDR;
    
67.           setsockopt(server_sock_fd_tcp,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
    
68.           setnonblocking(server_sock_fd_tcp);
    
69.            
    
70.     memset(&host_addr_tcp,0,sizeof(host_addr_tcp)); // 數(shù)據(jù)初始化--清零      
    
71.     host_addr_tcp.sin_family=PF_INET; // 設(shè)置為IP通信   
    
72.     host_addr_tcp.sin_addr.s_addr=inet_addr(HOST_IP_ADDRESS_TCP);// 服務(wù)器IP地址--允許連接到所有本地地址上   
    
73.     host_addr_tcp.sin_port=htons(HOST_PORT_TCP); // 服務(wù)器端口號(hào)  
    
74.    
    
75.     // 將套接字綁定到服務(wù)器的網(wǎng)絡(luò)地址上
    
76.     if (bind(server_sock_fd_tcp,(struct sockaddr *)&host_addr_tcp,sizeof(struct sockaddr))<0)   
    
77.     {   
    
78.         perror("bind");   
    
79.         //return 1;   
    
80.     }
    
81.     else
    
82.     {
    
83.             printf("Tcp server bind ok...\n");
    
84.             printf("IP  : %s   \n", inet_ntoa(host_addr_tcp.sin_addr));
    
85.             printf("port: %d \n",ntohs(host_addr_tcp.sin_port));
    
86.     }
    
87.     // 監(jiān)聽連接請(qǐng)求--監(jiān)聽隊(duì)列長(zhǎng)度為5
    
88.     listen(server_sock_fd_tcp,64);   
    
89.     sin_size=sizeof(struct sockaddr_in);
    
90.        
    
91. }
    
92. 
    
93. // 創(chuàng)建一個(gè)epoll句柄
    
94. int create_epoll_tcp(unsigned int event_num)
    
95.   {       
    
96.           int epoll_fd;
    
97.                 epoll_fd=epoll_create(event_num);
    
98.                 if(epoll_fd==-1)
    
99.                 {
    
100.                         perror("epoll_create failed");                       
     
101.                 }
     
102.                 ev.events=EPOLLIN | EPOLLET;
     
103.                 ev.data.fd=server_sock_fd_tcp;
     
104.                 // 向epoll注冊(cè)server_sockfd監(jiān)聽事件
     
105.                 if(epoll_ctl(epoll_fd,EPOLL_CTL_ADD,server_sock_fd_tcp,&ev)==-1)
     
106.                 {
     
107.                         perror("epll_ctl:server_sock_fd_tcp register failed");                       
     
108.                 }
     
109.                 else
     
110.           {
     
111.             printf("socket adding in  epoll success! \n");
     
112.           }
     
113.                 return epoll_fd;
     
114. }
     
115. 
     
116. void do_process_tcp_nowhile()
     
117. {                         
     
118.                         // 等待事件發(fā)生
     
119.                         nfds_tcp=epoll_wait(epoll_fd_tcp,events,1024,-1);
     
120.                         if(nfds_tcp==-1)
     
121.                         {
     
122.                                 perror("start epoll_wait failed");
     
123.                                 //exit(EXIT_FAILURE);
     
124.                         }
     
125.                         else
     
126.                         {
     
127.                                         printf(" epoll nfds_tcp = %d   \n",nfds_tcp);
     
128.                         }
     
129.                        
     
130.                         for(n=0;n<nfds_tcp;++n)
     
131.                         {
     
132.                                 printf(" for loop epoll nfds_tcp = %d   \n",nfds_tcp);
     
133.                                 // 客戶端有新的連接請(qǐng)求
     
134.                                 if(events[n].data.fd == server_sock_fd_tcp)
     
135.                                 {
     
136.                                         // 等待客戶端連接請(qǐng)求到達(dá)
     
137.                       if((client_sock_fd_tcp=accept(server_sock_fd_tcp,(struct sockaddr *)&remote_addr_tcp,&sin_size))<0)
     
138.                                         {   
     
139.                                                 perror("accept client_sock_fd_tcp failed");   
     
140.                                                 exit(EXIT_FAILURE);
     
141.                                         }
     
142.                                         // 向epoll注冊(cè)client_sockfd監(jiān)聽事件
     
143.                                         setnonblocking(client_sock_fd_tcp);
     
144.                                         ev.events=EPOLLIN | EPOLLET;
     
145.                                         ev.data.fd=client_sock_fd_tcp;
     
146.                                         if(epoll_ctl(epoll_fd_tcp,EPOLL_CTL_ADD,client_sock_fd_tcp,&ev)==-1)
     
147.                                         {
     
148.                                                 perror("epoll_ctl:client_sock_fd_tcp register failed");                                               
     
149.                                         }
     
150.                                         printf("accept client %s\n",inet_ntoa(remote_addr_tcp.sin_addr));                                               
     
151.                                 }
     
152.                                 else if(events[n].events & EPOLLIN)
     
153.                                 {
     
154.                                         // 客戶端有數(shù)據(jù)發(fā)送過來
     
155.                                         sprintf(send_data_buffer_size_tcp,"");
     
156.                                         //sin_size=sizeof(remote_addr_tcp);
     
157.                                
     
158.                                         len_recv_data_tcp=recv(events[n].data.fd,send_data_buffer_size_tcp,BUFFER_SIZE_TCP,0);
     
159.                                         if(len_recv_data_tcp<=0)
     
160.                                         {
     
161.                                                 printf("close id is : %d \n",events[n].data.fd);                                       
     
162.                                                 if(epoll_ctl(epoll_fd_tcp,EPOLL_CTL_DEL,events[n].data.fd,&ev)==0)
     
163.                                                 {
     
164.                                                         printf("delete ok \n");
     
165.                                                         close(events[n].data.fd);
     
166.                                                 }
     
167.                                                 else
     
168.                                                 {
     
169.                                                         printf("delete error \n");
     
170.                                                 }
     
171.                                         }
     
172.                                         else
     
173.                                         {//[color=#FF0000]處理PC來的命令包，，調(diào)用fuction.c文件中的 Receive_Process（）函數(shù)[/color]
     
174.                                      Receive_Process(4,send_data_buffer_size_tcp,retn_data_buffer_size_tcp);
     
175.                                     
     
176.                                                 ev.data.fd = events[n].data.fd;
     
177.             ev.events = EPOLLOUT|EPOLLET;
     
178.             epoll_ctl(epoll_fd_tcp, EPOLL_CTL_MOD, events[n].data.fd, &ev);                                                       
     
179.                                         }
     
180.                                 }
     
181.                                 else if(events[n].events & EPOLLOUT)//發(fā)送
     
182.                                 {                                       
     
183.                                         tcp_send_data_to_pc(4,send_data_buffer_size_tcp);        [color=#FF0000]//這個(gè)地方就正常        [/color]                       
     
184.                                 }
     
185.                         }                       
     
186.                
     
187.                 if(server_sock_fd_tcp>0)
     
188.                 {
     
189.                         printf("socket close \n");
     
190.                         shutdown(server_sock_fd_tcp,SHUT_RDWR);
     
191.                         close(server_sock_fd_tcp);
     
192.                 }
     
193.                
     
194. }
     

復(fù)制代碼

tcp.h頭文件

1. 
   
2. #include <arpa/inet.h>  
   
3. #include <fcntl.h>  
   
4. #include <sys/epoll.h>  
   
5. #include <sys/time.h>  
   
6. #include <sys/resource.h>  
   
7. 
   
8. #define BUFFER_SIZE_TCP 40
   
9. #define MAX_EVENTS_TCP 10
   
10. #define HOST_IP_ADDRESS_TCP "192.168.1.200"
    
11. #define HOST_PORT_TCP 4530
    
12. 
    
13. int n;
    
14. struct epoll_event ev;// epoll事件結(jié)構(gòu)體
    
15. 
    
16. int epoll_fd_tcp;
    
17. int tcp_send_data_to_pc(int len,char* buffer);
    
18. void tcp_initialize();
    
19. int create_epoll_tcp(unsigned int event_num);
    
20. void do_process_tcp_nowhile();
    
21. 
    

復(fù)制代碼

yulihua49

sasinop 發(fā)表于 2015-04-18 10:00
大概流程就是：main.c 主文件運(yùn)行后，接受客戶端連接，當(dāng)客戶端發(fā)相應(yīng)命令過來后，在tcp.c 文件中解析后， ...

這算是啥封裝哦！
根據(jù)你的題目，就是要寫一個(gè)函數(shù)，利用epoll進(jìn)行異步操作，讓應(yīng)用可以使用這個(gè)函數(shù)發(fā)送任何信息，屏蔽epoll的一切特性。
為完成這個(gè)任務(wù)，可能需要一些初始化工作。
http://72891.cn/thread-4174032-1-2.html
看看3樓那個(gè)，才是“封裝”，應(yīng)用只要調(diào)用那個(gè)函數(shù)即可發(fā)送任意數(shù)據(jù)，異步操作，epoll，線程池，協(xié)程之類的細(xì)節(jié)完全屏蔽。
那是一個(gè)實(shí)際可以工作的程序，不是個(gè)demo或者作業(yè)什么的。沒有給出初始化過程。

那個(gè)例子表示了什么是“封裝”。怎樣封裝的，需要對(duì)do_event()進(jìn)行逐層展開。
你的例子大量使用全局變量，無法支持多線程。

你同事的要求是對(duì)的，你要寫一個(gè)通用的發(fā)送函數(shù)，供各種場(chǎng)合用。很可能還需要個(gè)接收函數(shù)。
你的那么多行程序沒必要提供，自己留著用，只需對(duì)外提供：
初始化（構(gòu)造函數(shù)），善后（析構(gòu)函數(shù)），發(fā)送函數(shù)，接收函數(shù)即可。

人們不關(guān)心你的process，無數(shù)的應(yīng)用邏輯，可以有無數(shù)的process，他們的共同需求是在網(wǎng)上收發(fā)數(shù)據(jù)。
他們希望唯一的線程（你那個(gè)是單線程的）不要耽誤在等待IO上，又不希望復(fù)雜的異步邏輯把應(yīng)用邏輯攪得一塌糊涂。
于是，AIO -- 協(xié)程就產(chǎn)生了。

你可以拿我那個(gè)程序問問同事，要的是不是這個(gè)東西，然后再說怎么做。

linux_c_py_php

封裝性太差了，應(yīng)該先將epoll細(xì)節(jié)封裝起來，之后再封裝tcp/udp，這樣做業(yè)務(wù)才會(huì)變簡(jiǎn)單。

sasinop

回復(fù) 2# yulihua49

謝謝呀

沒法測(cè)試你的哪個(gè)函數(shù)


不知道你那個(gè)封裝的函數(shù)，是不是在一個(gè)工程里，有N多個(gè)文件時(shí)，隨意在某個(gè)文件里都可以調(diào)用，都可以來發(fā)送數(shù)據(jù)給客戶端？






   

sasinop

你同事的要求是對(duì)的，你要寫一個(gè)通用的發(fā)送函數(shù)，供各種場(chǎng)合用。很可能還需要個(gè)接收函數(shù)。

這樣好么？

一個(gè)函數(shù)比如，do (in,out) 這樣， 命令和結(jié)果一個(gè)函數(shù)扎口不好在什么地方呢？

同事那種要求：do(in), 只進(jìn)命令，，結(jié)果 send(out)，要在不同的文件，不同的命令分支調(diào)用，處理完成后，就直接把結(jié)果送出去了... 難道這樣好？

不解，請(qǐng)賜教呀

yulihua49

sasinop 發(fā)表于 2015-04-21 16:57
回復(fù) 2# yulihua49

謝謝呀

那個(gè)函數(shù)僅供學(xué)習(xí)，它是交易中間件的一部分，整個(gè)系統(tǒng)太大了，要下載整個(gè)中間件的源碼。
你用那個(gè)函數(shù)，看懂過程和概念即可，按這個(gè)思路寫自己的東西。

yulihua49

sasinop 發(fā)表于 2015-04-21 17:03
這樣好么？

一個(gè)函數(shù)比如，do (in,out) 這樣， 命令和結(jié)果一個(gè)函數(shù)扎口不好在什么地方呢？

in和out還是要分開的，比如有時(shí)是一進(jìn)一出，有時(shí)是幾進(jìn)一出，一進(jìn)幾出，只進(jìn)不出。。。。
還有，正常出，錯(cuò)誤（異常）出等等，業(yè)務(wù)邏輯什么需求都有。

所以，你只要提供 in，out就可以了，何時(shí)in，何時(shí)out，它們之前，之間，之后做了什么你就不必管了。

就像我那個(gè)程序，只管發(fā)送N字節(jié)到socket。之前，要填充包頭，包體要壓縮，加密，校驗(yàn)。。。
之后要?dú)w還資源（內(nèi)存和連接池），寫日志。。。。。。這些你管的著嗎？

你寫了個(gè)in，out，把AIO，epoll...都埋藏在這兩個(gè)函數(shù)里，外邊那些作業(yè)就容易多了。
看我的程序，知道怎么埋藏，這可是個(gè)大學(xué)問。

對(duì)了，那個(gè)windoze也很會(huì)埋，我還是跟他學(xué)的。不過他的代碼很多，你也可以用他的那個(gè)fiberized .IO, C++  的。