Redis + Node.js + Socket.io + Django/Celery设置中的奇怪行为。断开连接的插座仍然收到消息

我面临着一个奇怪的问题，我自己无法解决。我建立了一个安装程序，通过Django/Celery定期任务发送JSON序列化消息。此任务通过Redis与node.js服务器进行通信。 Node.js通过使用webbrowser的socket.io来处理通信。Redis + Node.js + Socket.io + Django/Celery设置中的奇怪行为。断开连接的插座仍然收到消息

的Django /芹菜任务

@periodic_task(run_every=crontab()) # every minute 
def process_channels(): 
    r = redis.StrictRedis(host='localhost', port=6379, db=0) 

    for i in xrange(1,21): # 1..20 
     data_dict = {} 
     data_dict['time'] = time.ctime(time.time()) 
     data_dict['message'] = os.urandom(10).encode('hex') 
     r.publish('channel', json.dumps(data_dict)) 
     time.sleep(2)

的node.js服务器

var http = require('http'); 
var server = http.createServer().listen(4000); 
var io = require('socket.io').listen(server); 
var querystring = require('querystring') 
var redis = require('socket.io/node_modules/redis'); 
var sub = redis.createClient(); 

sub.subscribe('channel'); 

io.sockets.on('connection', function (socket) { 
    // grab message from Redis and send to client 
    sub.on('message', function(channel, message) { 
     console.log(message + ' ' + channel + ' ' + socket.id); 
     socket.send(message); 
    }); 

    socket.on('disconnect', function() { 
     console.log('disconnected') 
    }); 
});

的index.html

$(document).ready(
    function() { 
     var socket = io.connect('localhost', { 
       port: 4000 
     }); 

     socket.on('connect', function() { 
       console.log("connecting"); 
     }); 

     socket.on('message', function(message) { 
      // deserialize message from DJANGO 
      var data = JSON.parse(message); 

      //Append message to the bottom of the list 
      $('#comments').append('Time: ' + data.time + '<br />'); 
      $('#comments').append('Message: ' + data.message + '<br /><br />'); 
      } }); 
    });

漂亮简单。该任务通过Redis将随机生成的消息发送到将其发送到浏览器的节点服务器。正如你所看到的，我在节点服务器中记录了消息和socket.id。

一切正常，直到我做一个页面重新加载。当网页加载完毕后，第一次在服务器控制台打印类似的东西：

{"message": "85105676e21512a33e72", "time": "Fri Oct 18 22:33:10 2013"} channel 94k39P2j9dMv1JEZRW6Q

当我做一个页面刷新显示：

disconnected 
{"message": "c3e93646d60a5a6727f6", "time": "Fri Oct 18 22:33:18 2013"} channel 94k39P2j9dMv1JEZRW6Q 
{"message": "c3e93646d60a5a6727f6", "time": "Fri Oct 18 22:33:18 2013"} channel wJwsRvpgEks7g1AURW6R

同样的消息已发送两次。每次我重新加载页面时，都会再次发送消息。查看socket.ids（第3个字段），它似乎是在重新加载之前套接字没有正确断开，并且服务器仍然通过该套接字发送消息。我不明白这种行为。 'disconnect'方法被调用，所以应该以任何方式处理。有人可以帮我吗？

非常感谢提前。

来源

2013-10-18 noplacetoh1de

在黑暗中拍摄，但也许考虑在客户端设置'强制新连接'为真？ –

在客户端尝试使用socket.once（）而不是socket.on（）。

socket.once('message', function() { 
    ... 
}

问题可能是，每次重新加载页面时，都会附加多个侦听器。我面临类似的问题，'.once（）'是我能找到的唯一解决方案。

如果这没有帮助，你可以尝试探索在这里发布的类似问题。希望它有帮助:) https://github.com/LearnBoost/socket.io/issues/997

来源

2013-10-25 23:43:07 slider

Redis + Node.js + Socket.io + Django/Celery设置中的奇怪行为。断开连接的插座仍然收到消息

回答

相关问题