1

Хочу отправить сообщение всем клиентам, но его получает только отправитель

Пытался решить сам (логически) создал сингалтон, но не помог

public class WebSocketHandler extends AbstractWebSocketHandler {
 
    private static WebSocketHandler webSocketHandler;
    private MessageRepo messageRepo;
    private JsonAdapter<Message> adapter;
 
    public WebSocketHandler(MessageRepo messageRepo) {
        this.messageRepo = messageRepo;
 
        Moshi moshi = new Moshi.Builder()
                .add(new DataAdapter())
                .build();
        adapter = moshi.adapter(Message.class);
    }
 
    public static WebSocketHandler getWebSocketHandler(MessageRepo messageRepo)
    {
        if (webSocketHandler == null)
        {
           webSocketHandler = new WebSocketHandler(messageRepo);
        }
        return webSocketHandler;
    }
 
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        Message messagePayload = adapter.fromJson(message.getPayload());
        messagePayload.setDateTime(LocalDateTime.now());
        messageRepo.save(messagePayload);
        session.sendMessage(new TextMessage(adapter.toJson(messagePayload)));
    }
 
    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        session.sendMessage(new TextMessage(exception.getMessage()));
    }
}
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
 
    private final MessageRepo messageRepo;
 
    @Autowired
    public WebSocketConfig(MessageRepo messageRepo) {
        this.messageRepo = messageRepo;
    }
 
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(WebSocketHandler.getWebSocketHandler(messageRepo),"/messages-update");
    }
}

1 ответ 1

0

Предполагаю, что надо заимплементить afterConnectionEstablished/afterConnectionClosed, в которых соответственно класть/удалять сессию в какую-то коллекцию сессий.

А в handleTextMessage пробежать по этой коллекции.

Коллекции нужно обеспечить потокобезопасность.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.