anyevent

4热度

1回答

我有一个使用AnyEvent :: MQTT订阅消息队列的perl脚本。当时我希望它做的就是当它收到消息时打印出来。我对perl完全陌生，所以我使用它随附的演示代码，其中包含一些将STDIN上的任何内容作为消息发布的功能 - 这很好，我可以看到所有收到的消息。此代码如下 #!/usr/bin/perl use strict; use warnings; use AnyEvent::MQ

3热度

1回答

Howto如何处理Perl中的AnyEvent，RabbitMQ（心跳）和长时间运行的作业？

我正在实现分布式cronjob执行系统（所谓的cron计算集群）。当动作时间在那里时，Cronjobs应该排队进入消息队列（RabbitMQ）。另一方面（集群的节点/工作者）是一个Perl守护进程，它利用AnyEvent::RabbitMQ从消息队列中完全接收一个cronjob /任务/消息，处理任务并从消息队列请求另一个恰好一个cronjob /任务/消息等等。我使用RabbitMQ的心跳功能

2热度

2回答

传递一个类子例程作为回调

我正在使用一个接收回调（AnyEvent :: Socket）的模块。我想传递一个类子程序作为回调，但没有什么工作例如： tcp_server undef, $self->port,\$self->handle_connection 这是行不通的，它有关未定义变量的投诉。如果我通过了功能作为一个匿名子它的工作原理

4热度

1回答

如何使用AnyEvent :: HTTP获取页面的一部分？

有必要只读取部分页面（n字节）并关闭连接，如何在AnyEvent :: HTTP上执行此操作？

1热度

1回答

如何等待AnyEvent :: HTTP中http_request的完成？

该程序从数据库中获取作业并在等待完成所有请求后执行AnyEvent :: HTTP :: http_request，如何正确地退出程序？ #!/usr/bin/perl use strict; use AnyEvent; use AnyEvent::DBI; use AnyEvent::HTTP; my @queue; my $added = 0; my $finished =

0热度

1回答

如何默认配置AnyEvent :: DNS解析器？

如何在默认情况下配置AnyEvent::DNS解析器，我想更改max_outstanding,reuse,timeout。有一个环境变量$ENV{PERL_ANYEVENT_MAX_OUTSTANDING_DNS}，但如何更改reuse和timeout？

0热度

2回答

来自Net :: RabbitMQ的示例不起作用

我正在努力学习RabbitMQ，了解我正在开发的项目。我的研究显示使用两个库，Net :: RabbitMQ和AnyEvent :: RabbitMQ。 AnyEvent :: RabbitMQ似乎对我的需求过分巴洛克式，但Net :: RabbitMQ似乎不起作用，因为示例显示它应该。下面是我找到的一些示例代码，它与我在POD中看到的相符，但它不起作用。 #!/usr/bin/env perl

2热度

1回答

为什么不在这个AnyEvent :: Handle示例中调用on_eof？

这是我的简单服务器。当我运行它并telnet到它（端口5222），并让telnet退出它的连接时，为什么我的on_eof函数没有被调用？即为什么不是字符串“突变体!!!”印？ #!/usr/bin/perl use v5.18; use warnings; use EV; use AnyEvent; use AnyEvent::Socket; use AnyEvent::Handl

1热度

1回答

AnyEvent是否可以使用perl 5.26？

我遇到了以下错误:: Can't use an undefined value as a subroutine reference at /home/basiliscos/perl5/perlbrew/perls/perl-5.26.0/lib/site_perl/5.26.0/x86_64-linux/AnyEvent/Loop.pm line 248 ，当我下的Perl 5.26.0运行我的程

2热度

1回答

AnyEvent :: STOMP :: Client + AnyEvent :: ForkManger =间歇性错误

我想写一个进程，侦听ActiveMQ并基于消息，出去并从Web服务抓取数据，做一些处理，然后将流程数据放到另一个Web服务中。（REST/JSON）下面的模块正常工作，直到我跟其中一个不知名的webservices返回错误。我已经尝试了很多东西来捕捉错误，但无济于事。一旦Web服务发生错误，虽然我得到以下信息：事件未处理的异常回调（MESSAGE， AnyEvent :: STOMP ::客