Conheça o Tyrus - sua implementação para WebSocket com backend em Node e Java

 var http = require('http'); var sockjs = require('sockjs'); var clients = {};
var sockjs\_echo = sockjs.createServer();
function broadcast (message, exclude) { console.log("mensagem a ser enviada: "+ message); for ( var i in clients ) { if ( i != exclude ) { console.log("Cliente selecionado para enviar mensagem"+ clients\[i\]); clients\[i\].write( message ); }
} }
sockjs\_echo.on('connection', function(conn) { //guarda cliente conectado clients```conn.id
 = conn;
//Quando receber uma mensagem, faz o broadcast conn.on('data', function(data) { broadcast(data); }); });
//criando um servidor http para ouvir o serviço var server = http.createServer();
//criando o canal de comunição websocket caelum sockjs\_echo.installHandlers(server, {prefix:'/caelum'});
server.listen(8082, '127.0.0.1'); 

 @ServerEndpoint("/caelum") public class CaelumServer { @OnOpen public void onOpen(Session cliente) { System.out.println("Novo cliente" + cliente); }
@OnClose public void onClose(Session cliente) { System.out.println("Cliente desconectado" + cliente); }
@OnMessage public void message(String message, Session client) throws IOException {
Set<Session> openSessions = client.getOpenSessions(); for (Session session : openSessions) { session.getBasicRemote().sendText(message); } } } 

 <dependency> <groupId>org.glassfish.tyrus.bundles</groupId> <artifactId>tyrus-standalone-client</artifactId> <version>1.4</version> </dependency> 

 @ClientEndpoint public class ChatClientReceiver { @OnOpen public void onOpen(Session session) { System.out.println("Client Receiver conectado: " + session); }
@OnMessage public void processMessage(String message) { System.out.println("Recebendo no Client Receiver: " + message); } }
@ClientEndpoint public class ChatClientSender { @OnOpen public void onOpen(Session session) { try { System.out.println("Client Sender conectado: " + session); session.getBasicRemote().sendText("Mensagem Enviada Via WebSocket"); } catch (IOException e) { e.printStackTrace(); } }
@OnMessage public void processMessage(String message) { System.out.println("Recebendo no Client Sender: "+ message); } } 

 public class TestClient { public static void main(String\[\] args) { WebSocketContainer container = ContainerProvider.getWebSocketContainer(); String uri = "ws://127.0.0.1:8082/caelum/websocket"; // String uri = "ws://127.0.0.1:8080/WebSocket/caelum"; try { container.connectToServer(ChatClientReceiver.class, URI.create(uri)); Thread.sleep(5000); container.connectToServer(ChatClientSender.class, URI.create(uri)); } catch (DeploymentException | IOException | InterruptedException e) { e.printStackTrace(); } } }