使用 Event::Lib 制作 perl 聊天客户端

Question

我正在尝试学习 perl 以及事件驱动编程。我制作了一个客户端，它附加到特定的 IP 和端口号，并通过套接字侦听消息。

my $socket = new IO::Socket::INET (
PeerHost => $server,
PeerPort => '5000',
Proto => 'tcp',
);

然后我监听服务器消息，并且我想从 STDIN 读取。为此，我尝试使用 CPAN 中的库 Event::Lib 实现事件编程

sub do_client{
my ($ev,$type) = @_;
my $event = shift;
my $fh = $event->fh;
$cl_data = <$fh>;
chomp $cl_data;
print $socket "$cl_data\r\n";
$event->add; 
}

sub do_server{
my ($ev,$type) = @_;
my $event = shift;
my $fh = $event->fh;
$sv_data = <$fh>;
chomp $sv_data;
print "$sv_data\n";
$event->add;
}


event_new($socket, EV_WRITE, \&do_server)->add;
event_new(STDIN, EV_WRITE, \&do_client)->add;
event_mainloop;

现在问题来了。在从套接字读取的每一行之后，我认为处理程序会转到 STDIN 事件并等待我的返回。如果我不从键盘按返回，则处理程序永远不会从套接字读取并打印它。 （它没有同步客户端和服务器通信）

这是我获得输出的方式。

Connection established
[Server]
    **** waits here for me to enter return *** 
Whats your name?

我正在尝试制作一个聊天客户端。因此，每当我向终端写入信息时，它都应该转到 STDIN 事件，并在套接字中有消息时打印出消息。 请告诉我在这里做错了什么。

Answer 1

您可能希望在代码中使用更高级别的模块。当您执行<STDIN> 时，它会阻塞

AnyEvent 通过事件驱动编程提供非阻塞 IO

   my $w; $w = AnyEvent->io (fh => \*STDIN, poll => 'r', cb => sub {
      chomp (my $input = <STDIN>);
      warn "read: $input\n";
      undef $w;
   });

这将在 STDIN 上不阻塞，然后用

清除观察者

undef $w;