[请教]一个客户端/服务器程序【已解决】

litao19

已解决，问题是应该在客户端线程中connect



客户端有多个线程向服务器发请求，但只能返回一个结果，或一个结果都不返回。
服务器端预先创建多个线程，各个线程各自accept。代码如下，请大家看看哪里出错了。
服务器端代码：

1. 
   
2. //服务线程
   
3. void *serviceThread(void *arg)
   
4. {
   
5.         if (pthread_detach(pthread_self()) != 0) {
   
6.                 g_Log.writeLog(FA, "Thread Detach Error...");
   
7.                 exit(-1);
   
8.         }
   
9. 
   
10.         g_Log.writeLog(D1, "new Service Thread");
    
11. 
    
12.         int listenfd = *(int *)arg;
    
13.         int connfd;
    
14.         socklen_t clilen;
    
15.         struct sockaddr cliaddr;
    
16.         for ( ; ; ) {
    
17.                 clilen = sizeof(cliaddr);
    
18.                 pthread_mutex_lock(&g_acptLock);
    
19.                 connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &clilen);
    
20.                 if (connfd < 0) {
    
21.                         g_Log.writeLog(ER, "Accept Error...");
    
22.                         pthread_mutex_unlock(&g_acptLock);
    
23.                         continue;
    
24.                 }
    
25.                 pthread_mutex_unlock(&g_acptLock);
    
26.                 doService(connfd);
    
27.                 close(connfd);
    
28.         }
    
29. 
    
30.         return NULL;
    
31. }
    
32. 
    
33. void doService(int &sockfd)
    
34. {
    
35.          for ( ; ; ) {
    
36.                    //从sockfd读数据，处理后，向sockfd写数据
    
37.          }
    
38. }
    

复制代码

客户端代码：

1. 
   
2. int main(int argc, char **argv)
   
3. {
   
4.         // init Log
   
5.         if(g_Log.init("./logs", "dnsLog", 10485760, 1) < 0){
   
6.                 cerr << "Init log error!" << endl;
   
7.                 exit(-1);
   
8.         };
   
9. 
   
10.         int sockfd;
    
11.         struct sockaddr_in servaddr;
    
12. 
    
13.         if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
    
14.                 cerr << "Socket Error" << endl;
    
15.                 exit(-1);
    
16.         }
    
17.        
    
18.         bzero(&servaddr, sizeof(servaddr));
    
19.         servaddr.sin_family = AF_INET;
    
20.         servaddr.sin_port = htons(8002);
    
21.         if(inet_pton(AF_INET, "****", &servaddr.sin_addr) != 1) {
    
22.                 cerr << "inet_pton error" << endl;
    
23.                 exit(-1);
    
24.         }
    
25.         if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
    
26.                 cerr << "Connect Error" << endl;
    
27.                 exit(-1);
    
28.         }
    
29. 
    
30. 
    
31.         uint32_t thrdNum = 10;
    
32.         pthread_t threads[thrdNum];
    
33.         for (uint32_t i = 0; i < thrdNum; i++) {
    
34.                 if (pthread_create(&threads[i], NULL, &requestIP, (void *)&sockfd) != 0) {
    
35.                         cerr << "Thread Create Error..." << endl;
    
36.                         exit(-1);
    
37.                 }
    
38.         }
    
39. 
    
40.         for ( ; ; )
    
41.                 pause();
    
42. 
    
43.         return 0;
    
44. }
    
45. void *requestIP(void *arg)
    
46. {
    
47.         //向sockfd写数据，然后接收数据
    
48. }
    

复制代码

[ 本帖最后由 litao19 于 2008-7-24 15:52 编辑 ]