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 ::客