高手帮帮忙，socket的问题。

liexusong

本来打算是初始化一个队列，然后开两个进程，一个接收请求并把接收结果入队列，另外一个是出队列的，但是不知道为什么总出队列进程一直打印队列是空的。队列的程序没有错的，我测试过了很多遍了。请各位帮帮忙吧。

1. 
   
2. #include <pthread.h>
   
3. #include <sys/types.h>
   
4. #include <sys/socket.h>
   
5. #include <unistd.h>
   
6. #include <netinet/in.h>
   
7. #include <stdio.h>
   
8. #include <stdlib.h>
   
9. #include <string.h>
   
10. #include "queue.h"
    
11. 
    
12. #define BACKLOG 1024
    
13. 
    
14. static queue *global_queue = NULL;//队列全局变量
    
15. 
    
16. void server(int argc, char **argv);
    
17. void working();
    
18. 
    
19. void destroy(void *arg) {
    
20.         free(arg);
    
21. }
    
22. 
    
23. /* recv: "id:domain" */
    
24. void *proccess(void *arg) {
    
25.         int fd = *(int *)arg;
    
26.         char buffer[1024];
    
27.         ssize_t readsize;
    
28.         char *entry;
    
29.        
    
30.         readsize = recv(fd, buffer, 1024, MSG_DONTWAIT);
    
31.        
    
32.         queue_entry(global_queue, strdup(buffer)); //入队列
    
33. 
    
34.         send(fd, "OK", strlen("OK"), MSG_DONTWAIT);
    
35.         close(fd);
    
36.        
    
37.         pthread_exit(NULL);
    
38. }
    
39. 
    
40. int main(int argc, char **argv) {
    
41.         global_queue = queue_init();//初始化队列
    
42.         pid_t pid;
    
43.        
    
44.         pid = fork();
    
45.         if (pid == 0) {
    
46.                 server(argc, argv);
    
47.         } else if (pid > 0) {
    
48.                 working();
    
49.         } else {
    
50.                 printf("Can not fork.\n");
    
51.         }
    
52.        
    
53.         return 0;
    
54. }
    
55. 
    
56. void server(int argc, char **argv) {
    
57.         int serverfd, clientfd;
    
58.         struct sockaddr_in server_addr;
    
59.         struct sockaddr_in client_addr;
    
60.         int err;
    
61.         pthread_t pid;
    
62.         int port;
    
63.        
    
64.         if (argc != 3) {
    
65.                 fprintf(stderr, "Error: server <ip> <port>.\n");
    
66.                 return;
    
67.         }
    
68.        
    
69.         port = atoi(argv[2]);
    
70.        
    
71.         if (global_queue == NULL) {
    
72.                 fprintf(stderr, "Can not create queue.\n");
    
73.                 return;
    
74.         }
    
75.        
    
76.         serverfd = socket(AF_INET, SOCK_STREAM, 0);
    
77.         if (serverfd < 0) {
    
78.                 fprintf(stderr, "Can not open socket.\n");
    
79.                 return;
    
80.         }
    
81.        
    
82.         bzero(&server_addr, sizeof(server_addr));
    
83.         server_addr.sin_family = AF_INET;
    
84.         server_addr.sin_addr.s_addr = inet_addr(argv[1]);
    
85.         server_addr.sin_port = htons(port);
    
86.        
    
87.         err = bind(serverfd, (struct sockaddr *)&server_addr, sizeof(server_addr));
    
88.         if (err < 0) {
    
89.                 fprintf(stderr, "Can not bind socket.\n");
    
90.                 return;
    
91.         }
    
92.        
    
93.         err = listen(serverfd, BACKLOG);
    
94.         if (err < 0) {
    
95.                 fprintf(stderr, "Can not listen socket.\n");
    
96.                 return;
    
97.         }
    
98.        
    
99.         for (;;) {
    
100.                 int addrlen = sizeof(struct sockaddr);
     
101.                
     
102.                 clientfd = accept(serverfd, (struct sockaddr *)&client_addr, &addrlen);
     
103.                 if (clientfd < 0) {
     
104.                         printf("Can not accept socket.\n");
     
105.                         continue;
     
106.                 }
     
107.                
     
108.                 err = pthread_create(&pid, NULL, proccess, &clientfd);
     
109.                 if (err < 0) {
     
110.                         printf("Can not create pthread.\n");
     
111.                         close(clientfd);
     
112.                 }
     
113.         }
     
114.        
     
115.         queue_destroy(global_queue, destroy);
     
116. }
     
117. 
     
118. void working() {
     
119.         char *entry;
     
120.         for (;;) {
     
121.                 if (!queue_empty(global_queue)) {//如果队列不为空
     
122.                         entry = (char *)queue_front(global_queue);//出队列
     
123.                        
     
124.                         printf("%s\n", entry);
     
125.                 }
     
126.                 sleep(2);
     
127.         }
     
128.        
     
129.         return;
     
130. }
     

复制代码

liexusong

请解谢谢！！

chenzhanyiczy

为什么每个客户有一个线程了，还要用到：MSG_DONTWAIT标记 ？
如果网络慢，而此时线程运行到recv()，由于recv()有MSG_DONTWAIT，它不等数据的到达就返回了，不是就接收不到数据了。

另外：
pthread_create(&pid, NULL, proccess, &clientfd);

这个有隐患

liexusong

为什么每个客户有一个线程了，还要用到：MSG_DONTWAIT标记 ？
如果网络慢，而此时线程运行到recv()，由于r ...
chenzhanyiczy 发表于 2010-10-15 17:19

    请问怎么设计呢？我第一次写服务端程序的！

chenzhanyiczy

最简单的：
while()
{
  recv();   不要加MSG_DONTWAIT,MSG_DONTWAIT是非阻塞的
  send();
}

另外，队列有锁吗？

pengjianbokobe

楼主解决没？

ydfgic

应该是MSG_WAITALL 吧？ recv那里

liexusong

我觉得是申请了两个进程的问题。

xiexiecn

你这个queue是怎么实现的，进程之间是不共享全局变量的。如果你是自己搞的链表之类的做的，就算新数据放入了队列，另外一个进程也是收不到的。