AnyEvent::Redis - Non-blocking Redis client
use AnyEvent::Redis; my $redis = AnyEvent::Redis->new( host => '127.0.0.1', port => 6379, encoding => 'utf8', on_error => sub { warn @_ }, ); # callback based $redis->set( 'foo'=> 'bar', sub { warn "SET!" } ); $redis->get( 'foo', sub { my $value = shift } ); my ($key, $value) = ('list_key', 123); $redis->lpush( $key, $value ); $redis->lpop( $key, sub { my $value = shift }); # condvar based my $cv = $redis->lpop( $key ); $cv->cb(sub { my $value = $_[0]->recv });
AnyEvent::Redis is a non-blocking (event-driven) Redis client.
This module is an AnyEvent user; you must install and use a supported event loop.
To create a new connection, use the new() method with the following attributes:
Required. The hostname or literal address of the server.
Optional. The server port.
Optional. Encode and decode data (when storing and retrieving, respectively) according to ENCODING ("utf8" is recommended or see Encode::Supported for details on possible ENCODING values).
"utf8"
Omit if you intend to handle raw binary data with this connection.
Optional. Callback that will be fired if a connection or database-level error occurs. The error message will be passed to the callback as the sole argument.
All methods supported by your version of Redis should be supported.
There are two alternative approaches for handling results from commands:
AnyEvent::CondVar based:
my $cv = $redis->command( # arguments to command ); # Then... my $res; eval { # Could die() $res = $cv->recv; }; warn $@ if $@; # or... $cv->cb(sub { my($cv) = @_; my($result, $err) = $cv->recv });
Callback:
$redis->command( # arguments, sub { my($result, $err) = @_; });
(Callback is a wrapper around the $cv approach.)
$cv
The subscription methods (subscribe and psubscribe) must be used with a callback:
subscribe
psubscribe
my $cv = $redis->subscribe("test", sub { my($message, $channel[, $actual_channel]) = @_; # ($actual_channel is provided for pattern subscriptions.) });
The $cv condition will be met on unsubscribing from the channel.
Due to limitations of the Redis protocol the only valid commands on a connection with an active subscription are subscribe and unsubscribe commands.
get
set
hset
hget
lpush
lpop
The Redis command reference (http://redis.io/commands) lists all commands Redis supports.
This requires Redis >= 1.2.
Tatsuhiko Miyagawa <miyagawa@bulknews.net> 2009-
This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.
Tatsuhiko Miyagawa
David Leadbeater
Chia-liang Kao
franck cuny
Lee Aylward
Joshua Barratt
Jeremy Zawodny
Leon Brocard
Michael S. Fischer
Redis, AnyEvent
To install AnyEvent::Redis, copy and paste the appropriate command in to your terminal.
cpanm
cpanm AnyEvent::Redis
CPAN shell
perl -MCPAN -e shell install AnyEvent::Redis
For more information on module installation, please visit the detailed CPAN module installation guide.