@ServerEndpoint("/websocket")
public class WebSocketServer {
    private static Set<Session> clients = Collections.synchronizedSet(new HashSet<Session>());

    @OnOpen
    public void onOpen(Session session) {
        // 添加клиент        clients.add(session);
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        // Обрабатывать сообщения
    }

    @OnClose
    public void onClose(Session session) {
        // Удалятьклиент        clients.remove(session);
    }

    @OnError
    public void onError(Throwable error, Session session) {
        // Обработка ошибок
    }
}

public static void sendMessage(String message) {
    for (Session session : clients) {
        try {
            session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            // Отправить сообщение Обработка ошибок
        }
    }
}

@ClientEndpoint
public class WebSocketClient {

    @OnOpen
    public void onOpen(Session session) {
        // Происходит при открытии канала связи
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        // Обрабатывать полученные сообщения
    }

    @OnClose
    public void onClose(Session session,CloseReason reason) {
        // закрытиесоединять    }

    @OnError
    public void onError(Session session, Throwable error) {
        // Обработка ошибок
    }
}

public static void connect(String endpointURI) {
    try {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        container.connectToServer(WebSocketClient.class, URI.create(endpointURI));
    } catch (DeploymentException | IOException e) {
        // Обработка ошибок
    }
}

public void send(String message) {
    try {
        session.getBasicRemote().sendText(message);
    } catch (IOException e) {
        // Отправить сообщение Обработка ошибок
    }
}