基于 SIGIO 信號的多路復用 ECHO 服務(wù)器

黑色陽光_cu

1. 
   
2. use strict;
   
3. use warnings;
   
4. use IO::Socket::INET;
   
5. use Fcntl;
   
6. use POSIX qw(EAGAIN);
   
7. 
   
8. my @socks;
   
9. my $listener = IO::Socket::INET->new
   
10. (
    
11.     Listen    => 5,
    
12.     LocalAddr => "localhost",
    
13.     LocalPort => 9000,
    
14.     Proto     => "tcp",
    
15. );
    
16. 
    
17. fcntl($listener, F_SETOWN, $);
    
18. fcntl($listener, F_SETFL, O_ASYNC);
    
19. fcntl($listener, F_SETFL, fcntl($listener, F_GETFL, 0) | O_NONBLOCK);
    
20. 
    
21. my $io_count = 0 ;
    
22. $SIG{IO} = sub { ++$io_count };
    
23. 
    
24. while (1) {
    
25.     sleep 60;
    
26.     while ($io_count > 0) {
    
27.         $io_count--;
    
28.         if (my $new_sock = $listener->accept()) {
    
29.             fcntl($new_sock, F_SETOWN, $);
    
30.             fcntl($new_sock, F_SETFL, O_ASYNC);
    
31.             fcntl($new_sock, F_SETFL, fcntl($new_sock, F_GETFL, 0) | O_NONBLOCK);
    
32.             push(@socks, $new_sock);
    
33.         }
    
34. 
    
35.         for (my $n = 0; $n <= $#socks; $n++) {
    
36.             if (sysread($socks[$n], my $buf, 8192)) {
    
37.                 syswrite($socks[$n], $buf);
    
38.             }
    
39.             else {
    
40.                 next if ($! == EAGAIN);
    
41.                 close $socks[$n];
    
42.                 splice(@socks, $n, 1) && $n--;
    
43.             }
    
44.         }
    
45.     }
    
46. }
    
47. 
    

復制代碼