用Perl如何实现高效稳定的Socket Server?

duketang

在运行一段时间后 进程就会死掉

#!/usr/bin/perl
use strict;
use IO::Socket;
my $server = IO::Socket::INET->new
(
        LocalPort =>2008,
        Type      =>SOCK_STREAM,
        Reuse     =>1,
        Listen    =>SOMAXCONN
)or die "Cound not create server!n";
my $client;
my $child_pid;
my $line;
while($client = $server->accept())
{
        unless (defined($child_pid=fork())) {die "Cound not create fork!n"};
        if($child_pid)
        {
                while($line=<$client>)
                {
                        print $line;
                }
        }else{
                while($line=<>)
                {
                        print $client $line;
                }
        }
}

兰花仙子

原帖由 duketang 于 2005-11-18 19:09 发表
在运行一段时间后 进程就会死掉

#!/usr/bin/perl
use strict;
use IO::Socket;
my $server = IO::Socket::INET->new
(
        LocalPort =>2008,
        Type      =>SOCK_STREAM,
         ...

while($client = $server->accept())
这里你这样写，不死掉才怪呢。

另外，要调用waitpid来回收child process。只创建，不回收，会对OS很不利的。

flw

Please use POE::Component::Server::TCP, it maybe a good choice for you.

1. use POE;
   
2. use POE::Component::Server::TCP;
   
3. 
   
4. POE::Component::Server::TCP->new(
   
5.     Port            => 9999,
   
6.     ClientConnected => sub {
   
7.                             $_[HEAP]->{client}->put( "Welcome!" );
   
8.                         },
   
9.     ClientInput     => sub {
   
10.                             my $msg = $_[ARG0];
    
11.                             $_[HEAP]->{client}->put( "Your said: $msg" );
    
12.                         },
    
13. );
    
14. 
    
15. POE::Kernel->run();

复制代码

For more information, please visit http://poe.perl.org/

[ 本帖最后由 flw 于 2005-11-18 20:42 编辑 ]

freeand

对啊，有没有用perl写的比较成熟的成品啊。。。

duketang

修改后 可以了
#!/usr/bin/perl
use strict;
use IO::Socket;
use POSIX 'WNOHANG';
use constant PORT => 2008;

my $quit        =       0;
$SIG{CHLD}      = sub   {while(waitpid(-1,WNOHANG)>0){}};
$SIG{INT}       = sub   {$quit++};
my $i=1;
my $server_socket       =       IO::Socket::INET->new
(
        LocalPort       =>      PORT,
        Listen          =>      SOMAXCONN,
        Proto                   =>      'tcp',
        Reuse                   =>      1,
        Timeout         =>      60
) or die "ERROR!n";
while(!$quit)
{
        next unless my $connection = $server_socket->accept;
        defined(my $child = fork()) or die "error!n";
        if($child == 0)
        {
                print "Line ".$i."   ";
                $server_socket->close;
                repeat_server($connection);
                exit 0;
        }

        $connection->close;
        $i++;
}

sub repeat_server
{
        my $sock = shift;
        while(my $line = <$sock>)
        {
                print $line;
        }
}

duketang

项这样的 每秒钟最多能承受多少连接？

兰花仙子

原帖由 duketang 于 2005-11-19 18:33 发表
项这样的 每秒钟最多能承受多少连接？

做个压力测试不就知道了嘛，几百个连接没问题的。
当然，还得取决于你的主机配置。

duketang

我现在最大只能达到八百多 实际环境中
如果在这段程序中实现对多个数据库发送query速度会慢多少？
数据库连接在前面初始化好 只在repeat_server中进行发送query的操作
没有检索 只是update delete ..等不需要数据返回的操作

兰花仙子

原帖由 duketang 于 2005-11-19 18:48 发表
我现在最大只能达到八百多 实际环境中
如果在这段程序中实现对多个数据库发送query速度会慢多少？
数据库连接在前面初始化好 只在repeat_server中进行发送query的操作
没有检索 只是update delete ..等不需要 ...

同时连接800多相当不错了，可别对perl socket期望太高。
数据库查询不是你的程序的性能瓶颈，如果数据库本身性能不错的话。

freeand

原帖由 兰花仙子 于 2005-11-19 20:01 发表


同时连接800多相当不错了，可别对perl socket期望太高。

为什么这样说？
没希望了？