五 netty學習之給寫操做加listener

1. channelRead的時候,有一個ChannelReadComplete()方法

前者是具體的讀操做,後者是讀完成以後的回調操做

2. 而寫的操做沒有什麼相似的ChannelWriteComplete(), 因此,咱們只有加一個listener

private final ChannelFutureListener trafficGenerator = new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture future) {
            if (future.isSuccess()) {
                generateTraffic();
            } else {
                future.cause().printStackTrace();
                future.channel().close();
            }
        }
    };

ctx.writeAndFlush(content.duplicate().retain()).addListener(trafficGenerator);

上面都是官方的例子裏