Perl Anyevent, nicht blockierende Redis Push

Question

Ich habe den folgenden Code zu tun, nicht blockieren rpush in einem Redis-Server Wenn ich dies für nur 1 rpush, funktioniert der Code gut Aber wenn ich dies in einer Weile das Skript ausführen hängt nach der ersten Ausführung. Warum?

#!/usr/bin/perl                                       
use AnyEvent; 
use AnyEvent::Redis::RipeRedis; 
use strict; 
#my $cv = AE::cv();                                      

my $redis = AnyEvent::Redis::RipeRedis->new(
    host  => 'localhost', 
    port  => '6379', 
    ); 

my $i=0; 

my $cv; 
while($i++ < 5) { 
    $cv = AnyEvent->condvar; 
    $redis->rpush('list', "1","2","3", 
        { on_done => sub { 
        my $data = shift; 
        print "$data\n"; 
        }, 
        } 
     ); 
    $cv->recv(); 
} 
$redis->quit(
    sub {$cv->send();} 
    ); 
$cv->recv(); 

Answer 1

Sie blockieren die Skriptausführung, wenn Sie $ cv-> recv() in while-Schleife und Skript $ cv-> send oder $ cv-> croak aufrufen, aber im Callback rufen Sie nicht $ cv-> send() auf.

$ cv-> recv

Warten (Blockierung, wenn nötig), bis der -> senden oder -> quaken Methoden haben sich auf $ cv genannt worden, während andere Beobachter der Wartung normal.

Wenn Sie verschiedene nicht blockierende Requests senden möchten, versuchen Sie, AnyEvents Methoden zum Starten und Beenden zu verwenden.

#!/usr/bin/perl 
use AnyEvent; 
use AnyEvent::Redis::RipeRedis; 
use strict; 

my $redis = AnyEvent::Redis::RipeRedis->new(
    host  => 'localhost', 
    port  => '6379', 
); 

my $i=0; 

my $cv = AnyEvent->condvar; 
while($i++ < 5) { 
    $cv->begin; 
    $redis->rpush('list', "1","2","3", 
       { 
        on_done => sub { 
        my $data = shift; 
        print "$data\n"; 
        $cv->end(); 
        }, 
       } 
    ); 
} 

$cv->recv(); 

Answer 2

Bitte beachten Sie, dass Sie nicht definiert haben, connection_timeout:

my $redis = AnyEvent::Redis::RipeRedis->new(
    host  => 'localhost', 
    port  => '6379', 
    ); 

Should wie folgt aussieht:

my $redis = AnyEvent::Redis::RipeRedis->new(
    host => 'localhost', 
    port => '6379', 
    password => 'your_password', 
    connection_timeout => 5, 
    reconnect => 1, 
    encoding => 'utf8'); 

Von:

ftp://ftp.uni-siegen.de/pub/CPAN/authors/id/I/IP/IPH/AnyEvent-Redis-RipeRedis-1.002.readme