Chinaunix

标题: 基于 SIGIO 信号的多路复用 ECHO 服务器 [打印本页]

作者: 黑色阳光_cu    时间: 2011-03-05 20:44
标题: 基于 SIGIO 信号的多路复用 ECHO 服务器
本帖最后由 黑色阳光_cu 于 2011-03-05 21:07 编辑

  1. use strict;
  2. use warnings;
  3. use IO::Socket::INET;
  4. use Fcntl;
  5. use POSIX qw(EAGAIN);

  6. my @socks;
  7. my $listener = IO::Socket::INET->new
  8. (
  9.     Listen    => 5,
  10.     LocalAddr => "localhost",
  11.     LocalPort => 9000,
  12.     Proto     => "tcp",
  13. );

  14. fcntl($listener, F_SETOWN, $);
  15. fcntl($listener, F_SETFL, O_ASYNC);
  16. fcntl($listener, F_SETFL, fcntl($listener, F_GETFL, 0) | O_NONBLOCK);

  17. my $io_count = 0 ;
  18. $SIG{IO} = sub { ++$io_count };

  19. while (1) {
  20.     sleep 60;
  21.     while ($io_count > 0) {
  22.         $io_count--;
  23.         if (my $new_sock = $listener->accept()) {
  24.             fcntl($new_sock, F_SETOWN, $);
  25.             fcntl($new_sock, F_SETFL, O_ASYNC);
  26.             fcntl($new_sock, F_SETFL, fcntl($new_sock, F_GETFL, 0) | O_NONBLOCK);
  27.             push(@socks, $new_sock);
  28.         }

  29.         for (my $n = 0; $n <= $#socks; $n++) {
  30.             if (sysread($socks[$n], my $buf, 8192)) {
  31.                 syswrite($socks[$n], $buf);
  32.             }
  33.             else {
  34.                 next if ($! == EAGAIN);
  35.                 close $socks[$n];
  36.                 splice(@socks, $n, 1) && $n--;
  37.             }
  38.         }
  39.     }
  40. }

复制代码

UNIX环境高级编程 —— 高级 IO.pdf

1.28 MB, 下载次数: 37






欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2