如何等待订阅建立？

Question

我有以下js代码：

stompClient.subscribe('/topic/clients', function (calResult) {
    updateClientsTable(JSON.parse(calResult.body));
});
$.get("/clients", null);

下面的服务器代码（最后一行调用它）：

 @GetMapping(value = {"/clients"})
 @ResponseBody
 public void loadClients() {
      brokerMessagingTemplate.convertAndSend("/topic/clients", clientService.getClientList());
 }

有时前端会忽略$的结果。获取（“/clients”，null）

正如我所理解的问题：在结果到达前端的那一刻，订阅是不会发生的。

如果要放入$。获取（“/clients”，null） 下面的代码-所有工作正常。

你能解释一下如何等待订阅建立吗？




Answer 1

您可以使用@SubscribeMapping来自spring消息传递的注释。

如果您已经按照此处和此处所述配置了Spring消息传递，则服务器端代码可能如下所示：

@Controller
public class MessagingController {
    @SubscribeMapping("/clients")
    public List<Client> loadClients() {
        return clientService.getClientList();
    }
}

这样您就不必调用$。获取（“/clients”，null） loadClients（）调用的结果。JS代码如下所示：

stompClient.subscribe('/topic/clients', function (calResult) {
    updateClientsTable(JSON.parse(calResult.body));
});

Answer 2

正如@light_303已经提到的，混合HTTP请求和通知机制是不好的。当客户端连接时，您可以注册时刻（在/clients上获取请求），但当客户端断开连接时，您不能注册时刻。

你应该用下一种方式来思考。当用户订阅/topic/clients时：

1. 您单独向他发送带有所有客户端列表的响应，然后仅推送更新

检查此问题：在Spring Websocket上向特定用户发送消息。

这真是可笑，Spring怎么会使事情复杂化。我建议您查看其他实时web通信框架，例如Vert。x或Netty和on-Go编程语言。使用WebSockets或SockJS而不是STOMP。所有这些技术都可以明显地为您提供更灵活、更高性能的解决方案。另外，检查离心机项目，也许它与您的任务相关。

Answer 3

我认为不将REST请求与此消息传递模式混合使用更有意义。

您是否考虑过通过SockJS将“updateClients”命令发送到“/apps/updateClients”频道，该频道会回复“/topic/clients”频道？