java websocket 定时器

Java WebSocket API 提供了 javax.websocket.Session 接口，该接口定义了用于 WebSocket 会话的方法。在该接口中提供了一个用于定时器的方法：

public Future<Void>  setTimer(long milliseconds);

可以通过该方法设置 WebSocket 会话的定时器，以便在指定的时间后执行某些操作。该方法返回一个 Future 对象，可以使用该对象来控制定时器的行为，例如取消定时器。

以下是一个简单的示例，演示如何在 Java WebSocket 中使用定时器：

import javax.websocket.*;
import java.net.URI;
import java.util.concurrent.Future;

@ClientEndpoint
public class WebSocketClient {

    private Session session;

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        try {
            Future<Void> future = session.setTimer(5000);
            future.get(); // 阻塞当前线程，等待定时器执行完成
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @OnMessage
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }

    @OnError
    public void onError(Throwable t) {
        t.printStackTrace();
    }

    public static void main(String[] args) {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        try {
            container.connectToServer(WebSocketClient.class, URI.create("ws://localhost:8080"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在上面的示例中，我们在 WebSocketClient 类中实现了 javax.websocket.ClientEndpoint 注解，这是 Java WebSocket API 的一部分，用于标识 WebSocket 客户端。

在 onOpen() 方法中，我们通过 session.setTimer() 方法设置了一个定时器，定时器将在 5 秒后触发。在定时器执行完成后，我们可以在 onMessage() 方法中接收到服务端发送的消息。

需要注意的是，在使用 Future.get() 方法时，当前线程会被阻塞，直到定时器执行完成。如果不想阻塞当前线程，可以使用 CompletableFuture 的异步方式来处理定时器事件。