diff --git a/src/main/java/com/ntlab/irisserver/resources/HelloWorld.java b/src/main/java/com/ntlab/irisserver/resources/HelloWorld.java index 92513a8..a169898 100644 --- a/src/main/java/com/ntlab/irisserver/resources/HelloWorld.java +++ b/src/main/java/com/ntlab/irisserver/resources/HelloWorld.java @@ -10,7 +10,7 @@ public class HelloWorld { @GET public String getHello() { - return "WebSocketのデモの追加。12/15-16:25"; + return "WebSocketのデモの追加。12/15-16:55"; } } diff --git a/src/main/java/com/ntlab/irisserver/websockets/HelloWebSocket.java b/src/main/java/com/ntlab/irisserver/websockets/HelloWebSocket.java index 2eceb16..8352029 100644 --- a/src/main/java/com/ntlab/irisserver/websockets/HelloWebSocket.java +++ b/src/main/java/com/ntlab/irisserver/websockets/HelloWebSocket.java @@ -17,43 +17,43 @@ // 5秒に1回HelloWorldを送るデモ @ServerEndpoint("/hello-websocket") public class HelloWebSocket { - private static final Queue sessions = new ConcurrentLinkedQueue<>(); +// private static final Queue sessions = new ConcurrentLinkedQueue<>(); +// +// static { +// ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); +// service.scheduleWithFixedDelay(HelloWebSocket::broadcast, 5, 5, TimeUnit.SECONDS); +// } +// +// @OnMessage +// public String onMessage(String message) { +// System.out.println("WebSocketで受信したメッセージ/ " + message); +// return "WebSocketでメッセージを正常に受信しました!"; +// } +// +// @OnError +// public void onError(Throwable th) { +// System.out.println("WebSocketエラーが発生/ " + th.getMessage()); +// } +// +// @OnOpen +// public void onOpen(Session session) { +// System.out.println("WebSocketセッション確立"); +// sessions.add(session); +// } +// +// @OnClose +// public void onClose(Session session) { +// System.out.println("WebSocketセッション終了"); +// sessions.remove(session); +// } - static { - ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); - service.scheduleWithFixedDelay(HelloWebSocket::broadcast, 5, 5, TimeUnit.SECONDS); - } - - @OnMessage - public String onMessage(String message) { - System.out.println("WebSocketで受信したメッセージ/ " + message); - return "WebSocketでメッセージを正常に受信しました!"; - } - - @OnError - public void onError(Throwable th) { - System.out.println("WebSocketエラーが発生/ " + th.getMessage()); - } - - @OnOpen - public void onOpen(Session session) { - System.out.println("WebSocketセッション確立"); - sessions.add(session); - } - - @OnClose - public void onClose(Session session) { - System.out.println("WebSocketセッション終了"); - sessions.remove(session); - } - - public static void broadcast() { - Date now = new Date(); - SimpleDateFormat formatter = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); +// public static void broadcast() { +// Date now = new Date(); +// SimpleDateFormat formatter = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); // sessions.forEach(session -> { // session.getAsyncRemote().sendText("HelloWorld! : " + formatter.format(now)); // }); - } + //} } \ No newline at end of file