Многоадресные веб-сокеты в Spring Boot
Контекст
Весной впервые работаю с веб-сокетами. В моем приложении используется один тип пользователей (CHAP), который сообщает свое текущее местоположение всем остальным, кто подписан (USR) (и имеет право подписываться на эту информацию).
Я читал документацию и нашел раздел это, который, как мне кажется, содержит мое решение, но я просто не уверен на 100%, как именно оно работает, и хотел бы, чтобы кто-нибудь с более сильным пониманием выразил это другими словами. Я видел похожие вопросы о переполнении стека, но решения кажутся слишком конкретными (хотя это может быть просто моим собственным непониманием).
Проблема
Один CHAP для каждой темы, которые могут публиковать свое местоположение в теме. Пользователи могут подписаться на любые темы, на которые они уполномочены подписаться.
Итак, по сути:
Несколько тем в переменной конечной точке (что-то вроде / {route_id} / location)
Пользователи могут подписаться на эти темы и получать обновления, когда они будут доступны.
Пользователи с ролью CHAP могут публиковать в одной теме. (т.е. у каждого CHAP есть {route_id}, на который они могут публиковать.
Пользователи с ролью USR могут прослушивать несколько тем, частью которых они являются (т.е. у каждого USR есть несколько маршрутов, по которым они могут прослушивать обновления)
Это похоже на проблему с несколькими комнатами чата, что является распространенным примером для веб-сокетов. Однако все примеры, которые я могу найти, имеют либо статические имена комнат чата, либо отдельные комнаты чата, либо могут нацеливать сообщения только на одного пользователя (а не на группу).
Текущий код
@MessageMapping("/chaperone/location") // chaperone sends data to here
@SendTo("/{route_id}/location") // users can listen in on this
public BusModel updateLocation(@DestinationVariable long route_id, BusModel busModel) {
return routeService.updateBusLocation(busModel);
}
Я думаю, что сопровождающие отправляют сообщения по этому URL-адресу, и все пользователи, подписанные на их маршрут, получат обновление.
Спасибо!
@ 123 наверное плохая формулировка с моей стороны. Аналогичный вопрос. Что-то вроде наличия нескольких чатов, на которые пользователи могут подписаться, и получать обновления только из этих чатов.
@ 123 точно! Во всех примерах я могу найти цель: 1. одного пользователя (одноадресная передача) или 2. всех пользователей (широковещательная рассылка), но я ищу многоадресную связь.
Вы используете STOMP?
@ 123 Я бы хотел использовать STOMP, так как он очень поддерживается весной.
@ 123 обновленный вопрос, надеюсь, будет немного яснее.
Круто, спасибо, банкомат занят, но я постараюсь ответить позже
@ 213 Нет проблем! Спасибо!
Ответы 1
Этот оказался решением и не потребовал особой настройки, как я думал ранее. Вот моя версия здесь:
WebSocketConfig
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
public static final String TOPIC = "/topic";
/**
* Consumers connect to endpoint/live to connect to the websocket
*
* @param registry
*/
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/live").setAllowedOrigins("*").withSockJS();
}
/**
* Once connected to the websocket, users can subscribe to endpoints prefixed with /topic
* as these are managed by the message broker.
* @param registry
*/
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker(TOPIC);
registry.setApplicationDestinationPrefixes("/");
}
}
LiveController
@SubscribeMapping(TOPIC + "/routes/{route_id}")
public MessageWrapper subscribeToRouteLocation(
@DestinationVariable(value = "route_id") long route_id) {
LOG.debug("New user subscribed to location of route %d", route_id);
return new MessageWrapper(LOCATION_MESSAGE, routeService.getBusForRoute(route_id));
}
@MessageMapping("/routes/{route_id}")
@SendTo(TOPIC + "/routes/{route_id}")
public MessageWrapper updateRouteLocation(
@DestinationVariable(value = "route_id") long route_id,
@Payload BusStatusUpdateModel busLocation) {
if (busLocation.getLat() == 0 && busLocation.getLon() == 0) {
LOG.debug("Ending route %d", route_id);
return new MessageWrapper(ROUTE_TERMINATED_MESSAGE, routeService.endBusForRoute(route_id));
} else {
LOG.debug("Updating location of route %d", route_id);
BusStatusUpdateModel statusUpdateModel = routeService.updateBusLocation(busLocation, route_id);
return new MessageWrapper(LOCATION_MESSAGE, statusUpdateModel);
}
}
Таким образом, сообщения, отправленные на / routes / {route_id}, будут передаваться подписчикам / topic / routes / {route_id}
Я еще не тестировал средства авторизации, заполню их, когда они будут у меня!
Что вы имеете в виду под групповыми веб-сокетами? Вы имеете в виду трансляцию для многих пользователей одновременно, то есть тему, а не очередь?