websocket定时发送消息

要实现websocket定时发送消息，可以使用定时器（如quartz）来触发发送消息的任务。首先，创建一个job类，该类不需要继承任何类或实现任何接口。在该类中，可以使用ConcurrentHashMap来获取WebSocketServer对象的映射，然后遍历映射中的WebSocketServer对象，向每个客户端推送消息。具体代码如下所示：

package com.socket.web.quartz;

import com.socket.web.socket.WebSocketServer;

import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class TestJob {
    public void task(){
        // 获取WebSocketServer对象的映射
        ConcurrentHashMap<String, WebSocketServer> map = WebSocketServer.getWebSocketMap();
        if (map.size() != 0){
            for (Map.Entry<String, WebSocketServer> entry : map.entrySet()) {
                WebSocketServer webSocketServer = entry.getValue();
                try {
                    // 向客户端推送消息
                    webSocketServer.getSession().getBasicRemote().sendText("每隔两秒,向客户端推送一次数据");
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
        }else {
            System.out.println("WebSocket未连接");
        }
    }
}

然后，可以使用定时器来执行这个job类的任务，实现定时发送消息的功能。