Netty关闭客户端

channelFuture.channel().closeFuture().sync();

package org.zln.netty.five.part05.client;

import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.zln.netty.five.part05.dto.SubscribeReq;
import org.zln.netty.five.part05.dto.SubscribeResp;

/**
 * Created by sherry on 16/11/5.
 */
public class SubReqClientHandler extends ChannelHandlerAdapter {

    /**
     * 日志
     */
    private Logger logger = LoggerFactory.getLogger(SubReqClientHandler.class);

    private static int count = 0;

    。。。。。。
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        SubscribeResp subscribeResp = (SubscribeResp) msg;
        logger.debug("这是收到的第 " + (++count) + " 笔响应 -- " + subscribeResp);
        //关闭链路
        ctx.close();
    }

。。。。。。
}