2. 程式人生 > >Netty 實現心跳機制.md

Netty 實現心跳機制.md

阿新 • • 發佈：2018-11-14
ann 構造 red 通過 case 程序 evel exc 基本使用

netty 心跳機制示例，使用netty4，IdleStateHandler 實現。

本文假設你已經了解了Netty的使用，或者至少寫過netty的helloworld，知道了netty的基本使用。我們知道使用netty的時候，大多數的東西都與Handler有關，我們的業務邏輯基本都是在Handler中實現的。Netty中自帶了一個IdleStateHandler 可以用來實現心跳檢測。

心跳檢測的邏輯

本文中我們將要實現的心跳檢測邏輯是這樣的：服務端啟動後，等待客戶端連接，客戶端連接之後，向服務端發送消息。如果客戶端在“幹活”那麽服務端必定會收到數據，如果客戶端“閑下來了”那麽服務端就接收不到這個服務端的消息，既然客戶端閑下來了，不幹事，那麽何必浪費連接資源呢？所以服務端檢測到一定時間內客戶端不活躍的時候，將客戶端連接關閉。本文要實現的邏輯步驟為：

  1. 啟動服務端，啟動客戶端
  2. 客戶端向服務端發送"I am alive"，並sleep隨機時間，用來模擬空閑。
  3. 服務端接收客戶端消息，並返回"copy that"，客戶端空閑時 計數+1.
  4. 服務端客戶端繼續通信
  5. 服務端檢測客戶端空閑太多，關閉連接。客戶端發現連接關閉了，就退出了。

有了這個思路，我們先來編寫服務端。

心跳檢測服務端代碼

public class HeartBeatServer {

    int port ;
    public HeartBeatServer(int port){
        this.port = port;
    }

    public void start(){
        ServerBootstrap bootstrap = new ServerBootstrap();
        EventLoopGroup boss = new NioEventLoopGroup();
        EventLoopGroup worker = new NioEventLoopGroup();
        try{
            bootstrap.group(boss,worker)
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new HeartBeatInitializer());

            ChannelFuture future = bootstrap.bind(port).sync();
            future.channel().closeFuture().sync();
        }catch(Exception e){
            e.printStackTrace();
        }finally {
            worker.shutdownGracefully();
            boss.shutdownGracefully();
        }
    }
    public static void main(String[] args) throws Exception {
        HeartBeatServer server = new HeartBeatServer(8090);
        server.start();
    }
}

熟悉netty的同誌，對於上面的模板一樣的代碼一定是在熟悉不過了。啥都不用看，只需要看childHandler(new HeartBeatInitializer()) 這一句。HeartBeatInitializer就是一個ChannelInitializer顧名思義，他就是在初始化channel的時做一些事情。我們所需要開發的業務邏輯Handler就是在這裏添加的。其代碼如下：

public class HeartBeatInitializer extends ChannelInitializer<Channel> {

    @Override
    protected void initChannel(Channel channel) throws Exception {
        ChannelPipeline pipeline = channel.pipeline();
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());
        pipeline.addLast(new IdleStateHandler(2,2,2, TimeUnit.SECONDS));
        pipeline.addLast(new HeartBeatHandler());
    }
}

代碼很簡單，我們先添加了StringDecoder,和StringEncoder。這兩個其實就是編解碼用的，下面的IdleStateHandler才是本次心跳的核心組件。我們可以看到IdleStateHandler的構造函數中接收了4個參數，起定義如下：

public IdleStateHandler(long readerIdleTime, long writerIdleTime, long allIdleTime, TimeUnit unit);

三個空閑時間參數，以及時間參數的格式。我們的例子中設置的是2,2,2，意思就是客戶端2秒沒有讀/寫，這個超時時間就會被觸發。超時事件觸發就需要我們來處理了，這就是上的HeartBeatInitializer中最後一行的HeartBeatHandler所做的事情。代碼如下：

public class HeartBeatHandler extends SimpleChannelInboundHandler<String> {

