Есть клиент-серверное приложение, написанное на java, представляющее собой набор SOA-сервисов и работающее под томкетом. Некоторые операции требуют временных затрат и, чтобы клиент не ждал, они проводятся в фоновом режиме. Однако по их окончании клиенту нужно отправить соответствующее сообщение. Идея была использовать для этого WebSocket. Сервис по окончании операции кладет сообщение в RabbitMQ. WebSocket-сервер считывает сообщение из очереди и посылает его клиентской части в браузер нужного пользователя. Во всех примерах, которые мне попались в интернете, WebSocket-сервер обычно принимает сообщение от браузера и передает его в другие подключенные браузеры (webchat), но у нас несколько другая задача, и в данный момент мне совершенно непонятно, как послать браузеру сообщения после его считывания из очереди, да и имплементация этой части в WebSocket-сервер не вполне ясна. Может, кто-нибудь сталкивался с решением подобной задачи?
-
Там вебсокетах настраивается канал, с каким-то уникальным айдишником @MessageMapping("/chat-room/{roomId}") и один из клиентов просто на него подписывается тем самы получается все сообщения которые туда приходят. Вот клиенту и надо на него подписаться и слушать что туда приходит. Дальше просто бросить туда сообщение от сервера messagingTemplate.convertAndSend("/chat-room/" + roomId, new OutputMessage(message, now));– Serhii Dikobrazko17 дек 2021 в 7:40
-
@SerhiiDikobrazko спасибо, попробую понять, как это сделать– Hermann Zheboldov17 дек 2021 в 7:50
1 ответ
Смотри Principal
аргумент для @MessageMapping
или @SubscribeMapping
.
С этого параметра ты можешь взять getName()
и использовать его позже для отправки результата этому пользователю.
Для этрпавки нам нужен SimpMessagingTemplate
и его convertAndSendToUser()
.
Смотри документацию для больше деталей: https://docs.spring.io/spring-framework/docs/current/reference/html/web.html#websocket-stomp-user-destination