diff --git a/sdk-amop/src/main/java/org/fisco/bcos/sdk/amop/topic/AmopMsgHandler.java b/sdk-amop/src/main/java/org/fisco/bcos/sdk/amop/topic/AmopMsgHandler.java index 1a1fe5606..5cace8170 100644 --- a/sdk-amop/src/main/java/org/fisco/bcos/sdk/amop/topic/AmopMsgHandler.java +++ b/sdk-amop/src/main/java/org/fisco/bcos/sdk/amop/topic/AmopMsgHandler.java @@ -90,8 +90,7 @@ public void onConnect(ChannelHandlerContext ctx) { @Override public void onMessage(ChannelHandlerContext ctx, Message msg) { - logger.trace( - "receive msg, msg type:{}, content:{}", msg.getType(), new String(msg.getData())); + logger.trace("receive msg, msg type:{}, seq:{}", msg.getType(), msg.getSeq()); if (!isRunning) { logger.warn("Amop on msg, amop is not running, exit."); } diff --git a/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelImp.java b/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelImp.java index 3756cf79e..580165c25 100644 --- a/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelImp.java +++ b/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelImp.java @@ -330,6 +330,7 @@ public void asyncSendToRandom(Message out, ResponseCallback callback, Options op if (peerList.size() == 0) { logger.warn( "no available peer to send to, seq: {}, type: {}", out.getSeq(), out.getType()); + return; } int random = (int) (Math.random() * (peerList.size())); String peerIpPort = peerList.get(random); diff --git a/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelMsgHandler.java b/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelMsgHandler.java index d876c3cfb..90d959cee 100644 --- a/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelMsgHandler.java +++ b/sdk-core/src/main/java/org/fisco/bcos/sdk/channel/ChannelMsgHandler.java @@ -120,7 +120,7 @@ public void onConnect(ChannelHandlerContext ctx) { @Override public void onMessage(ChannelHandlerContext ctx, Message msg) { - logger.trace( + logger.debug( "onMessage in ChannelMsgHandler called, host : {}, seq : {}, msgType : {}", ChannelVersionNegotiation.getPeerHost(ctx), msg.getSeq(), @@ -144,15 +144,16 @@ public void onMessage(ChannelHandlerContext ctx, Message msg) { response.setCtx(ctx); callback.onResponse(response); } else { - logger.trace( - " receive message, no callback, try call handler, seq:{} , type: {}, result: {}", - msg.getSeq(), - (int) msg.getType(), - msg.getResult()); MsgHandler msgHandler = msgHandlers.get(msg.getType().intValue()); if (msgHandler != null) { + logger.trace( + " receive message, no callback, call handler, seq:{} , type: {}, result: {}", + msg.getSeq(), + (int) msg.getType(), + msg.getResult()); msgHandler.onMessage(ctx, msg); } + logger.debug(" call "); } }