tcp连接发送消息问题

xiao2004

server code:

1. 
   
2. #!/usr/bin/perl -w
   
3. #testservers
   
4. 
   
5. use strict;
   
6. my $face=qq~
   
7. ##########################################
   
8. #
   
9. #Perl_CMD
   
10. ##########################################
    
11. ~;
    
12. print $face;
    
13. undef $face;
    
14. 
    
15. my $port=23456;
    
16. my $PF_INET=2;
    
17. my $SOCK_STREAM=1;
    
18. my $proto=getprotobyname("tcp");
    
19. my $ADDR=pack('SnC4x8',$PF_INET,$port,127,0,0,1);
    
20. my $command;
    
21. $|=1;  #关闭perl内部缓冲区
    
22. socket(SERVERS,$PF_INET,$SOCK_STREAM,$proto) || die "can't build a socket\n";
    
23. bind(SERVERS,$ADDR) || die "can't bind a SOCK\n";
    
24. listen(SERVERS,2);
    
25. for(;my $paddr=accept(CLIENT,SERVERS);)
    
26. {
    
27.         recv(CLIENT,$command,240,0);
    
28.         print $command;
    
29.         #if($command and $command=~/^\/\//)
    
30.         if($command)
    
31.         {
    
32.                 my @turndate=&dir($command);
    
33.                 foreach my $onedate (@turndate) {
    
34.                         send (CLIENT,$onedate,0);
    
35.                 }
    
36.         }else{
    
37.                 print CLIENT "Error CMD format\n";
    
38.         }
    
39. }
    
40. 
    
41. close CLIENT;
    
42. sub dir
    
43. {
    
44.         my $cmd=shift;
    
45.         #$cmd=~s/^\/\/(.*)//;
    
46.         my @turncmd=`$cmd`;
    
47.         return @turncmd;
    
48. }
    

复制代码

client code:

1. 
   
2. #!/usr/bin/perl -w
   
3. #testclient
   
4. 
   
5. use strict;
   
6. my $port=23456;
   
7. my $PF_INET=2;
   
8. my $SOCK_STREAM=1;
   
9. my $proto=getprotobyname("tcp");
   
10. $|=1;
    
11. 
    
12. my $ADDR=pack('SnC4x8',$PF_INET,$port,127,0,0,1);
    
13. socket(CLIENT,$PF_INET,$SOCK_STREAM,$proto) or die "can't create socket\n";
    
14. connect(CLIENT,$ADDR) or die "can't link\n";
    
15. print "[HuaiHuai]";
    
16. while(1)
    
17. {
    
18. my $cmd=<stdin>;
    
19. 
    
20. send(CLIENT,"$cmd",0);
    
21. while(<CLIENT>)
    
22. {
    
23.         print $_;
    
24. };
    
25. print "[HuaiHuai]";
    
26. }
    
27. 
    

复制代码

网上一段代socket代码,我将其修改了一下,使其能循环读取客户端的命令,然后把结果发送过来.
不知为啥卡在
while(<CLIENT>
{
        print $_;
};
这一段代码上了...跳不出来了.请各位帮我解答一下.

兰花仙子

偶没仔细看你的program，但听你这句话：
网上一段代socket代码,我将其修改了一下,使其能循环读取客户端的命令,然后把结果发送过来.

以及你的client的单进程实现方式，就知道肯定不行了。

在一个进程里循环发送数据和读取数据，不block才怪了。
你这里需要进一步改下client，在父进程发送数据，然后fork出child，在child里接受数据。这样方可避免阻塞。

xiao2004

不知道和c中的socket有啥不同,反正在c中是不必再createthread的,
for(;my $paddr=accept(CLIENT,SERVERS)
忙乎了好久,终于发现问题出在这,总在这accept连接,前一个连接就卡了,又来一个新连接.
结果就....

shute

server code

for(;my $paddr=accept(CLIENT,SERVERS)
{
        recv(CLIENT,$command,240,0);
        print $command;
        #if($command and $command=~/^\/\//)
        if($command)
        {
                my @turndate=&dir($command);
                foreach my $onedate (@turndate) {
                        send (CLIENT,$onedate,0);
                }
        }else{
                print CLIENT "Error CMD format\n";
        }
        close CLIENT;
}

client code

while(1)
{
socket(CLIENT,$PF_INET,$SOCK_STREAM,$proto) or die "can't create socket\n";
connect(CLIENT,$ADDR) or die "can't link\n";
print "[HuaiHuai]";

my $cmd=<stdin>;

send(CLIENT,"$cmd",0);
while(<CLIENT>
{
        print $_;
};
}

你这里是因为server端没关闭client的连接，client一直以为还有数据所以阻塞了。
在c里也要自己在server上fork来接受新连接的，多进程。

xiao2004

是个好主意,但这样断断连连,是不是不太好,怎么不连一次,把该做的事做完???