    int readIdleTimes = 0;

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String s) throws Exception {
        System.out.println(" ====== > [server] message received : " + s);
       if("I am alive".equals(s)){
            ctx.channel().writeAndFlush("copy that");
        }else {
           System.out.println(" 其他信息處理 ... ");
       }
    }

    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        IdleStateEvent event = (IdleStateEvent)evt;

        String eventType = null;
        switch (event.state()){
            case READER_IDLE:
                eventType = "讀空閑";
                readIdleTimes ++; // 讀空閑的計數加1
                break;
            case WRITER_IDLE:
                eventType = "寫空閑";
                // 不處理
                break;
            case ALL_IDLE:
                eventType ="讀寫空閑";
                // 不處理
                break;
        }
        System.out.println(ctx.channel().remoteAddress() + "超時事件：" +eventType);
        if(readIdleTimes > 3){
            System.out.println(" [server]讀空閑超過3次，關閉連接");
            ctx.channel().writeAndFlush("you are out");
            ctx.channel().close();
        }
    }
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.err.println("=== " + ctx.channel().remoteAddress() + " is active ===");
    }

}

至此，我們的服務端寫好了。

心跳檢測客戶端代碼

netty的api設計使得編碼的模式非常具有通用性，所以客戶端代碼和服務端的代碼幾乎一樣：啟動client端的代碼幾乎一樣，也需要一個ChannelInitializer，也需要Handler。改動的地方很少，因此本文不對客戶端代碼進行詳細解釋。下面給出client端的完整代碼：

public class HeartBeatClient  {

    int port;
    Channel channel;
    Random random ;

    public HeartBeatClient(int port){
        this.port = port;
        random = new Random();
    }
    public static void main(String[] args) throws Exception{
        HeartBeatClient client = new HeartBeatClient(8090);
        client.start();
    }

    public void start() {
        EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
        try{
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(eventLoopGroup).channel(NioSocketChannel.class)
                    .handler(new HeartBeatClientInitializer());

            connect(bootstrap,port);
            String  text = "I am alive";
            while (channel.isActive()){
                sendMsg(text);
            }
        }catch(Exception e){
            // do something
        }finally {
            eventLoopGroup.shutdownGracefully();
        }
    }

    public void connect(Bootstrap bootstrap,int port) throws Exception{
        channel = bootstrap.connect("localhost",8090).sync().channel();
    }

    public void sendMsg(String text) throws Exception{
        int num = random.nextInt(10);
        Thread.sleep(num * 1000);
        channel.writeAndFlush(text);
    }

    static class HeartBeatClientInitializer extends ChannelInitializer<Channel> {

        @Override
        protected void initChannel(Channel ch) throws Exception {
            ChannelPipeline pipeline = ch.pipeline();
            pipeline.addLast("decoder", new StringDecoder());
            pipeline.addLast("encoder", new StringEncoder());
            pipeline.addLast(new HeartBeatClientHandler());
        }
    }

    static class HeartBeatClientHandler extends SimpleChannelInboundHandler<String> {
        @Override
        protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
            System.out.println(" client received :" +msg);
            if(msg!= null && msg.equals("you are out")) {
                System.out.println(" server closed connection , so client will close too");
                ctx.channel().closeFuture();
            }
        }
    }
}

運行代碼

在上面的代碼寫好之後，我們先啟動服務端，然後在啟動客戶端。運行日誌如下：

server端：

=== /127.0.0.1:57700 is active ===
 ====== > [server] message received : I am alive
 ====== > [server] message received : I am alive
/127.0.0.1:57700超時事件：寫空閑
/127.0.0.1:57700超時事件：讀空閑
/127.0.0.1:57700超時事件：讀寫空閑
/127.0.0.1:57700超時事件：寫空閑
/127.0.0.1:57700超時事件：讀空閑
/127.0.0.1:57700超時事件：讀寫空閑
/127.0.0.1:57700超時事件：寫空閑
 ====== > [server] message received : I am alive
