netty之心跳机制

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了netty之心跳机制，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含5816字，纯文字阅读大概需要9分钟。

内容图文

　　1、心跳机制，在netty3和netty5上面都有。但是写法有些不一样。

　　2、心跳机制在服务端和客户端的作用也是不一样的。对于服务端来说：就是定时清除那些因为某种原因在一定时间段内没有做指定操作的客户端连接。对于服务端来说：用来检测是否断开连接，然后尝试重连等问题。游戏上面也可以来监控延时问题。

　　3、我这边只写了服务端的心跳用法，客户端基本差不多。

　　1）netty3的写法

                import
                 org.jboss.netty.bootstrap.ServerBootstrap;

                import
                 org.jboss.netty.channel.ChannelPipeline;

                import
                 org.jboss.netty.channel.ChannelPipelineFactory;

                import
                 org.jboss.netty.channel.Channels;

                import
                 org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;

                import
                 org.jboss.netty.handler.codec.string.StringDecoder;

                import
                 org.jboss.netty.handler.codec.string.StringEncoder;

                import
                 org.jboss.netty.handler.timeout.IdleStateHandler;

                import
                 org.jboss.netty.util.HashedWheelTimer;


                import
                 java.net.InetSocketAddress;

                import
                 java.util.concurrent.ExecutorService;

                import
                 java.util.concurrent.Executors;


                public
                class
                 Server {

    
                public
                static
                void
                 main(String[] args) {

        
                //
                声明服务类
        ServerBootstrap serverBootstrap = new ServerBootstrap();

        //设定线程池
        ExecutorService boss = Executors.newCachedThreadPool();
        ExecutorService work = Executors.newCachedThreadPool();

        //设置工厂
        serverBootstrap.setFactory(new NioServerSocketChannelFactory(boss,work));

        //设置管道流
        serverBootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            @Override
            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline channelPipeline = Channels.pipeline();
                //添加处理方式
                channelPipeline.addLast("idle",new IdleStateHandler(new HashedWheelTimer(),5,5,10));
                channelPipeline.addLast("decode",new StringDecoder());
                channelPipeline.addLast("encode",new StringEncoder());
                channelPipeline.addLast("server",new ServerHandler());
                return channelPipeline;
            }
        });

        //设置端口
        serverBootstrap.bind(new InetSocketAddress(9000));
    }
}

　　备注：这里和之前有变化的就是管道里面多加了一个心跳，实际的处理还是在处理类里面

　channelPipeline.addLast("idle",new IdleStateHandler(new HashedWheelTimer(),5,5,10));

                import org.jboss.netty.channel.*;
import org.jboss.netty.handler.timeout.IdleState;
import org.jboss.netty.handler.timeout.IdleStateEvent;

publicclass ServerHandler extends SimpleChannelHandler {

    @Override
    publicvoid messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
        System.out.println("client:"+e.getMessage());
        ctx.getChannel().write(e.getMessage());
        super.messageReceived(ctx, e);
    }

    @Override
    publicvoid handleUpstream(ChannelHandlerContext ctx, ChannelEvent e) throws Exception {
        if (e instanceof IdleStateEvent) {
            if (((IdleStateEvent)e).getState() == IdleState.ALL_IDLE) {
                ChannelFuture channelFuture = ctx.getChannel().write("Time out,You will close");
                channelFuture.addListener(channelFuture1 -> ctx.getChannel().close());
            }
        } else {
            super.handleUpstream(ctx, e);
        }
    }

    @Override
    publicvoid exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
        super.exceptionCaught(ctx, e);
    }

    @Override
    publicvoid channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        super.channelConnected(ctx, e);
    }

    @Override
    publicvoid channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        super.channelDisconnected(ctx, e);
    }

    @Override
    publicvoid channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        super.channelClosed(ctx, e);
    }
}

　　说明：这里是用SimpleChannelHandler里面给出的事件处理来实现的。方法为handleUpstream

　　2）netty5的写法和netty3差不多

                import
                 io.netty.bootstrap.ServerBootstrap;

                import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.handler.timeout.IdleStateHandler;

