diff --git a/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/handler/WebSocketHandler.java b/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/handler/WebSocketHandler.java index 5903dde..a69c2a6 100644 --- a/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/handler/WebSocketHandler.java +++ b/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/handler/WebSocketHandler.java @@ -3,6 +3,8 @@ package kr.co.palnet.kac.websocket.core.handler; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.SimpleChannelInboundHandler; +import io.netty.channel.group.ChannelGroup; +import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; import io.netty.handler.codec.http.websocketx.WebSocketFrame; import kr.co.palnet.kac.websocket.core.storage.ChannelStorage; import lombok.extern.slf4j.Slf4j; @@ -30,9 +32,9 @@ public class WebSocketHandler extends SimpleChannelInboundHandler>>>> channelActive <<<<<"); ChannelStorage channelStorage = ChannelStorage.getInstance(); - log.info("active size before : {}", channelStorage.getAll().size()); + log.info("active size before : {}", channelStorage.getGroup().size()); channelStorage.add(ctx.channel()); - log.info("active size after : {}", channelStorage.getAll().size()); + log.info("active size after : {}", channelStorage.getGroup().size()); } @Override diff --git a/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/storage/ChannelStorage.java b/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/storage/ChannelStorage.java index 6fc60f1..81a3e3d 100644 --- a/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/storage/ChannelStorage.java +++ b/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/storage/ChannelStorage.java @@ -34,7 +34,7 @@ public class ChannelStorage { return channelGroup.find(channelId); } - public ChannelGroup getAll() { + public ChannelGroup getGroup() { return channelGroup; } diff --git a/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/service/ScheduledService.java b/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/service/ScheduledService.java index eab93ab..d38affd 100644 --- a/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/service/ScheduledService.java +++ b/app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/service/ScheduledService.java @@ -29,7 +29,7 @@ public class ScheduledService { log.info("ready send to all channel"); // 채널 가져오기 ChannelStorage channelStorage = ChannelStorage.getInstance(); - ChannelGroup channelGroup = channelStorage.getAll(); + ChannelGroup channelGroup = channelStorage.getGroup(); // 데이터 가져오기 ControlStorage controlStorage = ControlStorage.getInstance(); List controlDtoList = controlStorage.getList(); diff --git a/http-client/http-client.env.json b/http-client/http-client.env.json index cddb90d..925cc7a 100644 --- a/http-client/http-client.env.json +++ b/http-client/http-client.env.json @@ -1,6 +1,6 @@ { "local": { "appHost": "http://localhost:8000", - "wsHost": "http://localhost:8001" + "wsHost": "ws://localhost:8001" } } \ No newline at end of file