如何使用 Spring 4 在我的 webSocket 服务器中捕获订阅事件

Question

我按照这个 https://spring.io/guides/gs/messaging-stomp-websocket/与弹簧4，STOMP和袜子.js进行了简单的Web套接字通信

现在我想将其升级到简单聊天。我的问题是，当用户订阅新的聊天室时，他应该收到过去的消息。我不知道如何捕捉他订阅向他发送消息列表的那一刻。

我尝试使用@MessageMapping注释，但没有取得任何成功：

@Controller
public class WebSocketController {
    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    @MessageMapping("/chat/{chatId}")
    public void chat(ChatMessage message, @DestinationVariable String chatId) {
        messagingTemplate.convertAndSend("/chat/" + chatId, new ChatMessage("message: " + message.getText()));
    }
    @SubscribeMapping("/chat")
    public void chatInit() {
        System.out.println("worked");
        int chatId = 1; //for example
        messagingTemplate.convertAndSend("/chat/" + chatId, new ChatMessage("connected"));
    }
}

然后我创建了它：

@Controller
public class ApplicationEventObserverController implements ApplicationListener<ApplicationEvent> {
    @Override
    public void onApplicationEvent(ApplicationEvent applicationEvent) {
        System.out.println(applicationEvent);
    }
}

它有效，但捕获所有可能的事件，我认为这不是一个好的做法。

所以，我的问题可以改写：当用户订阅 sth 时如何发送初始数据？

Answer 1

当客户端订阅目标时，可以使用@SubscribeMapping处理程序方法将任何内容直接返回给客户端。返回的对象不会转到代理，而是直接发送到客户端：

@SubscribeMapping("/chat")
public Collection<ChatMessage> chatInit() {
    ...
    return messages;
}

在客户端：

socket.subscribe("/app/chat", function(message) {
    ...
});

查看 GitHub 上的聊天示例，其中显示了此确切场景。