publicclass Server {

    publicstaticvoid main(String[] args) {
        //服务类
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        //声明两个线程池
        EventLoopGroup boss = new NioEventLoopGroup();
        EventLoopGroup work = new NioEventLoopGroup();

        try {
            //设置线程组            serverBootstrap.group(boss,work);
            //设置服务socket工厂
            serverBootstrap.channel(NioServerSocketChannel.class);
            //设置管道
            serverBootstrap.childHandler(new ChannelInitializer<Channel>() {
                protectedvoid initChannel(Channel channel) throws Exception {
                    channel.pipeline().addLast(new IdleStateHandler(5,5,10));
                    channel.pipeline().addLast(new StringDecoder());
                    channel.pipeline().addLast(new StringEncoder());
                    channel.pipeline().addLast(new ServerHandler());
                }
            });
            //设置服务器连接数
            serverBootstrap.option(ChannelOption.SO_BACKLOG,2048);
            //设置tcp延迟状态
            serverBootstrap.option(ChannelOption.TCP_NODELAY,true);
            //设置激活状态，2小时清除
            serverBootstrap.option(ChannelOption.SO_KEEPALIVE,true);
            //监听端口
            ChannelFuture channelFuture = serverBootstrap.bind(9000);
            //等待服务器关闭            channelFuture.channel().closeFuture().sync();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭线程池            boss.shutdownGracefully();
            work.shutdownGracefully();
        }

    }

}

                import
                 io.netty.channel.ChannelFuture;

                import
                 io.netty.channel.ChannelFutureListener;

                import
                 io.netty.channel.ChannelHandlerContext;

                import
                 io.netty.channel.SimpleChannelInboundHandler;

                import
                 io.netty.handler.timeout.IdleState;

                import
                 io.netty.handler.timeout.IdleStateEvent;


                public
                class ServerHandler extends SimpleChannelInboundHandler<String> {

    //接收消息并处理protectedvoid messageReceived(ChannelHandlerContext channelHandlerContext, String s) throws Exception {
        System.out.println(s);
        channelHandlerContext.writeAndFlush("hello client");
    }

    @Override
    publicvoid userEventTriggered(final ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent) {
            if (((IdleStateEvent)evt).state() == IdleState.ALL_IDLE) {
                ChannelFuture channelFuture = ctx.writeAndFlush("Time out,You will close");
                channelFuture.addListener(new ChannelFutureListener() {
                    publicvoid operationComplete(ChannelFuture channelFuture) throws Exception {
                        ctx.channel().close();
                    }
                });
            }
        } else {
            super.userEventTriggered(ctx, evt);
        }
    }
}

原文：http://www.cnblogs.com/ll409546297/p/8031989.html

内容总结

以上是互联网集市为您收集整理的netty之心跳机制全部内容，希望文章能够帮你解决netty之心跳机制所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1077044.html

来源：【匿名】

【上一篇】[netty] 0.Java NIO 原理【下一篇】一起学Netty（九）之LengthFieldBasedFrameDecoder

更多 ►

【netty之心跳机制】教程文章相关的互联网学习教程文章

一、前言　　前面学习了WebSocket协议，并且通过示例讲解了WebSocket的具体使用，接着学习如何使用无连接的UDP来广播事件。二、UDP广播事件2.1 UDP基础　　面向连接的TCP协议管理端到端的连接，在连接生命周期中，发送的消息会有序并且可靠地进行传输，最后连接有序地终止。然而，在无连接协议（如UDP）中，没有持久连接的概念，每个消息（UDP数据报）都是独立的传输，此外，UDP没有TCP的纠错机制（即每个对等体会确认其接收到的分...

Netty 架构

其实跟架构无关，这其实是我对Netty的一个整体认识。它会一直更新，直到学习完Netty为止。根据User guide，Server端会有一个bossGroup来接受Socket请求，有一个workerGroup来处理IO事件，这边的事件包括accept，connect, read, write(待确认)原文：http://www.cnblogs.com/rsdyxjh/p/4773968.html

Netty 搭建 WebSocket 服务端【代码】

