ACE在android上应用老是提示Connection Refused

iwojima

我把ACE源码移植到android上，通过JNI调用方法，手机作为Client，linux作为server，做一个简单的消息交互Demo，奇怪的是，同样的代码，在PC与PC之间就没问题，但在android和PC间就一直报errno=111 Connection Refused

先贴android上的client端代码：

1. int ACE_Agent::init(const char *strPort , const char *strHost)
   
2. {
   
3.     if ( !strPort || !strHost )
   
4.         {
   
5.                 return -1;
   
6.         }
   
7.         mConnector = new ACE_SOCK_Connector();
   
8.        
   
9.         mAddr.set(strPort , strHost);
   
10.         ACE_Time_Value timeout(5);
    
11.        
    
12.         int result = mConnector->connect(mStream , mAddr , &timeout);
    
13.         if( 0 != result )
    
14.         {
    
15.                 LOGE("*ERROR* Fail to Connect the Server ! result = %d errno = %d , strerr = %s 10s\n",result,errno,strerror(errno));
    
16.                 return -1;
    
17.         }
    
18.        
    
19.         IsInit = true;
    
20.        
    
21.         LOGI("ACE Init Success !\n");
    
22.        
    
23.         //show_internet_address();
    
24.        
    
25.         return 0;
    
26. }

复制代码

server端的代码：

1. void *pthread_function_one(void *pArg)
   
2. {
   
3.         int result = 0 , width = 0;
   
4.         ACE_Handle_Set active_handle_set;
   
5. 
   
6.         std::map<std::string , ACE_SOCK_Stream>::iterator iter;
   
7.        
   
8. struct timeval tv = {1, 0};
   
9. ACE_Time_Value atv(tv);
   
10. 
    
11. printf("max_set = %d\n",(int)handle_set.max_set());
    
12.        
    
13.         while ( 1 )
    
14.         {
    
15.                 active_handle_set = handle_set;
    
16.                 width = (int)active_handle_set.max_set() + 1; //max_set() Returns the number of the large bit.  UNIX下最大描述符+1
    
17. 
    
18.                 if (ACE::select(width , &active_handle_set , 0 , 0 , &atv) < 1)  //ACE::select 返回活动的句柄数目
    
19.                 {
    
20.                         continue;
    
21.                 }
    
22. 
    
23.                 /*
    
24.                 for(int i = 0; i < active_handle_set.num_set() ; i++)
    
25.                 {
    
26.                         printf("handle = %d , num_set = %d\n",i ,active_handle_set.num_set());
    
27.                 }
    
28.                 */
    
29.                
    
30.                 int set_size = active_handle_set.num_set();
    
31.                 if (set_size > 0)
    
32.                 {
    
33.                         std::cout<<"set_size = "<<set_size<<std::endl;
    
34.                 }
    
35.                
    
36.                
    
37.                 #if 0  //普通的ACE_Handle_Set轮询
    
38.                 for (iter = STRING_STREAM.begin() ; iter != STRING_STREAM.end() ; iter++)
    
39.                 {
    
40.                         if (active_handle_set.is_set((iter->second).get_handle()))
    
41.                         {
    
42.                                 ACE_INET_Addr inet_addr;
    
43.                                 (iter->second).get_remote_addr(inet_addr);
    
44.                                 std::cout<<"<==== The Data from "<<inet_addr.get_host_addr()<<" ====>"<<std::endl;
    
45.                                 handle_data(iter->second);
    
46.                                 active_handle_set.clr_bit(iter->second.get_handle());
    
47.                         }
    
48.                 }
    
49.                 #endif
    
50.                
    
51.                
    
52.                 ACE_Handle_Set_Iterator iterator(active_handle_set);
    
53.                 //ACE_Handle_Set_Iterator迭代
    
54.                 ACE_SOCK_Stream tmp;
    
55.                
    
56.                 ACE_HANDLE handle = iterator();
    
57.                
    
58.                 for ( ;handle != ACE_INVALID_HANDLE; handle = iterator())
    
59.                 {
    
60.                         //
    
61.                         ACE_INET_Addr inet_addr;
    
62.                         tmp.set_handle(handle);
    
63.                         tmp.get_remote_addr(inet_addr);
    
64.                         std::cout<<"<==== The Data from "<<inet_addr.get_host_addr()<<" ====>"<<std::endl;
    
65.                         handle_data(tmp);
    
66.                 }
    
67.                
    
68.                
    
69.         }
    
70. }
    

复制代码

iwojima

防沉啊，自顶！

iwojima

再顶！ 顶顶顶