/127.0.0.1:57700超時事件：寫空閑
/127.0.0.1:57700超時事件：讀寫空閑
/127.0.0.1:57700超時事件：讀空閑
/127.0.0.1:57700超時事件：寫空閑
/127.0.0.1:57700超時事件：讀寫空閑
/127.0.0.1:57700超時事件：讀空閑
 [server]讀空閑超過3次，關閉連接

client端：

 client sent msg and sleep 2
 client received :copy that
 client received :copy that
 client sent msg and sleep 6
 client sent msg and sleep 6
 client received :copy that
 client received :you are out
 server closed connection , so client will close too

Process finished with exit code 0

通過上面的運行日誌，我們可以看到：

1.客戶端在與服務器成功建立之後，發送了3次‘I am alive‘，服務端也回應了3次：‘copy that‘

2.由於客戶端消極怠工，超時了多次，服務端關閉了鏈接。

3.客戶端知道服務端拋棄自己之後，也關閉了連接，程序退出。

以上簡單了演示了一下，netty的心跳機制，其實主要就是使用了IdleStateHandler。源碼下載：https://gitee.com/dimixu/netty_learn.git

Netty 實現心跳機制.md

相關推薦

Netty 實現心跳機制.md

ann 構造 red 通過 case 程序 evel exc 基本使用 netty 心跳機制示例，使用netty4，IdleStateHandler 實現。 本文假設你已經了解了Netty的使用，或者至少寫過netty的helloworld，知道了netty的基本使用。我們

Netty學習(八)-Netty的心跳機制

1. 如何實現心跳機制一般實現心跳機制由兩種方式： TCP協議自帶的心跳機制來實現；在應用層來實現。但是TCP協議自帶的心跳機制系統預設是設定的是2小時的心跳頻率。它檢查不到機器斷電、網線拔出、防火牆這些斷線。而且邏輯層處理斷線可能也不是那麼好處理。另外該心跳機制是與TCP協議繫結的，那如果我們要是使用

netty 實現長連線，心跳機制，以及重連

實現的功能 心跳機制 and 長連線 and 重連機制 and 應用訊息傳輸： 這裡最關鍵的就是通過netty中的 IdleStateHandler 超時機制來實現心跳和重連 然後通過org.msgpack編碼器來實現跨平臺資料傳輸， 在這實現的功能就是通過Scanner來輸

聊聊心跳機制及netty心跳實現

　　我們在使用netty的時候會使用一個引數，ChannelOption.SO_KEEPALIVE為true, 設定好了之後再Linux系統才會對keepalive生效，但是linux裡邊需要配置幾個引數，tcp_keepalive_time, tcp_keepalive_invl, tcp_keepaliv

netty服務端實現心跳超時的主動拆鏈

