import javax.websocket.ClientEndpoint;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
import javax.websocket.MessageHandler;
@ClientEndpoint
public class MyWebSocketClient {
Session session;
@OnOpen
public void onOpen(Session session) {
this.session = session;
}
@OnMessage
public void onMessage(String message) {
System.out.println("Received message: " + message);
}
public void sendMessage(String message) {
session.getAsyncRemote().sendText(message);
}
}
import javax.websocket.ContainerProvider;
import javax.websocket.WebSocketContainer;
import java.net.URI;
public class Main {
public static void main(String[] args) throws Exception {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
String uri = "ws://localhost:8080/mywebsocket";
MyWebSocketClient client = new MyWebSocketClient();
container.connectToServer(client, new URI(uri));
// Send message to server
client.sendMessage("Hello, Server!");
}
}
client.sendMessage("Hello, Server!");
