时间戳

首页 > 解决方案 > spring websocket 无法建立连接

java - spring websocket 无法建立连接

问题描述

无法通过浏览器客户端与我的 websocket 服务器建立连接。

配置：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

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

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


}

和控制器：

@MessageMapping("/message")
@SendToUser("/queue/reply")
public String processMessageFromClient(@Payload String message, Principal principal) throws Exception {
    String name = new Gson().fromJson(message, Map.class).get("name").toString();
    System.out.println(name);
    //messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/reply", name);
    return name;
}

我启动服务器，然后在浏览器中打开 index.html，然后进行连接，然后ws://localhost:8080/greeting 发送消息到/app/message

但实际上什么也没发生。浏览器检查器显示 404。我怎么了？

标签： javaspring-websocket

解决方案

这是用于在 Spring 中实现 WebSocket 的方式。首先，您应该配置 Web 套接字消息代理并注册 stomp 端点，如下所示。在这里，我使用 setAllowedOrigins("*").withSockJS() 将此端点访问到任何主机。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/greeting")
                .setAllowedOrigins("*")
                .withSockJS();
    }
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app")
                .enableSimpleBroker("/topic", "/queue/");
    }
}

然后我如下创建控制器。

@Controller
public class WebSocketController {

    private final SimpMessagingTemplate template;

    @Autowired
    WebSocketController(SimpMessagingTemplate template){
        this.template = template;
    }

    @MessageMapping("/queue/reply")
    public void sendMessage(String message){
        System.out.println(message);
        this.template.convertAndSend("/topic",  message);
    }
}

使用@MessageMapping("/queue/reply") 代替上面的@SendToUser("/queue/reply")。

从那个简单的消息传递模板中，我使用 convertAndSend() 方法与该消息代理进行异步数据通信。如果有任何数据到达该消息代理，它将使用上面配置的名为 /socket 的 SockJS 和 Stomp 端点自动发送该数据。

你可以参考这篇文章来了解更多关于 Spring web socket 的信息。

推荐阅读