文档章节

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

石头哥哥
 石头哥哥
发布于 2015/07/28 14:16
字数 529
阅读 953
收藏 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   处理远程主机强制关闭一个连接


© 著作权归作者所有

共有 人打赏支持
上一篇: mysql编译安装
下一篇: 关于rpc的思考
石头哥哥
粉丝 302
博文 203
码字总数 120417
作品 2
渝中
程序员
私信 提问

暂无文章

iOS切面编程

aop编程(面向切面编程),其原理也就是在不更改正常的业务处理流程的前提下,通过生成一个动态代理类,从而实现对目标对象嵌入附加的操作。在iOS中,要想实现相似的效果也很简单,利用OC的动态性,...

RainOrz
30分钟前
1
0
0006-Zookeeper指标分析

1. 问题描述 通过CDH管理平台,进入Zookeeper管理界面,Zookeeper的平均请求延迟、最小请求延迟、最大请求延迟指标趋势图维持不变,指标数据异常。 2.问题复现 登录CDH平台,进入Zookeeper管...

Hadoop实操
39分钟前
1
0
PAT(Basic Level) 乙级练习题 ------ 1047 编程团体赛 java

1047.编程团体赛 题目: 编程团体赛的规则为:每个参赛队由若干队员组成;所有队员独立比赛;参赛队的成绩为所有队员的成绩和;成绩最高的队获胜。 现给定所有队员的比赛成绩,请你编写程序找...

Carol998
43分钟前
1
0
抓包

1、下载 2、 tcpdump -i em1 host 目标域名 -n -X -s0 -w 写入文件名 命令解析:-i 制定网卡-s 0 : 抓取数据包时默认抓取长度为68字节。加上-S 0 后可以抓到完整的数据包-w ./targ...

HenryZhou2
44分钟前
3
0
axios 实现下载excel文件的说明~~~~遇到一个大坑,还是没有熟悉源码的罪过

本来下载文件直接用a标签,非常easy,但是如果数据量巨大的话,没有loading效果,用户体验非常差。优化项目的时候领导要求必须修改。因此只能用axios来下载了。 a标签下载: <a :href="dow...

YJ_
45分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部