12345678910111213141516171819202122232425262728293031323334 |
- 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);
- //}
- }
-
- }
|