2

我想使用 Redis 实现轻量级作业队列（minion 需要 Postgresql）。我可以成功运行一个最小的示例，但我的完整 Mojolicious 应用程序有问题。

在startup例程和调用中如下所示。

sub startup{
    ...
    ###################### Redis part
    $self->helper(
        redis => sub {
            state $redis = Mojo::Redis2->new(server => '127.0.0.1:6379'); 
        }
    );

    $self->redis->on(message => sub {
        my ($redisself, $message, $channel) = @_;

        # PROBLEM: on morbo this is blocking
        # PROBLEM: on hypnotoad this works only sometimes 
        # - e.g., for the first time after hot deployment restart

        say "DEQUEUE: $message @ $channel";
        sleep (10); # replaces long-running operation
        say "FINISHED processing: $message @ $channel";
    });

    $self->redis->subscribe(['long_running_tasks'] => sub {
        my ($rself, $err, $res) = @_;
        say "SUBSCRIBED to channel long_running_tasks";       
    });

    $self->redis->on(connection => sub { 
        my ($self, $info) = @_;  
        say "got redis connection id: $info->{id}, group: $info->{group}, nblocking: $info->{nb}.";
    });

    $self->redis->on(error => sub {
        my ($self, $err) = @_;
        say "got redis error $err";
    });
    ######################## Redis part END
    ... 

    # route
    $manager->get('/regenerate')->to('controller#regenerate');
}


#######################
# in the Controller.pm
#######################
sub regenerate {
    my $self = shift;

    $self->redis->publish("long_running_tasks" => "regenerate");

    $self->flash(
        msg_type => 'info',
        msg      => 'Regeneration of will be executed in background.'
    );
    $self->redirect_to($self->get_referrer());
}

我在本地主机上运行 Redis 3.2.5（自制软件）。这些问题涉及代码的非确定性行为。

  • 最小的例子
    • 在 morbo 上运行良好
    • 发布动作在 hypnotoad 上执行 3 次
  • 大例子
    • 在 morbo 上，发布操作被阻止，但运行良好
    • 在 hypnotoad 上，发布操作以非阻塞方式执行，但仅在某些调用中执行（例如，热部署重启后的一些第一次调用）
      • 订阅操作总是成功的

问题在哪里？

4

0 回答 0