From d3cdbf19b53e24a1417364b098f7b8f71f36a208 Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Sun, 28 Feb 2021 19:47:04 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java b/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java
index d1c9322..8e76216 100644
--- a/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java
+++ b/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java
@@ -3,7 +3,7 @@
import com.alibaba.fastjson.JSONObject;
import com.xcong.excoin.netty.bean.RequestBean;
import com.xcong.excoin.netty.bean.ResponseBean;
-import com.xcong.excoin.netty.common.ChannelManager;
+import com.xcong.excoin.netty.common.ServerChannelManager;
import com.xcong.excoin.netty.common.NettyTools;
import io.netty.channel.Channel;
import org.springframework.stereotype.Component;
@@ -19,7 +19,7 @@
public void webReqConnection(RequestBean requestBean) {
- Channel channel = ChannelManager.findWebSocketChannel(requestBean.getChannelId());
+ Channel channel = ServerChannelManager.findWebSocketChannel(requestBean.getChannelId());
channel.writeAndFlush(NettyTools.webSocketBytes("this is ok"));
}
@@ -30,12 +30,12 @@
String type = jsonObject.getString("type");
ResponseBean responseBean = ResponseBean.ok(requestBean.getType(), null);
- Channel channel = ChannelManager.findWebSocketChannel(requestBean.getChannelId());
+ Channel channel = ServerChannelManager.findWebSocketChannel(requestBean.getChannelId());
channel.writeAndFlush(NettyTools.webSocketBytes(JSONObject.toJSONString(responseBean)));
}
public void defaultReq(RequestBean requestBean) {
- Channel channel = ChannelManager.findWebSocketChannel(requestBean.getChannelId());
+ Channel channel = ServerChannelManager.findWebSocketChannel(requestBean.getChannelId());
channel.writeAndFlush("this is error type");
}
}
--
Gitblit v1.9.1