一、编码器、解码器... ...@Autowired private HttpRequestHandler httpRequestHandler; @Autowired private TextWebSocketFrameHandler textWebSocketFrameHandler;... ....childHandler(new ChannelInitializer<SocketChannel> () {@Overrideprotected void initChannel(SocketChannel channel) throws Exception {// WebSocket 是基于 Http 协议的，要使用 Http 解编码器channel.pipeline().addLast("http-codec", new HttpServ...

【Netty】Netty源码编译【代码】【图】

环境准备Jdk：1.8.0_181Idea：2021.1.1 Community Edition（社区版）Maven：3.6.31、下载Netty源码　　本例下载的是 netty-4.1.63.Final2、使用Idea打开项目，进行编译导入Idea：File --> Open --> 选择Netty项目目录 netty-4.1.63.Final等待索引建立完成，在控制台输入命令：mvn clean package -DskipTests=true可能出现的错误　　问题1: Could not find artifact io.netty:netty-tcnative:jar:${os.detected.classifier}:2.0.38....

netty之微信-效果展示（一）【图】

支持可热拔插的channelHandler ，心跳与空闲检测，源码 1、启动服务端（运行nettyServer的main方法） 2、启动客户端（运行nettyclient的main方法），并输入登录用户名登录，如下图： 3、单聊发送方：接受方： 4、群聊（1）、发起群聊，创建群client： server：（2）、群管理（加入、退出、获取群成员列表）入群者：（3）、群聊原文：https://www.cnblogs.com/shanheyongmu/p/13344498.html

Netty Reator（三）Reactor 模型【图】

Netty Reator（三）Reactor 模型Netty 系列目录 (https://www.cnblogs.com/binarylei/p/10117436.html)本文介绍 DC Schmidt 大神的一篇文章《Reactor: an object behavioral pattern for concurrent event demultiplexing and event handler dispatching》一、What：Reactor 模式是什么？反应器设计模式(Reactor pattern)是一种为处理并发服务请求，并将请求提交到一个或者多个服务处理程序的事件设计模式。当客户端请求抵达后，服...

Mina、Netty、Twisted一起学（五）：整合protobuf【图】

protobuf是谷歌的Protocol Buffers的简称，用于结构化数据和字节码之间互相转换（序列化、反序列化），一般应用于网络传输，可支持多种编程语言。protobuf怎样使用这里不再介绍，本文主要介绍在MINA、Netty、Twisted中怎样使用protobuf，不了解protobuf的同学能够去參考我的还有一篇博文。在前面的一篇博文中。有介绍到一种用一个固定为4字节的前缀Header来指定Body的字节数的一种消息切割方式。在这里相同要使用到。仅仅是当中Bod...

（中级篇 NettyNIO编解码开发）第七章-java序列化【代码】

相信大多数Java程序员接触到的第一种序列化或者编解码技术就是.Java的默认序列化，只需要序列化的POJO对象实现java.io.Serializable接口，根据实际情况生成序列ID,这个类就能够通过java.io.Objectlnput和java.io.ObjectOutput序列化和反序列化。不需要考虑跨语言调用，对序列化的性能也没有苛刻的要求时，Java默认的序列化机制是最明智的选择之一。正因为此，虽然Java序列化机制存在着一些弊病，依然得到了广泛的应用。本章主要内容...

Pipeline的入站流程详解（netty源码死磕7）【代码】【图】

精进篇：netty源码死磕7 巧夺天工——Pipeline入站流程详解1. Pipeline的入站流程在讲解入站处理流程前，先脑补和铺垫一下两个知识点：（1）如何向Pipeline添加一个Handler节点（2）Handler的出站和入站的区分方式1.1. HandlerContext节点的添加在Pipeline实例创建的同时，Netty为Pipeline创建了一个Head和一个Tail，并且建立好了链接关系。代码如下：protected DefaultChannelPipeline(Channel channel) { this.channel = Obj...

netty入门（1）【代码】【图】

netty是基于JDK NIO的，为什么不直接使用java nio呢；屏蔽了JDk的实现细节，修复了很多java nio已知的bug java共支持3种网络编程模型/io模式：BIO，NIO(同步非阻塞)，AIO（异步非阻塞）netty是基于NIO的Selector其实就是netty中的bossGroup，client就是workGroup1. 通过事件来决定选择处理哪个chanal业务2. Buffer本身是一块内存，实际上是一个数组，可指定大小，数据读写都由buffer实现3. Nio中我们是面向块（block）和buffer编程...

Netty服务器Demo【代码】

代码在我自己的gitlab:http://120.76.219.142/marc/nettyServerDML类:package com.wulala;import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; import java.util.Properties; import java.util.UUID;public class ExecuteDML {private String driver;private String url;private String user;private String password;public void initParam(String paramFil...

Mina、Netty、Twisted一起学（八）：HTTP服务器【图】

HTTP协议应该是目前使用最多的应用层协议了，用浏览器打开一个网站就是使用HTTP协议进行数据传输。HTTP协议也是基于TCP协议，所以也有服务器和客户端。HTTP客户端一般是浏览器，当然还有可能是其他东西。HTTP服务器，也就是Web服务器，目前已经有很多成熟的产品，例如Apache HTTP Server、Tomcat、Nginx、IIS等。本文的内容不是讲解如何使用以上的HTTP服务器，而是要分别用MINA、Netty、Twisted实现一个简单的HTTP服务器。首先，要...

Netty系列之Netty可靠性分析

1. 背景1.1. 宕机的代价1.1.1. 电信行业毕马威国际(KPMG International)在对46个国家的74家运营商进行调查后发现，全球通信行业每年的收益流失约为400亿美元，占总收入的1%-3%。导致收益流失的因素有多种，主要原因就是计费BUG。1.1.2. 互联网行业美国太平洋时间8月16日下午3点50分到3点55分（北京时间8月17日6点50分到6点55分），谷歌遭遇了宕机。根据事后统计，短短的5分钟，谷歌损失了54.5万美元。也就是服务每中断一分钟，损失...

Netty源码分析第3章(客户端接入流程)---->第4节: NioSocketChannel注册到selector【代码】

Netty源码分析第三章: 客户端接入流程第四节: NioSocketChannel注册到selector 我们回到最初的NioMessageUnsafe的read()方法:publicvoid read() {//必须是NioEventLoop方法调用的, 不能通过外部线程调用assert eventLoop().inEventLoop();//服务端channel的configfinal ChannelConfig config = config();//服务端channel的pipelinefinal ChannelPipeline pipeline = pipeline();//处理服务端接入的速率final RecvByteBufAllocator...

Netty源码死磕二（Netty的启动流程）【代码】【图】

引言上一篇文章介绍了Netty的线程模型及EventLoop机制，相信大家对Netty已经有一个基本的认识。那么本篇文章我会根据Netty提供的Demo来分析一下Netty启动流程。启动流程概览开始之前，我们先来分析下Netty服务端的启动流程，下面是一个简单的流程图启动流程大致分为五步创建ServerBootstrap实例，ServerBootstrap是Netty服务端的启动辅助类，其存在意义在于其整合了Netty可以提供的所有能力，并且尽可能的进行了封装，以方便我们使...

NETTY - 最热教程

Netty面试题（2020）尚硅谷2019年Netty教程学习笔记--苟声 Java多线程：Linux多路复用，Java NIO与...当Tomcat遇上Netty java-Netty连接限制《精通并发与Netty》学习笔记（07 - 基...netty简介 Flink1.12源码解读—— Netty通讯模式 Netty 源码解析（二）：Netty 的 Chann...Netty源码解析 -- 对象池Recycler实现原...

首页 / NETTY / netty之心跳机制

netty之心跳机制

内容导读

内容图文

内容总结

内容备注

内容手机端

【netty之心跳机制】教程文章相关的互联网学习教程文章

【Netty】UDP广播事件【代码】【图】

Netty 架构

Netty 搭建 WebSocket 服务端【代码】

【Netty】Netty源码编译【代码】【图】

netty之微信-效果展示（一）【图】

Netty Reator（三）Reactor 模型【图】

Mina、Netty、Twisted一起学（五）：整合protobuf【图】

（中级篇 NettyNIO编解码开发）第七章-java序列化【代码】

Pipeline的入站流程详解（netty源码死磕7）【代码】【图】

netty入门（1）【代码】【图】

Netty服务器Demo【代码】

Mina、Netty、Twisted一起学（八）：HTTP服务器【图】

Netty系列之Netty可靠性分析

Netty源码分析第3章(客户端接入流程)---->第4节: NioSocketChannel注册到selector【代码】

Netty源码死磕二（Netty的启动流程）【代码】【图】

NETTY - 最新教程

NETTY - 最热教程