node.js中的socket.io redis pub/sub

我已经创建了简单的聊天应用程序。并因此我已经使用node.js 我已经看到了许多简单的例子在网上，所有人都说，代码工作正常。但是当我尝试的代码，它不给我适当的结果。node.js中的socket.io redis pub/sub

它抛出错误 “始乱终弃运输”

我已阅读以下页面： 1）Examples in using RedisStore in socket.io 2）http://www.ranu.com.ar/2011/11/redisstore-and-rooms-with-socketio.html 3）socket.io broadcast function & Redis pub/sub architecture 4）I'm receiving duplicate messages in my clustered node.js/socket.io/redis pub/sub application 还有更多...

以下是我的代码：

服务器端代码：app.js ~~~~~~~~~~~~~~~~~~~~~~

var app = express.createServer(); 
app.listen(process.env.PORT); 

var io = require('socket.io').listen(app); 

var store = redis.createClient(); 
var pub = redis.createClient(); 
var sub = redis.createClient(); 

var io = require('socket.io').listen(app); 

io.configure(function() { 

    // io.enable('browser client minification'); // send minified client 
    // io.enable('browser client etag');   // apply etag caching logic based on version number 
    // io.enable('browser client gzip');   // gzip the file 

    io.set('log level', 3); 
    io.set("transports", ["jsonp-polling", "xhr-polling", "websocket", "flashsocket", "htmlfile"]); 
    io.set("polling duration", 10); 
    io.set("flash policy server", false); 
    io.set("connect timeout", 500); 
    io.set("reconnect", true); 
    // io.set('close timeout', 60 * 60 * 24); // 24h time out 
    io.set('close timeout', 25); 
    io.disable('heartbeats'); 
    io.set('heartbeat interval', 20); 
    io.set('heartbeat timeout', 60); 
    // io.set("polling duration", 10); 
    // io.set("heartbate timeout", 30); 
    //console.log("blabla"); 

    //var RedisStore = require('socket.io/lib/stores/redis'); 
    //io.set('store', new RedisStore({ redisPub: pub, redisSub: sub, redisClient: store })); 
    //io.set('store', new RedisStore()); 
}); 

io.sockets.on('connection', function (client) { 

    client.on("OnConnect", function (data, fn) { 
     console.log("socket id : " + client.id + " connected !!!"); 
    }); 

    client.on('disconnect', function() { 
     console.log("\r\nmanish from server->disconnect"); 
     //  client.broadcast(client.sessionId + " disconnected") 
     client.emit('user disconnected'); 
     sub.unsubscribe("chat"); 
     sub.quit(); 
    }); 

    sub.subscribe("chat"); 
    sub.on("message", function (channel, message) { 
     console.log("message received on server from publish : '" + message + "'"); 
     client.send(message); 
    }); 
    }); 
});

客户端代码：index.html的 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

 this.Connect = function (nick, room) { 
      socket = io.connect('http://XXX.XXX.X.XX', { transports: ['jsonp-polling', 'xhr-polling'] }); 
      Nickname = nick; 
      Room = room; 

//   setInterval(function() { socket.emit("keep-alive", null) }, 20 * 1000); 

      socket.on('connect', function (data) { 
       socket.emit('OnConnect', { nick: nick, room: room }, function (response) { 
        $("#board").append("<p>" + response.msg + "</p>"); 
       }); 
      }); 

      socket.on("message", function (msg) { 
       alert("message received on client ..."); 
       $("#board").append("<p>" + msg +"</p>"); 
      }); 

      server.on("listening", function() { 
       var address = server.address(); 
       console.log("server listening " + address.address + ":" + address.port); 
      }); 

      socket.emit("message", { msg: msg, nick: Nickname }, function (response) { 
       $("#board").append("<p> send message : " + Nickname + ": " + msg + "</p>"); 
      }); 

     };

~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~但我不适合我。

意味着我在一个浏览器中运行这个程序（让说，Firefox和发送一些消息，第二连接，让说IE）

，但节目继的console.log

调试错误：设置请求GET /socket.io/1/jsonp-polling/Th9U-Zci8cVb5Wfwl24Y?t=1345123231804 & I = 0 调试：设置轮询超时调试：客户端授权调试：具有清热调查超时调试：jsonppolling写IO。 J0; 调试：为客户端设置关闭超时Th9U-Zci8cVb5Wfwl24Y 套接字ID：Th9U-Zci8cVb5Wfwl24Y连接！从发布服务器上接收消息： 'MSG 1' 调试：设定请求GET /socket.io/1/jsonp-polling/Th9U-Zci8cVb5Wfwl24Y?t=1345123231804 & I = 0 调试：设置轮询超时调试：客户端授权调试：清除轮询超时调试：jsonppolling写入io.j0; 调试：为客户端设置关闭超时Th9U-Zci8cVb5Wfwl24Y 套接字ID：Th9U-Zci8cVb5Wfwl24Y连接！ “味精1” 调试：从发布服务器接收消息解雇接近超时客户Th9U-Zci8cVb5Wfwl24Y 信息：运输结束（接近超时）调试：丢弃运输

来源

2012-08-16 Manish Sapkal

Socket.io房间里工作的开箱你不需要订阅redis或任何东西。

尝试在您的自定义连接功能

client.on("OnConnect", function (data, fn) { 
    console.log("socket id : " + client.id + " connected !!!"); 
    client.join(data.room); 
});

而且你不需要从房间退订，但如果你这样做应该是这样的

client.on('disconnect', function() { 
    console.log("\r\nmanish from server->disconnect"); 
    client.emit('user disconnected'); 
    client.leave("chat"); 
});

发送消息到聊天室是通过 client.broadcast.to（'chat'）。emit（'message'）;

您可以在https://github.com/LearnBoost/socket.io/wiki/Rooms

好运阅读更多关于房间！

来源

2012-10-06 15:40:22 Martin

node.js中的socket.io redis pub/sub

回答

相关问题