Commit 4720bbfb by huangfusuper

打印rpc日志

parent f9ce51a5
......@@ -27,9 +27,10 @@ public class NettyClientHandler extends SimpleChannelInboundHandler<RpcResponse>
@Override
protected void channelRead0(ChannelHandlerContext ctx, RpcResponse rpcResponse) throws Exception {
logger.info("------------------客户端接收到响应:{}--------------",rpcResponse);
// notify response
rpcInvokerFactory.notifyInvokerFuture(rpcResponse.getRequestId(), rpcResponse);
logger.info("------------------客户端解锁---------------");
}
@Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment