将socket服务器端程序放入多线程后接收不到数据？

dolphin836

写了一个服务器端/客户端的socket程序。在本机上测试，运行正常。

有一个不明白的地方：我客户端连接的地址是127.0.0.1,但是服务器端读出来的时候，第一次不是127.0.0.1,。具体可见下面的输出信息：
服务器端代码：

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <unistd.h>
   
5. #include <ctype.h>
   
6. #include <sys/socket.h>
   
7. #include <arpa/inet.h>
   
8. #include <string.h>
   
9. 
   
10. #define MAX_LINE 200
    
11. 
    
12. void my_fun(char * p)
    
13. {
    
14.         if(p == NULL)
    
15.                 return;
    
16. 
    
17.         for (; *p != '\0'; p++)
    
18.                 if(*p >= 'A' && *p <= 'Z')
    
19.                         *p = *p -'A'+ 'a';
    
20. }
    
21. 
    
22. int main(void)
    
23. {
    
24.      struct sockaddr_in sin;
    
25.      struct sockaddr_in cin;
    
26. 
    
27.      int l_fd;
    
28.      int c_fd;
    
29.      socklen_t len;
    
30.      char buf[MAX_LINE];
    
31.      char savebuf[200];
    
32.      char addr_p[INET_ADDRSTRLEN];
    
33.      int port = 8000;
    
34.      int n;
    
35. 
    
36.      bzero(&sin, sizeof(sin));
    
37.      sin.sin_family = AF_INET;
    
38.      sin.sin_addr.s_addr = INADDR_ANY;
    
39.      sin.sin_port = htons(port);
    
40.    
    
41.      l_fd = socket(AF_INET, SOCK_STREAM, 0);
    
42.        
    
43.      bind(l_fd, (struct sockaddr *)&sin, sizeof(sin));
    
44.        
    
45.      listen(l_fd, 10);
    
46.        
    
47.      printf("waiting ...\n");
    
48.    
    
49.         while(1)
    
50.         {
    
51.                 c_fd = accept(l_fd, (struct sockaddr *) &cin, &len);
    
52. 
    
53.                 n = read(c_fd, buf, MAX_LINE);
    
54. 
    
55.                 inet_ntop(AF_INET, &cin.sin_addr, addr_p, sizeof(addr_p));
    
56. 
    
57.                 printf("client IP is %s, port is %d\n", addr_p, ntohs(sin.sin_port));
    
58.                 printf("buf:%s \n",buf);
    
59.                 my_fun(buf);
    
60.                 write(c_fd, buf, n);
    
61.                 close(c_fd);
    
62.         }
    
63. 
    
64.         if(close(l_fd) == -1){
    
65.                 perror("fail to close");
    
66.                 exit(1);
    
67.         }
    
68. 
    
69.         return 0;
    
70. }
    

复制代码

客户端代码：

1. 
   
2. #include <stdio.h>
   
3. #include <unistd.h>
   
4. #include <sys/types.h>
   
5. #include <sys/socket.h>
   
6. #include <arpa/inet.h>
   
7. #include <string.h>
   
8. 
   
9. #define MAX_LINE 200
   
10. 
    
11. int main(int argc, char *argv[])
    
12. {
    
13.      struct sockaddr_in sin;
    
14.      char buf[MAX_LINE];
    
15.      int sfd;
    
16.      int port = 8000;
    
17.      char *str = "TEST STRING";
    
18. 
    
19.      if (argc > 1)
    
20.           str = argv[1];
    
21. 
    
22.      bzero(&sin, sizeof(sin));
    
23.      sin.sin_family = AF_INET;       
    
24.      inet_pton(AF_INET, "127.0.0.1", &sin.sin_addr);
    
25.      sin.sin_port = htons(port);
    
26. 
    
27.      sfd = socket(AF_INET, SOCK_STREAM, 0);
    
28.      connect(sfd, (struct sockaddr_in *)&sin, sizeof(sin));
    
29.      write(sfd, str, strlen(str) + 1);
    
30.      read(sfd, buf, MAX_LINE);
    
31. 
    
32.      printf("recive from server: %s\n", buf);
    
33.      close(sfd);
    
34. 
    
35.      return 0;
    
36. }
    

复制代码

程序输入输出信息：

1. input:
   
2. [root@localhost 2]# ./client "wwwwwwww"
   
3. recive from server: wwwwwwww
   
4. [root@localhost 2]# ./client "wwwwwwww"
   
5. recive from server: wwwwwwww
   
6. [root@localhost 2]# ./client "wwwwwwww"
   
7. recive from server: wwwwwwww
   
8. [root@localhost 2]# ./client "wwwwwwww"
   
9. recive from server: wwwwwwww
   
10. 
    
11. output:
    
12. [root@localhost 2]# ./server
    
13. waiting ...
    
14. client IP is 56.249.234.191, port is 8000     //为什么这里得到的IP不是127.0.0.1
    
15. buf:wwwwwwww
    
16. client IP is 127.0.0.1, port is 8000
    
17. buf:wwwwwwww
    
18. client IP is 127.0.0.1, port is 8000
    
19. buf:wwwwwwww
    
20. client IP is 127.0.0.1, port is 8000
    
21. buf:wwwwwwww

复制代码

dolphin836

然后我将服务器端的代码放入一个多线程中，
main函数的代码为：

1. 
   
2. int main(int argc, char *argv[])
   
3. {
   
4.         pthread_t t;                        
   
5.           pthread_create(&t,NULL,mysocket,NULL);   //socket
   
6.         while(1)
   
7.         {
   
8.         }
   
9. 
   
10.         return 0;
    
11. }
    

复制代码

多线程函数mysocket与上面服务器端代码一样。

运行后只能得到：

1. 
   
2. client IP is 56.249.234.191, port is 8000
   

复制代码

IP地址还会不一样。没有接收到客服端发送的数据。

请大家帮我分析一下，问题可能出在上面地方？

如果以后不是在本机运行，是不是只要将服务器的IP知道告知客户端，让客户端去连接这个IP就可以？

端口是服务器端指定的，还是客服端自己定就可以了？

初学者，往指导。

linux_c_py_php

len你没有赋值, 这是一个in/out参数, 你需要len = sizeof(struct sockaddr_in);

dolphin836

回复 3# linux_c_py_php


眼神真犀利 是的。

这是我在拷贝代码的时候犯的错。实际的程序是有这一句的。谢谢。


   

dolphin836

没人知道啊。

dolphin836

问题解决了

自己2了  

把多线程里面的输出语句注释掉了。。。。

上面的代码调试通过