首页 > 代码库 > gsoap：实现线程池处理时获取到客户端的ip

gsoap：实现线程池处理时获取到客户端的ip

2024-11-15 13:41:02   203人阅读

问题：

在使用线程池处理客户端请求时发现不能获取到客户端的ip！

原因：

    由于在server_loop注循环中只把连接字sock加到queue队列中，并没有客户端IP，所以每一次queue回调函数只能取得sock连接字，没有客户端的ip

解决方法：
    在将sock加入queue队列的同时把ip也加入到ips队列中，ips队列的长度和queue相同，而且存的数据下标要相同，取sock处理时也把IP取出来，即可得到了客户端IP

步骤：
    定义全局保存IP地址的变量
[cpp] view plaincopyprint?
  1. static unsigned long ips[MAX_QUEUE];  

    修改 enqueue函数
[cpp] view plaincopyprint?
  1. int enqueue(SOAP_SOCKET sock,unsigned long ip)//添加ip的参数  
  2. {  
  3.         int status = SOAP_OK;  
  4.         int next;  
  5.         int ret;   
  6.         if ((ret = MUTEX_LOCK(queue_cs)))  
  7.                 fprintf(stderr, "MUTEX_LOCK error %d\n", ret);  
  8.         next = (tail + 1) % MAX_QUEUE;  //1000   
  9.         if (head == next)  
  10.         {      
  11.                 /* don‘t block on full queue, 
  12.                  * 队列已满，return SOAP_EOM */  
  13.                 status = SOAP_EOM;  
  14.         }      
  15.         else   
  16.         {      
  17.                 queue[tail] = sock;  
  18.                 ips[tail] = ip;  //保存ip   
  19.                 tail = next;  
  20.                 if ((ret = COND_SIGNAL(queue_cv)))  
  21.                         fprintf(stderr, "COND_SIGNAL error %d\n", ret);  
  22.         }      
  23.         if ((ret = MUTEX_UNLOCK(queue_cs)))  
  24.                 fprintf(stderr, "MUTEX_UNLOCK error %d\n", ret);  
  25.         return status;  
  26. }  


    添加dequeue_ip()函数
[cpp] view plaincopyprint?
  1. unsigned long  dequeue_ip()  
  2. {  
  3.         unsigned long ip;  
  4.         int num=0;  
  5.         if(head == 0)  
  6.             num = MAX_QUEUE - 1;  
  7.         else   
  8.             num = head -1;  
  9.         ip = ips[num];  
  10.         return ip;  
  11. }  



修改queue回调函数函数
[cpp] view plaincopyprint?
  1. void *process_queue(void *soap)  
  2. {  
  3.         struct soap *tsoap = (struct soap*)soap;  
  4.         for (;;)  
  5.         {  
  6.                 tsoap->socket = dequeue();  
  7.                 tsoap->ip = dequeue_ip();//获取相应的ip地址  
  8.                 if (!soap_valid_socket(tsoap->socket))  
  9.                 {  
  10. #ifdef DEBUG   
  11.                         fprintf(stderr, "Thread %d terminating\n", (int)(long)tsoap->user);  
  12. #endif   
  13.                         break;  
  14.                 }  


解决！

测试：
在http_get_handler函数中测试
[cpp] view plaincopyprint?
  1.   
  1. int http_get_handler(struct soap *soap)  
  2. ｛  
  3.     。。。。。  
  4.      fprintf(stderr, "Request accepts connection from IP %d.%d.%d.%d\n",  
  5.            (int)(soap->ip>>24)&0xFF, (int)(soap->ip>>16)&0xFF,(int) (soap->ip>>8)&0xFF, (int)soap->ip&0xFF);  
  6. 。。。。。。  
  7. }  
输出：
[ruby] view plaincopyprint?
  1. Request accepts connection from IP 192.168.1.136  
  2. Request accepts connection from IP 192.168.1.136  
  3. Thread 3 finished serving request with failure 404  
  4. Error 404 fault: SOAP-ENV:Client [no subcode]  
  5. "HTTP Error: 404 Not Found"  
  6. Detail: [no detail]  
  7. Request accepts connection from IP 192.168.1.87  
  8. Request accepts connection from IP 192.168.1.87  
  9. Request accepts connection from IP 192.168.1.87  

gsoap：实现线程池处理时获取到客户端的ip


联系
我们