正在显示
1 个修改的文件
包含
0 行增加
和
5 行删除
| 1 | package com.crossoverjie.cim.server.handle; | 1 | package com.crossoverjie.cim.server.handle; |
| 2 | 2 | ||
| 3 | -import com.alibaba.fastjson.JSON; | ||
| 4 | import com.alibaba.fastjson.JSONObject; | 3 | import com.alibaba.fastjson.JSONObject; |
| 5 | import com.crossoverjie.cim.common.constant.Constants; | 4 | import com.crossoverjie.cim.common.constant.Constants; |
| 6 | import com.crossoverjie.cim.common.exception.CIMException; | 5 | import com.crossoverjie.cim.common.exception.CIMException; |
| @@ -64,9 +63,6 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto | @@ -64,9 +63,6 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto | ||
| 64 | 63 | ||
| 65 | LOGGER.info("定时检测服务端是否存活"); | 64 | LOGGER.info("定时检测服务端是否存活"); |
| 66 | 65 | ||
| 67 | - Thread thread = Thread.currentThread(); | ||
| 68 | - LOGGER.info("当前线程信息={}===={}",thread.getClass(), JSON.toJSONString(thread)); | ||
| 69 | - | ||
| 70 | HeartBeatHandler heartBeatHandler = SpringBeanFactory.getBean(ServerHeartBeatHandlerImpl.class) ; | 66 | HeartBeatHandler heartBeatHandler = SpringBeanFactory.getBean(ServerHeartBeatHandlerImpl.class) ; |
| 71 | heartBeatHandler.process(ctx) ; | 67 | heartBeatHandler.process(ctx) ; |
| 72 | } | 68 | } |
| @@ -124,7 +120,6 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto | @@ -124,7 +120,6 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto | ||
| 124 | protected void channelRead0(ChannelHandlerContext ctx, CIMRequestProto.CIMReqProtocol msg) throws Exception { | 120 | protected void channelRead0(ChannelHandlerContext ctx, CIMRequestProto.CIMReqProtocol msg) throws Exception { |
| 125 | LOGGER.info("收到msg={}", msg.toString()); | 121 | LOGGER.info("收到msg={}", msg.toString()); |
| 126 | Thread thread = Thread.currentThread(); | 122 | Thread thread = Thread.currentThread(); |
| 127 | - LOGGER.info("正常当前线程信息={}===={}",thread.getClass(), JSON.toJSONString(thread)); | ||
| 128 | 123 | ||
| 129 | if (msg.getType() == Constants.CommandType.LOGIN) { | 124 | if (msg.getType() == Constants.CommandType.LOGIN) { |
| 130 | //保存客户端与 Channel 之间的关系 | 125 | //保存客户端与 Channel 之间的关系 |
-
请 注册 或 登录 后发表评论