@ClientEndpoint
public class MyWebSocketClient {
@OnOpen
public void onOpen(Session session) {
System.out.println("WebSocket opened: " + session.getId());
session.getAsyncRemote().sendText("Hello Server");
}
@OnMessage
public void onMessage(String message, Session session) {
System.out.println("Received message: " + message);
}
@OnClose
public void onClose(Session session, CloseReason closeReason) {
System.out.println("WebSocket closed: " + session.getId() + ", Reason: " + closeReason.getReasonPhrase());
}
public static void main(String[] args) {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
String uri = "ws://localhost:8080/websocket";
try {
Session session = container.connectToServer(MyWebSocketClient.class, URI.create(uri));
} catch (Exception e) {
e.printStackTrace();
}
}
}
