jfinal-websocket

public interface WebSocketManager {
    /**
     * 在容器中的名字
     */
    String WEBSOCKET_MANAGER_NAME  = "webSocketManager";
    /**
     * 根据标识获取websocket session
     * @param identifier 标识
     * @return WebSocket
     */
    WebSocket get(String identifier);

    /**
     * 放入一个 websocket session
     * @param identifier 标识
     * @param webSocket websocket
     */
    void put(String identifier, WebSocket webSocket);

    /**
     * 删除
     * @param identifier 标识
     */
    void remove(String identifier);

    /**
     * 获取当前机器上的保存的WebSocket
     * @return WebSocket Map
     */
    Map<String , WebSocket> localWebSocketMap();

    /**
     * 统计所有在线人数
     * @return 所有在线人数
     */
    default int size(){
        return localWebSocketMap().size();
    }

    /**
     * 给某人发送消息
     * @param identifier 标识
     * @param message 消息
     */
    void sendMessage(String identifier, String message);

    /**
     * 广播
     * @param message 消息
     */
    void broadcast(String message);

    /**
     * WebSocket接收到消息的函数调用
     * @param identifier 标识
     * @param message 消息内容
     */
    void onMessage(String identifier , String message);

    /**
     * 在OnMessage中判断是否是心跳,
     * 从客户端的消息判断是否是ping消息
     * @param identifier 标识
     * @param message 消息
     * @return 是否是ping消息
     */
    default boolean isPing(String identifier , String message){
        return "ping".equalsIgnoreCase(message);
    }

    /**
     * 返回心跳信息
     * @param identifier 标识
     * @param message 消息
     * @return 返回的pong消息
     */
    default String pong(String identifier , String message){
        return "pong";
    }
}

```
/**
 * 接收处理跳转
 */
@Override
public void configHandler(Handlers me) {
      me.add(new WebSocketHandler("^/websocket"));
}
```

```
public class WebSocketManagerConfig {
    /**
     * 基于内存的单机 WebSocketManager
     */
    public static void configMemory(){
        WebSocketManagerUtil.setWebSocketManager(new MemWebSocketManager());
    }
    
    /**
     * 基于Redis的集群 WebSocketManager
     */
    public static void configCluster(Jedis jedis){
        jedis.subscribe(new Subscriber() , RedisWebSocketManager.CHANNEL);
        WebSocketManagerUtil.setWebSocketManager(new RedisWebSocketManager(jedis));
    }
    
    /**
     * 配置心跳监测
     * @param period 多长时间执行一次
     * @param timeSpan 时间间隔
     * @param errorTolerant 错误容忍次数
     * @param todoAtRemoved 干什么
     */
    public static void configHeartBeatCheck(int period , long timeSpan , int errorTolerant , TodoAtRemoved todoAtRemoved){
        Executors.newScheduledThreadPool(1).scheduleAtFixedRate(()->{
            new WebSocketHeartBeatChecker().check(
                    WebSocketManagerUtil.getWebSocketManager() ,
                    timeSpan , errorTolerant, todoAtRemoved);
        } , 0 , period , TimeUnit.SECONDS);
    }
}
```

```
@ServerEndpoint("/websocket/{identifier}")
public class WebSocketServerEndPoint extends BaseWebSocketEndpoint {
    @OnOpen
    public void onOpen(Session session , @PathParam(IDENTIFIER) String identifier) {
    }
    @OnClose
    public void onClose(Session session , @PathParam(IDENTIFIER) String identifier) {
    }
    @OnMessage
    public void onMessage(String message, Session session , @PathParam(IDENTIFIER) String identifier) {
    }
}
```

public class DemoListener implements top.jfunc.common.event.core.ApplicationListener<top.jfunc.websocket.WebSocketConnectEvent/WebSocketCloseEvent> {
    @Override
    public void onApplicationEvent(top.jfunc.websocket.WebSocketConnectEvent/WebSocketCloseEvent event) {
        //do with event
    }
}

new EventInitializer().scanPackage("xxx listener包")/addListener(xxx listener).async().start();

```
Nginx反向代理要支持WebSocket，需要配置几个header，否则连接的时候就报404
       proxy_http_version 1.1;
       proxy_set_header Upgrade $http_upgrade;
       proxy_set_header Connection "upgrade";
       proxy_read_timeout 3600s; //这个时间不长的话就容易断开连接
```