java - Spring Boot 中 websocket 的互斥体

Question

我有一个问题，我不知道到底要搜索什么。我有一个 Spring Boot 应用程序，它通过带有 stomp javascript 客户端的 Web 套接字广播消息。问题是我是否可以在发送消息时对其加锁，因为我不希望有人同时发送另一条消息。我想要制作的系统就像交通灯。如果你能给我一个例子或者要寻找什么。

Answer 1

您应该使用synchronized关键字并等待客户端响应。 synchronized 关键字确保只有一个线程可以同时执行该方法。您需要客户端响应，因为您可以按顺序发送两条消息，例如以两秒的间隔发送，但您的客户端将同时收到它们。响应可以是一些虚拟的 ok 消息。

public class Traffic {
    synchronized void Send() {
        // write message to websocket
        // read response from websocket 
    }
}