文档章节

netty 处理远程主机强制关闭一个连接

石头哥哥
 石头哥哥
发布于 2015/07/28 14:16
字数 529
阅读 5.7K
收藏 4

行业解决方案、产品招募中!想赚钱就来传!>>>

netty   处理远程主机强制关闭一个连接,首先看下api解释:

/**
 * Returns {@code true} if and only if the channel should not close itself when its remote
 * peer shuts down output to make the connection half-closed.  If {@code false}, the connection
 * is closed automatically when the remote peer shuts down output.
 */
boolean isAllowHalfClosure();

/**
 * Sets whether the channel should not close itself when its remote peer shuts down output to
 * make the connection half-closed.  If {@code true} the connection is not closed when the
 * remote peer shuts down output. Instead,
 * {@link ChannelInboundHandler#userEventTriggered(ChannelHandlerContext, Object)}
 * is invoked with a {@link ChannelInputShutdownEvent} object. If {@code false}, the connection
 * is closed automatically.
 */
SocketChannelConfig setAllowHalfClosure(boolean allowHalfClosure);

默认是自动关闭channel,但是这样无法捕获远程主机强制关闭一个连接异常,所以 设置serverconfig 

allowHalfClosure=true

这里初始化配置可以在下面的方法中处理

/**
 * This method will be called once the {@link Channel} was registered. After the method returns this instance
 * will be removed from the {@link ChannelPipeline} of the {@link Channel}.
 *
 * @param ch            the {@link Channel} which was registered.
 * @throws Exception    is thrown if an error occurs. In that case it will be handled by
 *                      {@link #exceptionCaught(ChannelHandlerContext, Throwable)} which will by default close
 *                      the {@link Channel}.
 */
protected abstract void initChannel(Channel ch) throws Exception;

像这样:

ch.config().setAllowHalfClosure(true);

就可以在

/**
 * Calls {@link ChannelHandlerContext#fireUserEventTriggered(Object)} to forward
 * to the next {@link ChannelInboundHandler} in the {@link ChannelPipeline}.
 *
 * Sub-classes may override this method to change behavior.
 */
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    ctx.fireUserEventTriggered(evt);
}

中捕获远程主机强制关闭一个连接了 想这样处理,在自己的handler中重写上面的方法:

/**
 * 读取数据超时   --->  断定连接断开  ----> 释放对应的socket连接
 * <p/>
 * 心跳处理
 * 链路读写超时处理
 *
 * @param ctx
 * @param evt
 * @throws Exception sub_reactor                          ChannelInputShutdownEvent.INSTANCE
 */
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    try {
        Channel channel = ctx.channel();
        if (evt instanceof IdleStateEvent) {
            IdleStateEvent e = (IdleStateEvent) evt;
            if (e.state() == IdleState.READER_IDLE) {
                channel.close();  //call back channelInactive(ChannelHandlerContext ctx)
                if (logger.isDebugEnabled()) logger
                        .debug(channel.remoteAddress() + "---No data was received for a while ,read time out... ...");
            } //     because we are attaching  more importance to the read_idle time(timeout to rec)
            else if (e.state() == IdleState.WRITER_IDLE) { // No data was sent for a while.
                channel.close();
                if (logger.isDebugEnabled()) logger
                        .debug(channel.remoteAddress() + "---No data was sent for a while.write time out... ...");
            }
        } else if (evt instanceof ChannelInputShutdownEvent) {
            channel.close();//远程主机强制关闭连接
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}


通过以上设置就可以捕获 并处理逻辑相关资源了 netty   处理远程主机强制关闭一个连接


石头哥哥

石头哥哥

粉丝 304
博文 203
码字总数 120417
作品 2
广州
程序员
私信 提问
加载中
请先登录后再评论。
Netty那点事(三)Channel与Pipeline

Channel是理解和使用Netty的核心。Channel的涉及内容较多,这里我使用由浅入深的介绍方法。在这篇文章中,我们主要介绍Channel部分中Pipeline实现机制。为了避免枯燥,借用一下《盗梦空间》的...

黄亿华
2013/11/24
2W
22
我的架构演化笔记 功能1: 基本的用户注册

“咚咚”,一阵急促的敲门声, 我从睡梦中惊醒,我靠,这才几点,谁这么早, 开门一看,原来我的小表弟放暑假了,来南京玩,顺便说跟我后面学习一个网站是怎么做出来的。 于是有了下面的一段...

强子哥哥
2014/05/31
976
3
CDH5: 使用parcels配置lzo

一、Parcel 部署步骤 1 下载: 首先需要下载 Parcel。下载完成后,Parcel 将驻留在 Cloudera Manager 主机的本地目录中。 2 分配: Parcel 下载后,将分配到群集中的所有主机上并解压缩。 3 激...

cloud-coder
2014/07/01
6.8K
1
树莓派(Raspberry Pi):完美的家用服务器

自从树莓派发布后,所有在互联网上的网站为此激动人心的设备提供了很多有趣和具有挑战性的使用方法。虽然这些想法都很棒,但树莓派( RPi )最明显却又是最不吸引人的用处是:创建你的完美家用...

异次元
2013/11/09
6.1K
8
5分钟 maven3 快速入门指南

前提条件 你首先需要了解如何在电脑上安装软件。如果你不知道如何做到这一点,请询问你办公室,学校里的人,或花钱找人来解释这个给你。 不建议给Maven的服务邮箱来发邮件寻求支持。 安装Mav...

fanl1982
2014/01/23
1.2W
6

没有更多内容

加载失败,请刷新页面

加载更多

叮! Q币派送中,快来看看你中奖了吗?

中奖名单新鲜出炉啦! 大家好 为了感谢大家一直以来对我们公众号的关注和支持 D妹来给大家发!奖!品!了! 是哪几位幸运鹅 能把这30Q币收入囊中? 赶紧过来康康吧! 也欢迎各位后续多多分享...

腾讯云DNSPod
今天
24
0
Qt音视频开发5-vlc事件订阅

一、前言 事件订阅可以拿到文件长度、播放进度、播放状态改变等信息,vlc的事件订阅机制封装的比较友好,只需要先创建一个事件管理器,然后逐个订阅自己感兴趣的需要的事件,不感兴趣的可以不...

飞扬青云
33分钟前
18
0
酒精和药物影响下出现交通事故的频率

导读: 在酒精或药物影响下驾驶,已被认为是与发生潜在交通事故和出现严重伤亡结果相关的关键因素[1]。2016年,美国酒驾事故导致10,497人死亡,占当年交通事故死亡总人数的28%,其死亡总人数...

科研菌
昨天
0
0
高可用高并发的 9 种技术架构!

来源:androidchina http://www.androidchina.net/7928.html 1、分层 分层是企业应用系统中最常见的一种架构模式,将系统在横向维度上切分成几个部分,每个部分负责一部分相对简单并比较单一...

Java技术栈
34分钟前
23
0
联盟链要对区块链做减法

当前联盟链平台在公有链的基础上,对共识机制做调整,去掉公有属性,使得准入可控、效率提升,这实际上是对区块链在做减法。但这是否足够呢? 我们在应用中很快发现,联盟链的使用比较受限制...

FISCO-BCOS开源社区
昨天
11
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部