节点Redis对PubSub的回调

Node Redis Callback on PubSub

本文关键字:回调 PubSub Redis 节点      更新时间:2023-09-26

为什么我不能有一个回调与PubSub模式设计在节点Redis?

例如:

server.publish("someChanel", someData, function(response) {
   // response should come back from client
});
client.on('message', function(channel, data, callback) {
   // Do stuff with data
   // Return data to callback
   callback(someNewData);
});

这显然是失败的,因为callback没有定义。

redis连接将发出事件,因此当您每次有消息时注册client.on('message'时,function(channel, data)将触发。在这个函数中,你可以做任何事情,包括调用一个不同的函数。

function YourCallBackFn (err, data) {
    // do something with data
}
server.publish("someChanel", someData, function(response) {
   // response should come back from client
});
client.on('message', function(channel, data) {
   // Do stuff with data
   // Return data to callback
   YourCallBackFn(null, data);
});