diff --git a/Server.java b/Server.java new file mode 100644 index 0000000..b1e4968 --- /dev/null +++ b/Server.java @@ -0,0 +1,34 @@ +package websocket; + +import javax.websocket.server.*; + +import java.io.IOException; + +import javax.websocket.*; + +@ServerEndpoint("/hello/") +public class Server { + private Session session; + + @OnOpen + public void connect(Session session) { + this.session= session; + System.out.println("session :"+ session); + } + + @OnClose + public void close() { + this.session=null; + System.out.println("session closed"); + } + + @OnMessage + public void onMessage(String msg) throws IOException { + System.out.println("msg recu:"+msg); + this.session.getAsyncRemote().sendText("server:"+msg); + //if (this.session != null && this.session.isOpen()) { + // this.session.getBasicRemote().sendText("server:"+msg); + //} + } + +}