Nestjs как использовать HTTP-запрос и Websocket одновременно

Question

Nestjs как использовать HTTP-запрос и Websocket одновременно

У меня есть контроллер в Nestjs, который обрабатывает HTTP-запросы. Существует устройство IoT, которое связывается с сервером и отправляет последние изменения на сервер с помощью почтового запроса. В то же время есть мобильное приложение, которое должно получать обновления в реальном времени с помощью Websockets.

Я знаю, что HTTP-запрос и веб-сокеты - это разные концепции в Nestjs, но есть ли способ генерировать событие всякий раз, когда я получаю HTTP-запрос?

Любая идея будет высоко оценена.

3

node.js socket.io nestjs nestjs-gateways nestjs-socket.io

Источник

user4055329 15 мар '21 в 15:07

1 ответ

Решение

Другие вопросы по тегам node.js socket.io nestjs nestjs-gateways nestjs-socket.io

15 мар '21 в 18:19 2021-03-15 18:19 · Accepted Answer · 2021-03-15 18:19

Для этого действительно есть подходящее решение. Вам нужен Injectableкоторый содержит RxJS. Когда бы ты ни Controllerполучает значение через запрос POST, он делегирует значение внедренной службе. Затем служба "дает указание" передать значение. На другой стороне цепочки, внутри вашего WebSocket Gateway @SubscribeMessage, вы возвращаете RxJS Observable - который получен из Subject - подключенным клиентам.

Подробнее о теме и асинхронных ответах

Вот реализация .