Mojolicious websocket redis publish/subscribe example

mojo-websocket-pubapp.pl

#!/usr/bin/env perl

# Usage:
# cpanm Mojolicious Mojo::Redis
# ./mojo-websocket-pubapp.pl daemon

use Mojolicious::Lite;
use Mojo::Redis;

websocket '/' => sub {
    my $self = shift;
    my $pub = Mojo::Redis->new;
    my $sub = $pub->subscribe('test');

    $sub->on(message => sub {
      my ($sub, $message, $channel) = @_;
      $self->send($message . ' ' . time);
    });

    $self->on(finish => sub {
        undef $self;
        undef $pub;
        undef $sub;
    });
};

app->start;