public static final Map<String , Session> sessions = new ConcurrentHashMap<>();

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<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);
    }

    /**
    * Вернуть сообщение pong
    * @param identifier Идентификатор
    * @param message Сообщение
    * @return Сообщение pong
    */
    default String pong(String identifier , String message){
        return "pong";
    }
}

compile 'top.jfunc.websocket:websocket-springboot-starter:1.8.2.4'

maven { url 'https://jitpack.io' }
compile 'com.gitee.xxssyyyyssxx:websocket-springboot-starter:1.8.4'

/**
* 1. Расширить top.jfunc.websocket.BaseWebSocketEndpoint
* 2. Отметить @Component @ServerEndpoint
* @author xiongshiyan
*/
@Component
@ServerEndpoint(value ="/websocket/connect/{identifier}")
public class WebSocketEndpoint extends top.jfunc.websocket.BaseWebSocketEndpoint{
}

@EnableMemWebSocketManager для одноузлового управления
или
@EnableRedisWebSocketManager использовать механизм кластера Redis для реализации кластеризации

@Configuration
public class WebSocketConfig {
/**
 * См. https://www.cnblogs.com/betterboyz/p/8669879.html
 * Сначала необходимо внедрить ServerEndpointExporter, этот bean автоматически зарегистрирует Websocket endpoint, объявленный с помощью аннотации @ServerEndpoint.
 * Обратите внимание, что если вы используете независимый контейнер сервлетов, а не встроенный контейнер springboot напрямую, не вводите ServerEndpointExporter,
 * потому что он будет предоставлен и управляется контейнером, иначе будет сообщено о повторяющейся ошибке endpoint.
 */
@ConditionalOnProperty(prefix = "server.websocket.exporter" ,
                                name = "enable" ,havingValue = "true")
@Bean
public ServerEndpointExporter serverEndpointExporter() {
    return new ServerEndpointExporter();
}


/**
 * Можно использовать свой собственный WebSocketManager, обратите внимание на фиксированное имя
 */
/*@Bean(WebSocketManager.WEBSOCKET_MANAGER_NAME)
public WebSocketManager webSocketManager(){
``` Если используется **Nginx** в качестве балансировщика нагрузки, то необходимо добавить в конфигурацию:

Что касается мониторинга сердцебиения, можно настроить его самостоятельно, имитируя `top.jfunc.websocket.config.WebSocketSchedulingConfig`. Добавьте три параметра конфигурации для включения мониторинга сердцебиения:
- webSocket.heartCheck.enabled=true
- webSocket.heartCheck.timeSpan=1000
- webSocket.heartCheck.errorToleration=30