时间戳

首页 > 解决方案 > 使用Java代码以编程方式推送消息的websocket

spring-mvc - 使用Java代码以编程方式推送消息的websocket

问题描述

java 8 Spring 5 mvc Websocket 处理程序。

它如何以编程方式（使用 javacode）将 websocket 消息推送到客户端？

我遵循以下示例。

http://boraji.com/spring-mvc-5-handling-websocket-message-example

这会创建TextWebsocketHandler.

@Component
public class MyWebSocketHandler extends TextWebSocketHandler {

   @Override
   protected void handleTextMessage(WebSocketSession session, TextMessage message)
         throws Exception {

      String clientMessage = message.getPayload();

      if (clientMessage.startsWith("Hello") || clientMessage.startsWith("Hi")) {
         session.sendMessage(new TextMessage("Hello! What can i do for you?"));
      } else {
         session.sendMessage(
               new TextMessage("This is a simple hello world example of using Spring WebSocket."));
      }
   }
}

然后将其传递给 websocket configurere

@Configuration
@EnableWebSocket
@ComponentScan("com.boraji.tutorial.spring.websocket")
public class WebSocketConfig implements WebSocketConfigurer {

   @Autowired
   private MyWebSocketHandler myWebSocketHandler;

   @Override
   public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
      registry.addHandler(myWebSocketHandler, "/socketHandler");
   }

}

标签： spring-mvcjava-8spring-websocket

解决方案

只需将您WebSocketSession的代码保存在某个位置，然后sendMessage(TextMessage m)在您想将某些内容发送回客户端时调用它。

例如，您可以OnOpen在处理程序中调用方法时保存 WebSocketSession 引用。引用作为参数传递。

但无论如何，您的代码只是在执行以下操作：

session.sendMessage(
           new TextMessage("This is a simple hello world example of using Spring WebSocket."));

并且在

session.sendMessage(new TextMessage("Hello! What can i do for you?"));

你说的程序化是什么意思？例如，您可以为自己创建一个协议以及如何处理消息。

推荐阅读