Redis
 sql >> Base de données >  >> NoSQL >> Redis

L'événement d'espace de clés Redis ne se déclenche pas

Vous avez oublié d'abonner le client abonné à un canal spécifique. De plus, si vous souhaitez surveiller tous les événements, vous devez utiliser un abonnement basé sur un modèle.

Vous voudrez peut-être faire quelque chose comme ceci (non testé):

subscriber.on("pmessage", function (pattern, channel, message) {
    console.log("("+  pattern +")" + " client received message on " + channel + ": " + message);
    switch (channel) {
        // blah blah blah
        // ...
    }
});
subscriber.psubscribe(''__key*__:*')

Voir plus d'informations dans la documentation Redis et dans les exemples node_redis.

Mise à jour :

Voici un exemple pour illustrer la différence entre l'abonnement au canal et l'abonnement au modèle. La gestion appropriée des erreurs est omise par souci de brièveté.

var redis = require("redis");

var client = redis.createClient('6379','127.0.0.1');
var subscriber1 = redis.createClient('6379','127.0.0.1');
var subscriber2 = redis.createClient('6379','127.0.0.1');

// First subscriber listens only to events occurring for key mykey
function S1(next) {
    subscriber1.on('message', function(channel, msg) {
        console.log( "S1: received on "+channel+" event "+msg )
    });
    subscriber1.subscribe( "[email protected]__:mykey", function (err) {
        next();
    });
}

// Second subscriber listens to events occuring for ALL keys
function S2(next) {
    subscriber2.on('pmessage', function(pattern,channel, msg) {
        console.log( "S2: received on "+channel+" event "+msg )
    });
    subscriber2.psubscribe( "[email protected]__:*", function (err) {
        next();
    });
}

// Do something with keys mykey and anotherkey
function do_something() {
    client.set("mykey","example", function( err ) {
        client.set("mykey", "another example", function( err ) {
            client.del("mykey", function( err ) {
                client.set("anotherkey","example", function( err ) {
                    client.del("anotherkey");
                });
            });
        });
    });
}

// Here we go
S1( function () {
    S2( function () {
        do_something();
    });
});

Le résultat de ce script est :

S1: received on [email protected]__:mykey event set
S2: received on [email protected]__:mykey event set
S2: received on [email protected]__:mykey event set
S1: received on [email protected]__:mykey event set
S1: received on [email protected]__:mykey event del
S2: received on [email protected]__:mykey event del
S2: received on [email protected]__:anotherkey event set
S2: received on [email protected]__:anotherkey event del

Vous pouvez voir que le premier abonné n'a reçu que des événements pour mykey, tandis que le second abonné reçoit des événements pour toutes les clés.