diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java index e261f63d3..85bd695de 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java @@ -79,17 +79,17 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { // 判断该帧类型是否为某请求帧的应答帧 String requestFrameType = YKCFrameTypeCode.PileAnswersRelation.getRequestFrameType(frameType); - log.info("同步获取响应数据-判断该帧类型是否为某请求帧的应答帧, frameType:{}, requestFrameType:{}", frameType, requestFrameType); + // log.info("同步获取响应数据-判断该帧类型是否为某请求帧的应答帧, frameType:{}, requestFrameType:{}", frameType, requestFrameType); if (StringUtils.isNotBlank(requestFrameType)) { // 根据请求id,在集合中找到与外部线程通信的SyncPromise对象 String msgId = ctx.channel().id().toString() + "_" + requestFrameType; - log.info("同步获取响应数据-收到消息, msgId:{}", msgId); + // log.info("同步获取响应数据-收到消息, msgId:{}", msgId); SyncPromise syncPromise = RpcUtil.getSyncPromiseMap().get(msgId); if(syncPromise != null) { // 设置响应结果 syncPromise.setRpcResult(msg); // 唤醒外部线程 - log.info("同步获取响应数据-唤醒外部线程, SyncPromise:{}", JSON.toJSONString(syncPromise)); + // log.info("同步获取响应数据-唤醒外部线程, SyncPromise:{}", JSON.toJSONString(syncPromise)); syncPromise.wake(); } }