如何使用消息队列处理特定的 client/user?
How to address specific client/user using a message queue?
我用 node.js 和 socket.io 开发了一个拍卖平台。
但是,我想用消息队列替换 socket.io。
虽然我在实现基于套接字的拍卖平台方面没有遇到任何问题,但我不知道如何使用消息队列来做到这一点。
我不明白的主要是如何解决特定的 client/user。
socket.io 我有 socket.id:
io.sockets.connected[socket.id].emit('notify', msg)
这如何与消息队列一起工作,例如 Redis Simple Message Queue?
如果有人能向我解释这是如何工作的,我会很高兴。
套接字通信和消息队列并不相似。 Socket.io 提供端点(客户端和服务器)之间的连续双向通信。消息队列提供了一种方法来处理一系列待处理的项目。
您没有提到为什么您想放弃套接字并用消息队列替换它们,但这不太可能奏效。
更有可能的是,您可以使用消息队列和您的套接字连接,将一系列项目传递到系统的其他部分。您的套接字连接可能会保持原样,当服务器收到一条消息时,它会与发送它的连接的标识符一起放入队列中。
我用 node.js 和 socket.io 开发了一个拍卖平台。
但是,我想用消息队列替换 socket.io。
虽然我在实现基于套接字的拍卖平台方面没有遇到任何问题,但我不知道如何使用消息队列来做到这一点。
我不明白的主要是如何解决特定的 client/user。
socket.io 我有 socket.id:
io.sockets.connected[socket.id].emit('notify', msg)
这如何与消息队列一起工作,例如 Redis Simple Message Queue?
如果有人能向我解释这是如何工作的,我会很高兴。
套接字通信和消息队列并不相似。 Socket.io 提供端点(客户端和服务器)之间的连续双向通信。消息队列提供了一种方法来处理一系列待处理的项目。
您没有提到为什么您想放弃套接字并用消息队列替换它们,但这不太可能奏效。
更有可能的是,您可以使用消息队列和您的套接字连接,将一系列项目传递到系统的其他部分。您的套接字连接可能会保持原样,当服务器收到一条消息时,它会与发送它的连接的标识符一起放入队列中。