我正在尝试将SocketIO与Redis Pub / Sub结合使用以监视应用程序中的事件。到目前为止,我对服务器有类似以下内容
io.on 'connection', (socket) ->
log.info "Connection established. [Socket: #{socket.id}]"
socket.on 'join_room', (roomName) ->
log.info "Join room '#{roomName}'. [Socket: #{socket.id}]"
socket.join roomName
redis.on 'message', (redisChannel, message) ->
message = JSON.parse message
log.info "Room: #{message.room} - Event: #{message.event} - Message: #{message.message}"
io.sockets.in(message.room).emit(message.event, message.message)
socket.on 'disconnect', ->
log.info "Connection destroyed. [Socket #{socket.id}]"
然后,在客户端上,我有
socket = io.connect('http://127.0.0.1:3333/')
socket.emit('join_room', 'login_events')
socket.emit('join_room', 'cj_alerts')
socket.on 'failed_login', (msg) ->
console.log msg
socket.on 'successful_login', (msg) ->
console.log msg
当服务器运行时,我可以使用它$redis.publish 'redisChannel', {:room => 'room', :event => 'failed_login', :message => 'message'}.to_json
来redis.on 'message'
正确启动。实际上,一切都很好。
当我刷新客户端代码所在的页面而不重新启动服务器时,就会出现问题。我的“连接销毁”日志正确显示,但似乎连接从未真正消失。每次刷新时,都会添加另一个侦听器。下面的屏幕截图应有助于弄清我的意思。
每个“连接破坏” /“连接建立”均表示刷新。
我还假设客户端的代码将基于每个浏览器窗口。但是,即使当我打开一个新的浏览器时,我也得到了输出,指出所有事件都将应用于每个窗口。
关于它为什么做的任何提示以及正确的实现方法将不胜感激。
问题是由我的redis.on 'message'
听众的位置引起的。我在创建的每个套接字上都在监听它。实际上,我只需要从全局的角度聆听它,然后向所有房间发送消息。看起来像这样:
io.on 'connection', (socket) ->
log.info "Connection established. [Socket: #{socket.id}]"
socket.on 'join_room', (roomName) ->
log.info "Join room '#{roomName}'. [Socket: #{socket.id}]"
socket.join roomName
socket.on 'disconnect', ->
log.info "Connection destroyed. [Socket #{socket.id}]"
redis.on 'message', (redisChannel, message) ->
message = JSON.parse message
log.info "Room: #{message.room} - Event: #{message.event} - Message: #{message.message}"
io.sockets.in(message.room).emit(message.event, message.message)
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句