websocketのログを出力するようにしました。

Fork: 0

nitta-lab-2019 / CosmosServer

Browse code websocketのログを出力するようにしました。 fixGetRequests master yolp
1 parent 90050b2 commit 57afde6c5036d134778046990a3fe13bc831ff31 n-kande authored on 21 Oct 2019

Patch

Unified Split

Showing 2 changed files

                Ignore Space
               Show notes
              View
            
          
          8 ■■■■■
          src/main/java/com/example/cosmos_serversb/resources/WebSocket.java
             package com.example.cosmos_serversb.resources;
 
import com.example.common.LogUtils;
import org.springframework.stereotype.Component;
 
import javax.websocket.server.ServerEndpoint;
import java.util.HashSet;
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
        System.out.println("session確立しました");
        LogUtils.info(session.getId() + " のsession確立しました");
 
//        String roomName = session.getUri().getQuery();
//        roomSessionPool.compute(roomName, (key, sessions) -> {
//            if (sessions == null) {
//                sessions = new CopyOnWriteArraySet<>();
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        String strMessage = message.getPayload();
        System.out.println("message( " + strMessage + " )を受信しました");
        LogUtils.info(session.getId() + " からmessage( " +strMessage + " )を受信しました");
 
        session.sendMessage(message);
        for(WebSocketSession roomsSession : sessions){
            roomsSession.sendMessage(message);
            LogUtils.info(roomsSession.getId() + " にmessage( " +strMessage + " )を送信しました");
        }
//        String roomName = session.getUri().getQuery();
//        for (WebSocketSession roomSession : roomSessionPool.get(roomName)) {
//            roomSession.sendMessage(message);
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session);
        System.out.println("session閉じました");
        LogUtils.info(session.getId() + " のsessionを閉じました");
 
//        String roomName = session.getUri().getQuery();
//        roomSessionPool.compute(roomName, (key, sessions) -> {
//            sessions.remove(session);
//            if (sessions.isEmpty()) {
 package com.example.cosmos_serversb.resources;
+import com.example.common.LogUtils;
 import org.springframework.stereotype.Component;
 import javax.websocket.server.ServerEndpoint;
 import java.util.HashSet;
     @Override
     public void afterConnectionEstablished(WebSocketSession session) throws Exception {
         sessions.add(session);
         System.out.println("session確立しました");
+        LogUtils.info(session.getId() + " のsession確立しました");
 //        String roomName = session.getUri().getQuery();
 //        roomSessionPool.compute(roomName, (key, sessions) -> {
 //            if (sessions == null) {
 //                sessions = new CopyOnWriteArraySet<>();
     @Override
     protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
         String strMessage = message.getPayload();
         System.out.println("message( " + strMessage + " )を受信しました");
+        LogUtils.info(session.getId() + " からmessage( " +strMessage + " )を受信しました");
         session.sendMessage(message);
         for(WebSocketSession roomsSession : sessions){
             roomsSession.sendMessage(message);
+            LogUtils.info(roomsSession.getId() + " にmessage( " +strMessage + " )を送信しました");
         }
 //        String roomName = session.getUri().getQuery();
 //        for (WebSocketSession roomSession : roomSessionPool.get(roomName)) {
 //            roomSession.sendMessage(message);
     @Override
     public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
         sessions.remove(session);
         System.out.println("session閉じました");
+        LogUtils.info(session.getId() + " のsessionを閉じました");
 //        String roomName = session.getUri().getQuery();
 //        roomSessionPool.compute(roomName, (key, sessions) -> {
 //            sessions.remove(session);
 //            if (sessions.isEmpty()) {

                Ignore Space
               Show notes
              View
            
          
          4 ■■■■■
          src/test/java/WebSocketTest/SampleClient.java
         WebSocket ws;
        final Request request = new Request.Builder()
//                .url("http://localhost:8080/WebSocketSampleServer")
                .url("http://localhost:8080/websocket")
//                .url("http://localhost:8080/websocket")
                .url("http://nitta-lab-www.is.konan-u.ac.jp/cosmos/websocket")
                .build();
        final OkHttpClient client = new OkHttpClient.Builder()
                .build();
        final WebSocketListener listener = new WebSocketListener() {
         WebSocket ws;
         final Request request = new Request.Builder()
 //                .url("http://localhost:8080/WebSocketSampleServer")
+                .url("http://localhost:8080/websocket")
+//                .url("http://localhost:8080/websocket")
+                .url("http://nitta-lab-www.is.konan-u.ac.jp/cosmos/websocket")
                 .build();
         final OkHttpClient client = new OkHttpClient.Builder()
                 .build();
         final WebSocketListener listener = new WebSocketListener() {

Show line notes below