Browse Source

feat: socket - ws - front 테스트 확인

feature/socket
지대한 7 months ago
parent
commit
e488d3be33
  1. 6
      app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/handler/WebSocketHandler.java
  2. 2
      app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/core/storage/ChannelStorage.java
  3. 2
      app/kac-websocket-app/src/main/java/kr/co/palnet/kac/websocket/service/ScheduledService.java
  4. 2
      http-client/http-client.env.json

6
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.ChannelHandler;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler; 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 io.netty.handler.codec.http.websocketx.WebSocketFrame;
import kr.co.palnet.kac.websocket.core.storage.ChannelStorage; import kr.co.palnet.kac.websocket.core.storage.ChannelStorage;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -30,9 +32,9 @@ public class WebSocketHandler extends SimpleChannelInboundHandler<WebSocketFrame
public void channelActive(ChannelHandlerContext ctx) throws Exception { public void channelActive(ChannelHandlerContext ctx) throws Exception {
log.info(">>>>> channelActive <<<<<"); log.info(">>>>> channelActive <<<<<");
ChannelStorage channelStorage = ChannelStorage.getInstance(); ChannelStorage channelStorage = ChannelStorage.getInstance();
log.info("active size before : {}", channelStorage.getAll().size()); log.info("active size before : {}", channelStorage.getGroup().size());
channelStorage.add(ctx.channel()); channelStorage.add(ctx.channel());
log.info("active size after : {}", channelStorage.getAll().size()); log.info("active size after : {}", channelStorage.getGroup().size());
} }
@Override @Override

2
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); return channelGroup.find(channelId);
} }
public ChannelGroup getAll() { public ChannelGroup getGroup() {
return channelGroup; return channelGroup;
} }

2
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"); log.info("ready send to all channel");
// 채널 가져오기 // 채널 가져오기
ChannelStorage channelStorage = ChannelStorage.getInstance(); ChannelStorage channelStorage = ChannelStorage.getInstance();
ChannelGroup channelGroup = channelStorage.getAll(); ChannelGroup channelGroup = channelStorage.getGroup();
// 데이터 가져오기 // 데이터 가져오기
ControlStorage controlStorage = ControlStorage.getInstance(); ControlStorage controlStorage = ControlStorage.getInstance();
List<DronControlDto> controlDtoList = controlStorage.getList(); List<DronControlDto> controlDtoList = controlStorage.getList();

2
http-client/http-client.env.json

@ -1,6 +1,6 @@
{ {
"local": { "local": {
"appHost": "http://localhost:8000", "appHost": "http://localhost:8000",
"wsHost": "http://localhost:8001" "wsHost": "ws://localhost:8001"
} }
} }
Loading…
Cancel
Save