use ctx out apt ket cond else pipeline ali 一、服務器啟動示例： public class MySocketServer { protected static Logger logger = LoggerFactory.g

心跳機制tcp keepalive的討論、應用及“斷網”、"斷電"檢測的C代碼實現(Windows環境下)

astar har 心跳 存在 假設 clu ali clean struct 版權聲明：本文為博主原創文章，轉載時請務必註明本文地址， 禁止用於任何商業用途， 否則會用法律維權。 https://blog.csdn.net/stpeace/article/details/

netty的心跳檢測實現

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

C#之實現Scoket心跳機制

TCP網路長連線 手機能夠使用聯網功能是因為手機底層實現了TCP/IP協議，可以使手機終端通過無線網路建立TCP連線。TCP協議可以對上層網路提供介面，使上層網路資料的傳輸建立在“無差別”的網路之上。 建立起一個TCP連線需要經過“三次握手”： 第一次握手：客戶端傳送syn包(syn=j)到伺服

NETTY 心跳機制

end value trap parseint acceptor blog channel 出發 每次 最近工作比較忙，但閑暇之余還是看了阿裏的馮家春（fengjiachun）的github上的開源代碼Jupiter，寫的RPC框架讓我感嘆人外有人，廢話不多說，下面的代碼全

基於Netty實現的WebSocket聊天室--支援多人同時線上及定時心跳檢測

專案簡介 基於Netty實現的WebSocket聊天室，實現的功能如下： 支援暱稱登入； 支援多人同時線上； 同步顯示線上人數； 支援文字和表情的內容； 瀏覽器與伺服器保持長連線，定時心跳檢測；

Python3 Socket與Socket心跳機制簡單實現

什麼是 Socket? Socket又稱"套接字"，應用程式通常通過"套接字"向網路發出請求或者應答網路請求，使主機間或者一臺計算機上的程序間可以通訊。 socket()函式 Python 中，我們用 socket（）函式來建立套接字，語法格式如下： socket.s

netty自定義訊息實現心跳檢測與重連

其實客戶端心跳傳送用到的是IdleStateHandler，詳細看程式碼你就會明白為什麼。 //處理空閒狀態事件的處理器 pipeline.addLast(new IdleStateHandler(6,7,8, TimeUnit.SECONDS)); 在IdleSt

Netty(一) SpringBoot 整合長連線心跳機制

前言 Netty 是一個高效能的 NIO 網路框架，本文基於 SpringBoot 以常見的心跳機制來認識 Netty。 最終能達到的效果： 客戶端每隔 N 秒檢測是否需要傳送心跳。 服務端也每隔 N 秒檢測是否需要傳送心跳。 服務端可以主動 push 訊息到客戶端。 基於 SpringBo

Android TCP長連線 心跳機制及實現

維護任何一個長連線都需要心跳機制，客戶端傳送一個心跳給伺服器，伺服器給客戶端一個心跳應答， 這樣雙方都知道他們之間的連線是沒有斷開。【客戶端先發送給服務端】 如果超過一個時間的閾值，客戶端沒有收到伺服器的應答，或者伺服器沒有收到客戶端的心跳， 那麼對

java零碎要點009---java實現伺服器心跳機制,TCP握手

什麼是心跳包？ 心跳包就是在客戶端和伺服器間定時通知對方自己狀態的一個自己定義的命令字，按照一定的時間間隔傳送，類似於心跳，所以叫做心跳包。 　　  用來判斷對方（裝置，程序或其它網元）是否正常執行，採用定時傳送簡單的通訊包，如果在指定時間段內未收到對方響應，則判斷對方已經離線。

Socket長連線Android端心跳機制實現

1. 把socket連結和心跳功能都放在一個Service中，為什麼要放在Service中？ 一般我們這種socket幾乎是跟app的生命週期一樣長，甚至更長。不管在不在Service中去完成操作，我們都得開非同步執行緒，雖然Service並不是

Netty實現服務端客戶端長連線通訊及心跳檢測

通過netty實現服務端與客戶端的長連線通訊，及心跳檢測。       基本思路：netty服務端通過一個Map儲存所有連線上來的客戶端SocketChannel,客戶端的Id作為Map的key。每次伺服器端如果要向某個客戶端傳送訊息，只需根據ClientId取出對應的So

netty自定義心跳機制

   在我的上一篇文章中已經介紹過了rts遊戲的基本架構，下面來看一下心跳協議的使用    在netty中重寫ChannelInboundHandlerAdapter的userEventTriggered方法可以實現心跳協議的檢測，寫起來也比較簡單，網上的demo很多，但是

淺析 Netty心跳機制

public IdleStateHandler(int readerIdleTimeSeconds, int writerIdleTimeSeconds, int allIdleTimeSeconds) { this((long)readerIdleTimeSeconds, (long)writerI

PHP實現事件機制實例分析

word-wrap [0 popu except switch targe att otto 對象 PHP實現事件機制實例分析 內置了事件機制的語言不多，php也沒有提供這種功能。事件(Event)說簡單了就是一個Observer模式。實現起來非常ea