zoukankan      html  css  js  c++  java
  • 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;
    
        。。。。。。
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            SubscribeResp subscribeResp = (SubscribeResp) msg;
            logger.debug("这是收到的第 " + (++count) + " 笔响应 -- " + subscribeResp);
            //关闭链路
            ctx.close();
        }
    
    。。。。。。
    }
  • 相关阅读:
    Ajax原生XHR对象
    node-sass报错解决方法
    AngularJS中的表单验证
    javaScirpt事件详解-原生事件基础(一)
    jQuery Ajax总结
    Ruby 方法
    JS中常遇到的浏览器兼容问题和解决方法
    History对象
    转码与解码
    Location对象
  • 原文地址:https://www.cnblogs.com/sherrykid/p/6038672.html
Copyright © 2011-2022 走看看