我正在构建一个应用程序,其中我在两个服务(API-网关和通知)之间使用Redis连接。对于这个连接,我使用Redis的pub/sub方法。我使用的库叫做NRP。
问题是,我可以将数据从API网关传递到通知,但API网关没有接收到我需要返回的数据。假设我想要登录,然后API网关将用户名和密码发布到通知。在通知中,登录的所有逻辑都已完成,当一切正常时,我向API网关发回一条消息。
来自API-gateway的代码(其中subchannel和pubchannel作为函数的参数给出):
{
return new Promise((resolve, reject) => {
try {
this.sub.Subscribe(subchannel, (data, channel) => {
let body = data.body;
let message = body.message;
if(data.rmid == data.mid){
sub.unSubscribe((nrp)=>{
nrp.quit();
resolve(message);
});
}
});
const sent = this.sub.publish(pubchannel, {
body: {
param: params,
message: '',
}
});
} catch (e) {
reject(e);
}
});
}
来自上面sub.Subscribe部分的代码,以及订阅发布发生的部分:
Subscribe(pattern, callback)
{
console.log('Im gonna subscribe');
console.log(pattern);
nrp.on(pattern, (data, channel) => {
console.log('subd on ' + pattern);
return callback(data, channel);
});
}
所以问题是,当我在通知服务上发布消息告诉API网关登录成功的时候,它并没有在API网关中触发订阅的回调。通知服务上的代码是正确的,因为如果我在redis-client应用程序上订阅,它就可以工作。如果在redis-client应用程序上发布,它会显示我有一个侦听器,所以Api-Gateway正在侦听。不知何故,回调没有被执行。
发布于 2018-05-31 17:25:37
所以我想通了。显然,在发送消息之前,我需要对消息进行json编码,否则nrp库不会拾取它。
https://stackoverflow.com/questions/50607035
复制相似问题