我正在尝试使用以下代码从azure redis keyspace notification获取所有通知,但它没有收到任何通知,我检查了密钥,它是在azure redis示例中创建的。另外,我通过设置 notify-keyspace-events
至 Kxg
.
感谢您的帮助:
const redis = require('redis');
process.env.REDIS_CACHE_HOST_NAME = "<cachename>.redis.cache.windows.net";
process.env.REDIS_CACHE_KEY = "<cachekey>";
const client = redis.createClient(
6380,
process.env.REDIS_CACHE_HOST_NAME,
{
auth_pass: process.env.REDIS_CACHE_KEY,
tls: { servername: process.env.REDIS_CACHE_HOST_NAME },
});
const client2 = redis.createClient(
6380,
process.env.REDIS_CACHE_HOST_NAME,
{
auth_pass: process.env.REDIS_CACHE_KEY,
tls: { servername: process.env.REDIS_CACHE_HOST_NAME },
});
const db = 0;
const notificationChannel = "__keyspace@" + db + "__:*";
client.on("message", function (channel, message) {
console.log('100', channel , message);
});
client.subscribe(notificationChannel, function (err) {
console.log('101' , err);
client2.set("foo", "bar", 'EX', 10, function (err) {
console.log('102' , err);
});
});
更新:我用这里的代码片段尝试了c代码https://github.com/rustd/redissamples/blob/master/helloworld/keyspacenotifications.cs 它工作正常,这意味着接收事件的nodejs代码有问题。
update2:使用以下代码,我可以接收自己发布的消息,因此订阅一般没有问题:
client.subscribe("pub");
client3.publish("pub", "a test message");
1条答案
按热度按时间kkih6yb81#
我终于弄明白了,它和
client.psubscribe
以及client.on("pmessage",...)
.