node.js - 使用 Express 和 Redis 进行异步调用

Question

我正在使用 Redis Pub/Sub 将消息从 Node.js 传输到后端服务器。

问题是如何从订阅者消息事件中获取消息以便在快速响应中访问。这是我应该用中间件处理的事情吗？或者有没有更简单的异步回调方法？

这是我所说的一个基本示例:

subscriber.on("message", function (channel, message) {
    console.log("received: " + channel + ": " + message);
});

server.get('/', function(req, res){
    publisher.publish(server.uuid, server.uuid + ": message here");
    res.send(message);
});

更新:

通过将带有 id 的响应对象传递给异步队列解决了我自己的问题。

Answer 1

我对 node.js 的经验很少，但是类似于下面的东西会起作用。我认为您只需要使用包含服务器可识别模式的消息的请求来访问服务器。在以下示例中，请求是 http://yoursite.com/msg/ some_msg_here。

var http = require('http');var site = http.createClient('127.0.0.1', 80);subscriber.on("message", function(channel, message)) {    var req = site.request("GET", "/msg/" + message, {'host': '127.0.0.1'});    req.end();}server.get('/msg', function(req, res){    var msg = req.params.msg;    publisher.publish(server.uuid, server.uuid + ": " + msg;    res.send(msg);

如果不是最终解决方案，希望这有助于作为起点。