使用STOMP simple broker时的错误处理

Question

我正在使用@EnableWebSocketMessageBroker创建简单的STOMP代理。当RuntimeException在@MessageMapping方法中发生时，我希望接收STOMP ERROR帧，但默认情况下它不是这样工作的。

在简单代理：https://github.com/spring-projects/spring-framework/blob/master/spring-messaging/src/main/java/org/springframework/messaging/simp/SimpMessageType.java#L28-L44中似乎不支持ERROR框架

另一方面，有一种机制可以发送spring-websocket中已经可用的ERROR帧，并且它的代码引用了一些与简单代理相关的类：https://github.com/spring-projects/spring-framework/blob/master/spring-websocket/src/main/java/org/springframework/web/socket/messaging/StompSubProtocolHandler.java#L349

如何在RuntimeException在@MessageMapping方法中发生时启用发送ERROR帧的机制？

Answer 1

快速而简单的方法是在客户端上有一个特定的错误处理程序订阅，在调用@MessageMapping端点之前订阅该错误处理程序。然后，用try catch块包装对websocket服务器中该方法的所有调用，并处理发生的异常。然后这是一个简单的例子，做一些类似的事情：

messagingTemplate.convertAndSend( "/topic/clientControl/1234", "SHUT_DOWN"); (or send to user etc, depends on your subscription model)

您可以向客户端发送错误消息并允许其进行处理，也可以决定如何在服务器端执行操作，并拥有一个允许服务器将命令传递给客户端的控件订阅。