Spring WebSockets：消息未发布

Question

Spring WebSockets：消息未发布

javaspringwebsocketstompspring-websocket

5

我使用Spring WebSockets、STOMP和SockJS来处理前端的相关内容。虽然它工作得不错，但我还遇到了一些困难。

这是后端代码：

 @MessageMapping("/showAccountlist")
 @SendTo("/topic/accounts")
 public Account createPublishAccount(String name) throws Exception {

     return new Account(name);
 }

这是前端代码，完全正常运行，所有消息都会发布到所有客户端。

 stompClient.send("/app/showAccountlist", {}, name);

但是当我从Java后端调用我的后端方法时，方法名称为：from。

createPublishAccount("Carlos");

似乎消息没有被发布。有什么解决方法吗？或者这不是它的工作方式，只有在通过SockJS触发时才起作用？

这是我的webconfig：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer  {

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

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

}

- Spring

Spring是否实例化了具有createPublishAccount方法的类？ - Jakub Bibro

1

您IP地址为143.198.54.68，由于运营成本限制，当前对于免费用户的使用频率限制为每个IP每72小时10次对话，如需解除限制，请点击左下角设置图标按钮（手机用户先点击左上角菜单按钮）。 - Jakub Bibro

当然。请参阅http://docs.spring.io/spring/docs/current/spring-framework-reference/html/websocket.html#websocket-stomp-handle-send - Jakub Bibro

@Jakub Bibro 谢谢，SimpMessagingTemplate起作用了。如果你能以描述方式并提供代码示例更新你的答案，我会接受它。 - Spring

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Jakub Bibro · Accepted Answer

似乎无法通过调用@SendTo注释方法来发送消息。

Spring推荐的发送消息方式是使用SimpMessagingTemplate。例如在convertAndSendToUser方法中，可以将目标作为参数（在您的情况下为/topic/accounts）（http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/messaging/simp/SimpMessagingTemplate.html）。

请参阅Spring文档摘录（http://docs.spring.io/spring/docs/current/spring-framework-reference/html/websocket.html#websocket-stomp-handle-send）：

“如果您想从应用程序的任何部分向已连接的客户端发送消息怎么办？任何应用程序组件都可以向“brokerChannel”发送消息。最简单的方法是注入SimpMessagingTemplate，并使用它发送消息。通常，按类型注入应该很容易，例如：”

@Controller
public class GreetingController {

    private SimpMessagingTemplate template;

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

    @RequestMapping(path="/greetings", method=POST)
    public void greet(String greeting) {
        String text = "[" + getTimestamp() + "]:" + greeting;
        this.template.convertAndSend("/topic/greetings", text);
    }

}