import javax.websocket.Endpoint; import javax.websocket.EndpointConfig; import javax.websocket.Session; import java.io.IOException; public class MyEndpoint 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) { } @Override public void onMessage(Session session, String message) { } } import javax.websocket.server.ServerContainer; import javax.websocket.server.ServerEndpointConfig; import org.glassfish.tyrus.server.Server; public class MyServer { public static void main(String[] args) { Server server = new Server("localhost", 8080, "/myapp", null, MyEndpoint.class); try { server.start(); server.getServerContainer().addEndpoint(ServerEndpointConfig.Builder.create(MyEndpoint.class, "/myendpoint").build()); Thread.sleep(Long.MAX_VALUE); } catch (Exception e) { e.printStackTrace(); } finally { server.stop(); } } }


上一篇:
下一篇:
切换中文