Redis密钥空间事件不启动

我有两个Redis客户端,在一个文件中,我有一个简单的脚本设置,并删除了Redis键:

var redis = require("redis"); var client = redis.createClient('6379','127.0.0.1'); client.config("SET","notify-keyspace-events", "KEA"); client.set("string key 1", "string val", redis.print); client.set("string key 2", "string val", redis.print); client.set("placeholder","placeholder value", redis.print); client.del("string key 1", redis.print); client.del("string key", redis.print); 

在第二个文件中,我有一个作为订阅者的Redis客户端:

 var redis = require("redis"); var subscriber = redis.createClient('6379','127.0.0.1'); const REDIS_PUB_MESSAGE = 'redis_pub_message'; const EVENT_SET = '__keyevent@0__:set'; const EVENT_DEL = '__keyevent@0__:del'; const SPACE_SPECIFIC_KEY = '__keyspace@0__:placeholder set'; const EVENT_SPECIFIC_KEY = '__keyevent@0__:placeholder set'; const SPACE_SPECIFIC_KEY_set = '__keyspace@0__:set placeholder'; const EVENT_SPECIFIC_KEY_set = '__keyevent@0__:set placeholder'; subscriber.on('message', function(channel, key) { switch (channel) { case SPACE_SPECIFIC_KEY_set: console.log('space specific key channel:',channel,'key:',key); case EVENT_SPECIFIC_KEY_set: console.log('event specific key channel:',channel,'key:',key); case EVENT_SPECIFIC_KEY: console.log('space specific key channel:',channel,'key:',key); case SPACE_SPECIFIC_KEY: console.log('event specific key channel:',channel,'key:',key); } }); 

关键的'占位符'正在设置,所以有没有什么好的理由,我没有得到'消息'处理程序中的任何输出?

您忘记订阅订阅者客户端到特定的频道。 此外,如果您想要观看所有事件,则需要使用基于模式的订阅。

你可能想要做这样的事情(未经testing):

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

请参阅Redis文档以及node_redis示例中的更多信息。

更新:

下面是一个例子来说明频道的订阅和模式订阅的区别。 为了简洁起见,适当的error handling被省略。

 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( "__keyspace@0__: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( "__keyspace@0__:*", 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(); }); }); 

这个脚本的结果是:

 S1: received on __keyspace@0__:mykey event set S2: received on __keyspace@0__:mykey event set S2: received on __keyspace@0__:mykey event set S1: received on __keyspace@0__:mykey event set S1: received on __keyspace@0__:mykey event del S2: received on __keyspace@0__:mykey event del S2: received on __keyspace@0__:anotherkey event set S2: received on __keyspace@0__:anotherkey event del 

您可以看到第一个用户只接收mykey的事件,而第二个用户接收所有密钥的事件。