4

我有一个使用 AnyEvent::MQTT 订阅消息队列的 perl 脚本。

目前我想做的就是在收到消息时打印出来。我对 perl 完全陌生，所以我使用它附带的演示代码，其中包含一些将 STDIN 上的任何内容作为消息发布的位 - 这很好用，我可以看到收到的所有消息。

此代码如下所示

#!/usr/bin/perl
use strict;
use warnings;

use AnyEvent::MQTT;
my $mqtt = AnyEvent::MQTT->new;
my $cv = $mqtt->subscribe(topic => '/AlarmMode',
                           callback => sub {
                               my ($topic, $message) = @_;
                                       print $topic, ' ', $message, "\n"
                                   });

my $qos = $cv->recv; # subscribed, negotiated QoS == $qos



  # publish line-by-line from file handle
      $cv =  $mqtt->publish(handle => \*STDIN,
                            topic => '/topic');

我遇到的问题是，如果我在评论后删除所有内容，publish line-by-line from file handle那么我的应用程序一运行就会退出。

我尝试过包含一个休眠 5 秒但不起作用的 while 循环（该应用程序看起来就像挂起）。

我知道我需要做一些事情来告诉应用程序只是为了保持活力和冷静，但我不知道那个命令是什么:-)

4

1 回答 1

6

如果您使用不支持 AE 的内容（例如sleep）进行阻止，则不会处理 AE 事件。

要在允许处理 AE 事件的同时休眠，通常使用

my $done_cv = AE::cv;
$done_cv->recv;

用于$done_cv->send;结束睡眠。例如，如果你想睡 5 秒，你会使用

my $sleep_cv = AE::cv;
my $w = AE::timer(5, 0, $sleep_cv);  # Short for AE::timer(5, 0, sub { $sleep_cv->send });
$sleep_cv->recv;
于 2016-01-17T17:46:12.890 回答