关于网络编程的初级问题

towerjt

这是一个服务器端的程序，客户端连上后在客户端打印“Hello World”,然后关掉客户端，
但客户在第一次连接的时候没有相应。以后就正常了。

测试客户端程序 ：telnet
测试主机：solaris

各位大侠能否指教一二



#include        <stdio.h>;
#include        <stdlib.h>;
#include        <string.h>;
#include        <memory.h>;
#include        <ctype.h>;
#include        <unistd.h>;
#include        <time.h>;
#include        <fcntl.h>;
#include        <signal.h>;
#include        <errno.h>;
#include        <stropts.h>;
#include        <poll.h>;
#include        <sys/types.h>;
#include        <sys/stat.h>;
#include        <sys/socket.h>;
#include        <netinet/in.h>;
#include        <netdb.h>;

main(int argc,char **argv)
{
        int        local_port;
        struct        sockaddr_in remote,local;
        unsigned long        rlen;
        int        sock,client_fd;
        int        status;
        struct        pollfd pd;
        char        buff[2048];
        int        i=0;
       
        local_port = atoi(argv[1]);
       
        bzero(&amp;local,sizeof(local));
        local.sin_addr.s_addr =INADDR_ANY/*inet_addr(local_addr)*/;
        local.sin_family = AF_INET;
        local.sin_port = htons(local_port);
       
        bzero(&amp;remote,sizeof(remote));
        remote.sin_family = AF_INET;
        remote.sin_addr.s_addr =INADDR_ANY /*inet_addr(remote_addr)*/;
        remote.sin_port = 0;
       
        sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
        status = bind(sock,(struct sockaddr *)(&amp;local),sizeof(local));
        if (status<0)
        {
                printf("bind %s\n",strerror(errno));
                return -1;
        }
       
        if (listen(sock,2)==-1)
        {
                printf("listen %s\n",strerror(errno));
                return -1;
        }
       
        pd.fd = sock;
        pd.events = POLLIN;
        pd.revents = 0;
       
        for(;
        {
                status = poll(&amp;pd,1,-1);
                if (status<=0)
                {
                        printf("poll %s\n",strerror(errno));
                        return -1;
                }
               
                if (pd.revents)
                {
                        pd.revents = 0;
                        rlen = sizeof(remote);
                        if (client_fd = accept(sock,(struct sockaddr *)&amp;remote,&amp;rlen)==-1)
                        {
                                printf("accept %s\n",strerror(errno));
                                close(client_fd);
                                continue;
                        }
                        printf("received a connection from %s \n",inet_ntoa(remote.sin_addr));
                        /*
                        status=recv(client_fd,&amp;buff,sizeof(buff),0);
                        printf("recv=%d\n",status);
                        printf("%s\n",buff);
                        if(status==0)
                        {
                                close(client_fd);
                                continue;
                        }
                       
                        memset(buff,sizeof(buff),0);
                        sprintf(buff,"have send %d pakages",i);
                        send(client_fd,&amp;buff,sizeof(buff),0);
                        */
                       
                        if (write(client_fd,"Hello,World\n",12)==-1)
                                perror("write error";
                       
                        i++;
                        close(client_fd);
                }
        }
}

HopeCao

请用

1. 
   
2. 代码.....
   

复制代码

towerjt

第一次提问，以后注意，请大侠继续指教

HopeCao

那你再贴一次啊！

towerjt

代码：

1. 
   
2. #include        <stdio.h>;
   
3. #include        <stdlib.h>;
   
4. #include        <string.h>;
   
5. #include        <memory.h>;
   
6. #include        <ctype.h>;
   
7. #include        <unistd.h>;
   
8. #include        <time.h>;
   
9. #include        <fcntl.h>;
   
10. #include        <signal.h>;
    
11. #include        <errno.h>;
    
12. #include        <stropts.h>;
    
13. #include        <poll.h>;
    
14. #include        <sys/types.h>;
    
15. #include        <sys/stat.h>;
    
16. #include        <sys/socket.h>;
    
17. #include        <netinet/in.h>;
    
18. #include        <netdb.h>;
    
19. 
    
20. main(int argc,char **argv)
    
21. {
    
22.         int        local_port;
    
23.         struct        sockaddr_in remote,local;
    
24.         unsigned long        rlen;
    
25.         int        sock,client_fd;
    
26.         int        status;
    
27.         struct        pollfd pd;
    
28.         char        buff[2048];
    
29.         int        i=0;
    
30.        
    
31.         local_port = atoi(argv[1]);
    
32.        
    
33.         bzero(&local,sizeof(local));
    
34.         local.sin_addr.s_addr =INADDR_ANY/*inet_addr(local_addr)*/;
    
35.         local.sin_family = AF_INET;
    
36.         local.sin_port = htons(local_port);
    
37.        
    
38.         bzero(&remote,sizeof(remote));
    
39.         remote.sin_family = AF_INET;
    
40.         remote.sin_addr.s_addr =INADDR_ANY /*inet_addr(remote_addr)*/;
    
41.         remote.sin_port = 0;
    
42.        
    
43.         sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
44.         status = bind(sock,(struct sockaddr *)(&local),sizeof(local));
    
45.         if (status<0)
    
46.         {
    
47.                 printf("bind %s\n",strerror(errno));
    
48.                 return -1;
    
49.         }
    
50.        
    
51.         if (listen(sock,2)==-1)
    
52.         {
    
53.                 printf("listen %s\n",strerror(errno));
    
54.                 return -1;
    
55.         }
    
56.        
    
57.         pd.fd = sock;
    
58.         pd.events = POLLIN;
    
59.         pd.revents = 0;
    
60.        
    
61.         for(;;)
    
62.         {
    
63.                 status = poll(&pd,1,-1);
    
64.                 if (status<=0)
    
65.                 {
    
66.                         printf("poll %s\n",strerror(errno));
    
67.                         return -1;
    
68.                 }
    
69.                
    
70.                 if (pd.revents)
    
71.                 {
    
72.                         pd.revents = 0;
    
73.                         rlen = sizeof(remote);
    
74.                         if (client_fd = accept(sock,(struct sockaddr *)&remote,&rlen)==-1)
    
75.                         {
    
76.                                 printf("accept %s\n",strerror(errno));
    
77.                                 close(client_fd);
    
78.                                 continue;
    
79.                         }
    
80.                         printf("received a connection from %s \n",inet_ntoa(remote.sin_addr));
    
81.                         /*
    
82.                         status=recv(client_fd,&buff,sizeof(buff),0);
    
83.                         printf("recv=%d\n",status);
    
84.                         printf("%s\n",buff);
    
85.                         if(status==0)
    
86.                         {
    
87.                                 close(client_fd);
    
88.                                 continue;
    
89.                         }
    
90.                        
    
91.                         memset(buff,sizeof(buff),0);
    
92.                         sprintf(buff,"have send %d pakages",i);
    
93.                         send(client_fd,&buff,sizeof(buff),0);
    
94.                         */
    
95.                        
    
96.                         if (write(client_fd,"Hello,World\n",12)==-1)
    
97.                                 perror("write error");
    
98.                        
    
99.                         i++;
    
100.                         close(client_fd);
     
101.                 }
     
102.         }
     
103. }
     
104. 
     

复制代码

towerjt

现在怎么样？

雷斯林

我试了一下，结果如下：
$ a.out 2000
received a connection from 192.168.0.47
Hello,World
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47
received a connection from 192.168.0.47

我发现你的问题出在运算符优先级上：

if (client_fd = accept(sock,(struct sockaddr *)&amp;remote,&amp;rlen)==-1)
这句话是将accept()的返回值与-1相比较，得0 (false)，然后将0赋给了client_fd，而0表示stdout，所以你的第一个连接的输出是在终端上，而不是套接字上。
那么为什么以后可以了呢？是因为，第一次执行后，你close(client_fd)，将stdout给关闭了，所以这之后，标识符0将成为第一个可用的标识符，以后的连接被accept后刚好就使用这个0来标识，而你那个错误的赋值刚好也是0，于是就瞎猫碰着死耗子，行了。应该这样写:

client_fd = accept(sock,(struct sockaddr *)&amp;remote,&amp;rlen);
if (client_fd < 0)
{
     /* error process */
}

or

if ((client_fd = accept(sock, (struct sockaddr *)&amp;remot, &amp;rlen)) < 0)
{
    ...
}

towerjt

但是，我将程序改了一下，还是一样的错

towerjt

不好意思，低级错误，我知道了再次感谢

pcerma

代码
[code]
for(;
fork();
[\code]