Как обратиться к конкретному клиенту/пользователю с помощью очереди сообщений?

Question

Я разработал платформу аукциона с node.js и socket.io.

Однако я хочу заменить socket.io на очередь сообщений.

Хотя у меня не было проблем при внедрении платформы на основе сокетов, я понятия не имею, как это сделать с очередью сообщений.

Главное, что я не понимаю, - это обращение к конкретному клиенту/пользователю.

С Socket.io я имел socket.id:

io.sockets.connected[socket.id].emit('notify', msg) 

Как это работает с очередью сообщений, таких как, например Redis Simple Message Queue?

Я был бы рад, если бы кто-нибудь мог объяснить мне, как это работает.

Answer 1

Служебные сообщения и очереди сообщений не аналогичны. Socket.io обеспечивает непрерывную двустороннюю связь между конечными точками (клиент и сервер). Очередь сообщений обеспечивает способ обработки последовательности обрабатываемых элементов.

Вы не указали , почему вы хотите вырезать сокеты и заменить их на очередь сообщений, но это вряд ли сработает.

Скорее всего, вы могли бы использовать очередь сообщений с сокетным соединением, чтобы передать последовательность элементов в другие части вашей системы. Ваше сокет-соединение, вероятно, останется таким же, как есть, и когда сообщение было получено на сервере, оно будет помещено в очередь вместе с идентификатором соединения, которое его отправило.