请问perl不使用【IO::Socket、POE】，如何建立非阻塞socket？

suposonic

RT，

另外，connect时候，不使用alarm，如何设置超时？

兰花仙子

不用IO::Socket也起码要用到Socket.pm吧，否则如何进行socket编程？
非阻塞Socket与用不用IO::Socket无关，它是一套机制，需要相关技巧来实现，ie, IO::Select.
可google with "perl non-blocking socket".

suposonic

1. # create a client socket for caller.
   
2. sub client_socket()
   
3. {
   
4.     my ($proto) = -1;
   
5.     $proto = getprotobyname('tcp');
   
6.     my ($host) = shift(@_);
   
7.     my ($port) = shift(@_);
   
8.     #my ($hd_socket) = undef ;
   
9. 
   
10.     # get the address of socket handle.
    
11.     my ($hd_socket) = shift(@_) ;
    
12. 
    
13.     $host = inet_aton($host);
    
14. 
    
15.     # port on the IP address for the remote host
    
16.     my $servaddr = sockaddr_in($port, $host);
    
17. 
    
18.     socket($$hd_socket, PF_INET, SOCK_STREAM, $proto) or die "Unable to create socket: $!";
    
19.     setsockopt ($$hd_socket, SOL_SOCKET, SO_REUSEADDR,1) or die "setsockopt err";
    
20. 
    
21.     bind($$hd_socket, sockaddr_in(0, inet_aton($ip_bind))) or die "Unable to bind: $!";
    
22. my $t_connect_ret = connect($$hd_socket, $servaddr) ; #or die "Unable to connect: $!";
    
23. return  $t_connect_ret ;
    
24. }

复制代码

我的问题是在 connect 时候挂死，原因是传入IP不可达，请问有没有办法为此connect设置超时（不想使用alarm）？
这样就不会阻塞在这里了。

黑色阳光_cu

1. 
   
2. #!/bin/env perl
   
3. 
   
4. use strict;
   
5. use warnings;
   
6. use Socket;
   
7. use Fcntl;
   
8. use IO::Select;
   
9. 
   
10. my $socket = &socket_init("192.168.2.3", 80, 5);
    
11. 
    
12. sub socket_init
    
13. {
    
14.         my ($host, $port, $timeout) = @_;
    
15.         my $socket;
    
16.         my $dest;
    
17. 
    
18.         if (socket($socket, PF_INET, SOCK_STREAM, 6))
    
19.         {
    
20.                 if ($^O eq 'MSWin32')
    
21.                 {
    
22.                         my $nonblocking = pack('L', 1);
    
23.                         ioctl($socket, 0x8004667e, unpack('I', pack('P', $nonblocking)));
    
24.                 }
    
25.                 else
    
26.                 {
    
27.                         fcntl($socket, F_SETFL, fcntl($socket, F_GETFL, 0) | O_NONBLOCK);
    
28.                 }
    
29. 
    
30.                 my $dest = sockaddr_in($port, inet_aton($host));
    
31.                 connect($socket, $dest);
    
32.                 my $select = new IO::Select($socket);
    
33.                 my ($read_set, $write_set, $error_set) = IO::Select->select(undef, $select, $select, $timeout);
    
34.                 if ($#$write_set > -1 and $#$error_set == -1)
    
35.                 {
    
36.                         ;
    
37.                 }
    
38.                 else
    
39.                 {
    
40.                         warn "$^E\n";
    
41.                         $socket = undef;
    
42.                 }
    
43.         }
    
44. 
    
45.         return $socket;
    
46. }
    

复制代码

黑色阳光_cu

1 把套接字句柄设成非阻塞的，这样子connect是马上返回的。
2 用IO::Select去监视句柄的状态，当正常连接上时，$#$write_set大于-1而且$#$error_set等于-1。当$timeout秒没连接上时，IO::Select返回-1 -1 -1

hitsubunnu

use Coro::Socket;
use Coro::Timer；

10行代码搞定

suposonic

已经通过select方式搞定。
谢谢各位的帮忙！

1.     connect($$hd_socket, $servaddr) ;
   
2.     my $sel_socket = new IO::Select($$hd_socket);
   
3.     my ($read_set, $write_set, $error_set) = IO::Select->select($sel_socket, $sel_socket, $sel_socket, $TIMEOUT);
   
4.     if ($#$write_set > -1 and $#$error_set == -1)
   
5.     {
   
6.         if ($#$read_set == 0 || $sel_socket->can_read(0))
   
7.         {
   
8.             print "connect refused.\n";
   
9.             $$hd_socket = undef;
   
10.             return -1;
    
11.         }
    
12.         return 1;
    
13.     }
    
14.     else
    
15.     {
    
16.         print "unreachable host.\n";
    
17.         $$hd_socket = undef;
    
18.         return -1;
    
19.     }

复制代码

PS： 是不是非阻塞socket，使用sysread读写是不是需要特殊处理？
直接调用 sysread($hd_tmp, $$buf_recv, 204  为啥收不到东西？

黑色阳光_cu

已经通过select方式搞定。
谢谢各位的帮忙！PS： 是不是非阻塞socket，使用sysread读写是不是需要特殊处理 ...
suposonic 发表于 2010-06-02 10:00

最简单的 connect上以后 把套接字句设再设为阻塞式

非阻塞的，每次读写前都要用select判断可读写

suposonic

这个方式我试了，但是貌似不行。。。
我的方式如下：

1. my $save_fl = fcntl($$hd_socket, F_GETFL, 0);
   
2. fcntl($$hd_socket, F_SETFL, fcntl($$hd_socket, F_GETFL, 0) | O_NONBLOCK);

复制代码

然后，我设置回来的时候使用如下方法：

1. fcntl($$hd_socket, F_SETFL,  $save_fl );

复制代码

貌似不好用，请问是不是哪里处理的不妥？

suposonic