import javax.websocket.Endpoint;
import javax.websocket.EndpointConfig;
import javax.websocket.Session;
import javax.websocket.CloseReason;
public class MyWebSocketServer extends Endpoint {
@Override
public void onOpen(Session session, EndpointConfig config) {
}
@Override
public void onClose(Session session, CloseReason closeReason) {
}
@Override
public void onError(Session session, Throwable throwable) {
}
}
<web-app>
<servlet>
<servlet-name>WebSocketServer</servlet-name>
<servlet-class>org.apache.tomcat.websocket.server.WsServerContainer</servlet-class>
<init-param>
<param-name>javax.websocket.server.ServerContainer</param-name>
<param-value>org.apache.tomcat.websocket.server.WsServerContainer</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>WebSocketServer</servlet-name>
<url-pattern>/websocket/*</url-pattern>
</servlet-mapping>
</web-app>
import org.apache.tomcat.websocket.server.WsServerContainer;
public class WebSocketServerApp {
public static void main(String[] args) {
WsServerContainer serverContainer = (WsServerContainer) ContainerProvider.getWebSocketContainer();
serverContainer.addEndpoint(MyWebSocketServer.class);
}
}
import javax.websocket.ClientEndpoint;
import javax.websocket.EndpointConfig;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
@ClientEndpoint
public class MyWebSocketClient {
@OnOpen
public void onOpen(Session session, EndpointConfig config) {
}
@OnMessage
public void onMessage(String message, Session session) {
}
}
