免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 1717 | 回复: 1
打印 上一主题 下一主题

请教,为什么异步的udp server[poe,AnyEvent],在recv事件里,必须有send操作? [复制链接]

论坛徽章:
0
跳转到指定楼层
1 [收藏(0)] [报告]
发表于 2012-12-20 22:09 |只看该作者 |倒序浏览
在poe,AnyEvent都试了下,比如:

1、在客户端发送多个信息,下面服务端如果没有push_send,只能接受一次信息。
use AnyEvent::Handle::UDP;
use IO::Socket::INET;

my $cv_recv = AnyEvent->condvar;

my $server = AnyEvent::Handle::UDP->new(bind => ['127.0.0.1', 20203], on_recv => \&my_recv);
print "h\n";
$cv_recv->recv;

sub  my_recv{
        my ($message, $handle, $client_addr) = @_;
        print $message,"\n";
        $handle->push_send("World", $client_addr);
}


2、下面这个也类似,如果去掉了send,也只能打印一次接收的信息。

use POE;
use IO::Socket::INET;
use constant DATAGRAM_MAXLEN => 1024;
POE::Session->create(
  inline_states => {
    _start       => \&server_start,
    get_datagram => \&server_read,
  }
);
POE::Kernel->run();
exit;

sub server_start {
  my $kernel = $_[KERNEL];
  my $socket = IO::Socket::INET->new(
    Proto     => 'udp',
    LocalPort => '20203',
  );
  die "Couldn't create server socket: $!" unless $socket;
  $kernel->select_read($socket, "get_datagram");
}


sub server_read {
  my ($kernel, $socket) = @_[KERNEL, ARG0];
  my $remote_address = recv($socket, my $message = "", DATAGRAM_MAXLEN, 0);
  return unless defined $remote_address;
  my ($peer_port, $peer_addr) = unpack_sockaddr_in($remote_address);
  my $human_addr = inet_ntoa($peer_addr);
  print "(server) $human_addr : $peer_port sent us $message\n";
  $message =~ tr[a-zA-Z][n-za-mN-ZA-M];
  send($socket, $message, 0, $remote_address) == length($message)
    or warn "Trouble sending response: $!";
}

论坛徽章:
0
2 [报告]
发表于 2012-12-21 21:32 |只看该作者
本帖最后由 fdimim 于 2012-12-21 21:32 编辑

服务端没问题。一直想错了方向。 是客户端发送之后有个recv导致的。。。
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们:huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP