javascript - 带有socketio的nodejs中的redis pubsub：发布者不发布消息吗？

Question

我正在 nodejs 中使用 redis 和 socketio 尝试 pubsub。

我的服务器端代码是：

var io = require('socket.io').listen(server);
var pub = redis.createClient();

io.sockets.on("connection", function(socket) {
    console.log('connecteed');

    var sub = redis.createClient();

    sub.subscribe("messages");
    sub.on("message", function(channel, message) {
      console.log('message',message);
      socket.emit(channel,message);
    });

    socket.on("disconnect", function() {
      sub.unsubscribe("messages");
      sub.quit();
    });
});
pub.publish("messages", JSON.stringify({type: "foo", content: "bar"}));

我的 html 页面 index.html 包含以下脚本：

var host = window.location.host.split(':')[0];
var socket = io.connect('http://' + host);
socket.on('messages',function(msg){
    console.log(msg);
})

但在 index.html 中，console.log 永远不会执行。

这是基本的，但我没有在我的代码中找到错误。它在哪里？

Answer 1

这可能是因为您在发布消息时没有连接任何客户端（提示 io.socket.on 连接函数在 pub.publish 之后执行）。尝试更换

pub.publish("messages", JSON.stringify({type: "foo", content: "bar"}));

和

setIntervall(function(){
    pub.publish("messages", JSON.stringify({type: "foo", content: "bar"}));
},1000);

这将每秒发送消息，并为您提供足够的时间来验证您的设置。