1 回答
TA贡献1848条经验 获得超10个赞
我发现通过在我的控制器中使用它:
@MessageMapping("/meeting/{roomId}")
private void sendMessageTpPrivateRoom(String message, @DestinationVariable String roomId) throws IOException {
System.out.println("message sent to: " + roomId);
this.template.convertAndSend("/meeting/" + roomId, message);
addToHistory(roomId, message);
}
在我的配置中与此相结合:
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/socket")
.setAllowedOrigins("*")
.withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.setApplicationDestinationPrefixes("/app")
.enableSimpleBroker("/chat", "/meeting");
}
我能够动态创建聊天室,其中一个聊天室中的客户端不会从另一个聊天室中的客户端接收消息
添加回答
举报