rpc调用有重复2次 about nettyrpc HOT 2 CLOSED

类 com.nettyrpc.client.RpcClientHandler

public RPCFuture sendRequest(RpcRequest request) {
final CountDownLatch latch = new CountDownLatch(1);
RPCFuture rpcFuture = new RPCFuture(request);
pendingRPC.put(request.getRequestId(), rpcFuture);
//channel.writeAndFlush(request); #9 注释掉就行了，看下面一行，再次调用了写入了request

    channel.writeAndFlush(request).addListener(new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture future) {
            latch.countDown();
        }
    });
    try {
        latch.await();
    } catch (InterruptedException e) {
        LOGGER.error(e.getMessage());
    }

    return rpcFuture;
}

}

from nettyrpc.

@caleimo
Thanks, fixed it.

from nettyrpc.