Netty关闭客户端

在启动客户端的时候，我们一般会

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

这是一段阻塞的代码，除非链路断了，否则是不会终止的，我们可以在handler中手动关闭，达到关闭客户端的效果

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

转载于:https://www.cnblogs.com/sherrykid/p/6038672.html

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！