netty关闭客户端 -ag凯发k8国际

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

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

总结

以上是ag凯发k8国际为你收集整理的netty关闭客户端的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得ag凯发k8国际网站内容还不错，欢迎将ag凯发k8国际推荐给好友。