websocket-java

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

	}
}


@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://localhost.bb.com.br:8080/Angular/caelum";
		String uri = "ws://127.0.0.1:8082/caelum/websocket";
		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();
		}
	}
}