我想将消息从 Java 推送到 WebSocket 客户端。我已经成功地让一个 js 客户端发送到服务器并在 2 个 js 客户端上收到一条消息,所以客户端代码工作正常。
我的问题是我想在 Java 应用程序中发生事件时启动发送。因此,例如,每次下 10 个订单时,都会向所有订阅的客户发送一条消息。这可能吗?
我当前的配置:
<websocket:message-broker application-destination-prefix="/app">
<websocket:stomp-endpoint path="/hello">
<websocket:sockjs/>
</websocket:stomp-endpoint>
<websocket:simple-broker prefix="/topic"/>
</websocket:message-broker>
@Controller
public class MessageController {
@MessageMapping("/hello")
@SendTo("/topic/greetings")
public Greeting greeting() throws Exception {
return new Greeting("Hello world");
}
}
我希望能够做的是这样的事情:
public class OrderManager {
@Autowired MessageController messageController;
int orderCount = 0;
public void processOrder(Order o) {
orderCount++;
if(orderCount % 10 == 0)
messageController.greeting();
}
}
所有订阅 websocket 的客户端都会收到一条消息。
最佳答案
您可以使用 SimpMessagingTemplate。
它是自动注册的。只需在您想要的任何 Spring bean 中 Autowiring
即可。
@Autowired
private SimpMessagingTemplate template;
...
this.template.convertAndSend("/topic/greetings", text);
关于java - 使用 Spring 4 WebSocket 从 Java 推送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24393480/