public class ResponseFuture {
    private final String commandSeq;
    private final Channel processChannel;
    private final long timeoutMillis;
    private final BiConsumer<Command/*request*/, Command/*ack*/> consumer;
    private final long beginTimestamp = System.currentTimeMillis();
    private final CountDownLatch countDownLatch = new CountDownLatch(1);

    private final SemaphoreReleaseOnlyOnce once;

    private volatile Command request;
    private volatile Command response;
    private volatile boolean sendOk = true;
    private volatile Throwable cause;
」

    
final ResponseFuture responseFuture = new ResponseFuture(channel, commandSeq, timeoutMillis, null, null, request);
            this.responseTable.put(commandSeq, responseFuture);
            channel.writeAndFlush(request).addListener((ChannelFutureListener) f -> {
                if(f.isSuccess()) {
                    responseFuture.setSendOk(true);
                    if(logger.isDebugEnabled()) {
                        logger.debug("发送命令 {}", JSON.toJSONString(request));
                    }
                    return;
                } else {
                    responseFuture.setSendOk(false);
                }

                requestFail(commandSeq, f.cause());
                throw new NettyException("invokeSync error", f.cause());
            });

            Command response = responseFuture.waitResponse(timeoutMillis);

    
public Command waitResponse(final long timeoutMillis) throws InterruptedException {
        this.countDownLatch.await(timeoutMillis, TimeUnit.MILLISECONDS);
        return this.response;
    }