import javax.websocket.ClientEndpoint;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
import javax.websocket.CloseReason;
@ClientEndpoint
public class WebSocketClient {
@OnOpen
public void onOpen(Session session) {
}
@OnMessage
public void onMessage(String message, Session session) {
}
public static void main(String[] args) {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
String uri = "ws://localhost:8080/websocket";
try {
Session session = container.connectToServer(WebSocketClient.class, URI.create(uri));
session.getBasicRemote().sendText("Hello, WebSocket server!");
} catch (Exception e) {
e.printStackTrace();
}
}
@OnClose
public void onClose(Session session, CloseReason closeReason) {
}
}
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="websocketContainer" class="org.springframework.web.socket.client.standard.StandardWebSocketClient" />
<bean id="webSocketClient" class="com.example.WebSocketClient">
<constructor-arg name="container" ref="websocketContainer" />
</bean>
</beans>
