基于Java的websocket客户端用于基于Spring的websocket服务器

Question

我使用Spring Boot开发了这个websocket服务器。服务器与基于js的客户机配合得很好。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(final MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(final StompEndpointRegistry registry) {
        registry.addEndpoint("/chat").withSockJS();
        registry.addEndpoint("/chat");
    }

}

控制器：

@Controller
public class ChatController {

    @MessageMapping("/chat")
    @SendTo("/topic/messages")
    public OutputMessage send(final Message message) throws Exception {

        final String time = new SimpleDateFormat("HH:mm").format(new Date());
        return new OutputMessage(message.getFrom(), message.getText(), time);
    }

}

这是服务器端。现在，对于客户机，我已经创建了一个@ClientEndpoint，当我连接到URI“ws：//localhost:8080/spring-mvc-java/chat”时，我能够建立一个连接，并且可以看到@ClientEndpoint的@OnOpen回调被触发。

但是，userSession.getAsyncRemote（）.sendText（message）似乎没有任何作用。我没有看到服务器的响应。

我可以看到js客户端是：

1. 连接到服务器var socket=new SockJS（“/spring-mvc-java/chat”）
2. 正在订阅StompClient.Subscribe（“/topic/messages”，...
3. 发送消息stompclient.send（“/app/chat”，...

我能做到第一步。如何在基于Java的客户端中实现第二步和第三步？

谢谢

Answer 1

首先，您需要一个websocketclient和websocketstompclient

WebSocketClient client = new StandardWebSocketClient();
WebSocketStompClient stompClient = new WebSocketStompClient(client);
stompClient.setMessageConverter(new MappingJackson2MessageConverter());

您必须从stompsessionhandler自定义处理程序

getPayloadType
handleFrame
afterConnected
handleException
handleTransportError

方法

StompSessionHandler sessionHandler = new CustomStompSessionHandler();

你可以这样连接你的插座。您可以完成发送和接收消息

StompSession stompSession=stompClient.connect("ws://localhost:8080/chat",sessionHandler).get();

这两个触发您的websocket主题/messages通过套接字为您提供消息

/app/chat向套接字发送消息

stompSession.subscribe("/topic/messages", sessionHandler);
stompSession.send("/app/chat", new Message("Hi", "user"));

你想要这样吗？