Mojo::Redis::PubSub - Publish and subscribe to Redis messages
use Mojo::Redis; my $redis = Mojo::Redis->new; my $pubsub = $redis->pubsub; $pubsub->listen("user:superwoman:messages" => sub { my ($pubsub, $message) = @_; say "superwoman got a message: $message"; }); $pubsub->notify("user:batboy:messages", "How are you doing?");
See https://github.com/jhthorsen/mojo-redis/blob/master/examples/chat.pl for example Mojolicious application.
Mojo::Redis::PubSub is an implementation of the Redis Publish/Subscribe messaging paradigm. This class has the same API as Mojo::Pg::PubSub, so you can easily switch between the backends.
This object holds one connection for receiving messages, and one connection for sending messages. They are created lazily the first time "listen" or "notify" is called. These connections does not affect the connection pool for Mojo::Redis.
See pubsub for more details.
$pubsub->on(before_connect => sub { my ($pubsub, $conn) = @_; ... });
Emitted before "connection" is connected to the redis server. This can be useful if you want to gather the CLIENT ID or run other commands before it goes into subscribe mode.
$pubsub->on(disconnect => sub { my ($pubsub, $conn) = @_; ... });
Emitted after "connection" is disconnected from the redis server.
$pubsub->on(reconnect => sub { my ($pubsub, $conn) = @_; ... });
Emitted after switching the "connection" with a new connection. This event will only happen if "reconnect_interval" is 0 or more.
$db = $pubsub->db;
Holds a Mojo::Redis::Database object that will be used to publish messages or run other commands that cannot be run by the "connection".
$conn = $pubsub->connection;
Holds a Mojo::Redis::Connection object that will be used to subscribe to channels.
$interval = $pubsub->reconnect_interval; $pubsub = $pubsub->reconnect_interval(1); $pubsub = $pubsub->reconnect_interval(0.1); $pubsub = $pubsub->reconnect_interval(-1);
The amount of time in seconds to wait to "reconnect" after disconnecting. Default is 1 (second). "reconnect" can be disabled by setting this to a negative value.
$conn = $pubsub->connection; $pubsub = $pubsub->connection(Mojo::Redis->new);
Holds a Mojo::Redis object used to create the connections to talk with Redis.
$promise = $pubsub->channels_p->then(sub { my $channels = shift }); $promise = $pubsub->channels_p("pat*")->then(sub { my $channels = shift });
Lists the currently active channels. An active channel is a Pub/Sub channel with one or more subscribers (not including clients subscribed to patterns).
$pubsub = $pubsub->json("foo");
Activate automatic JSON encoding and decoding with "to_json" in Mojo::JSON and "from_json" in Mojo::JSON for a channel.
# Send and receive data structures $pubsub->json("foo")->listen(foo => sub { my ($pubsub, $payload) = @_; say $payload->{bar}; }); $pubsub->notify(foo => {bar => 'I ♥ Mojolicious!'});
$cb = $pubsub->keyspace_listen($key, $op, sub { my ($pubsub, $message) = @_ }) }); $cb = $pubsub->keyspace_listen($key, $op, \%args, sub { my ($pubsub, $message) = @_ }) });
Used to listen for keyspace notifications. See https://redis.io/topics/notifications for more details.
$key $op and %args are optional. $key and $op will default to "*" and %args can have the following key values:
$key
$op
%args
The channel that will be subscribed to will look like one of these:
__keyspace@${db}__:$key $op __keyevent@${db}__:$op $key
db
Default database to listen for events is the database set in "url" in Mojo::Redis. "*" is also a valid value, meaning listen for events happening in all databases.
key
Alternative to passing in $key. Default value is "*".
op
Alternative to passing in $op. Default value is "*".
type
Will default to "keyevent" if $key is "*", and "keyspace" if not. It can also be set to "key*" for listening to both "keyevent" and "keyspace" events.
$pubsub = $pubsub->keyspace_unlisten(@args); $pubsub = $pubsub->keyspace_unlisten(@args, $cb);
Stop listening for keyspace events. See "keyspace_listen" for details about keyspace events and what @args can be.
@args
$cb = $pubsub->listen($channel => sub { my ($pubsub, $message) = @_ });
Subscribe to a channel, there is no limit on how many subscribers a channel can have. The returning code ref can be passed on to "unlisten".
$pubsub->notify($channel => $message);
Send a plain string message to a channel.
$promise = $pubsub->channels_p->then(sub { my $int = shift });
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command). Note that this is not just the count of clients subscribed to patterns but the total number of patterns all the clients are subscribed to.
$promise = $pubsub->numsub_p(@channels)->then(sub { my $channels = shift });
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels as a hash-ref, where the keys are channel names.
$pubsub = $pubsub->unlisten($channel); $pubsub = $pubsub->unlisten($channel, $cb);
Unsubscribe from a channel.
Mojo::Redis.
To install Mojo::Redis, copy and paste the appropriate command in to your terminal.
cpanm
cpanm Mojo::Redis
CPAN shell
perl -MCPAN -e shell install Mojo::Redis
For more information on module installation, please visit the detailed CPAN module installation guide.