Netty學習筆記

何為Netty

??Netty是一個異步事件驅動的網路應用程式框架，用于快速開發可維護的高性能協議服務器和客戶端，

何為事件驅動

事件處理的兩道工序：

事件分離器的兩種模式：

何為異步I/O

??常見的I/O模式有一下幾種，Netty是多路復用模式，假設場景：用戶想從水管管道取5000L水，但是這個水管的水流是斷斷續續的，那么他有以下幾種方法：

I/O多路復用模式

Netty示例決議

以下是一個經典示例：

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.mqtt.MqttDecoder;
import io.netty.handler.codec.mqtt.MqttEncoder;
import io.netty.handler.timeout.IdleStateHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.yb.iot.mqtt.handler.ChannelPipelineHandler;
import org.yb.iot.mqtt.handler.InboundMessageHandler;

import java.util.concurrent.TimeUnit;

public class NettyServer {


    public static void main(String[] args) {
        /**
         * NioEventLoopGroup是處理I / O操作的多執行緒事件回圈，多種實作可選，
         * 使用多少個執行緒以及如何將它們映射到創建的通道取決于EventLoopGroup實作，甚至可以通過建構式進行配置，
         * 在上文中提到，I/O多路復用機制有多種，Netty中提供了多種實作,，以Group尾綴的為多執行緒實作，
         */
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        
        try {
            /**
             * 設定服務器的幫助程式類，
             */
            ServerBootstrap serverBootstrap = new ServerBootstrap();

            /**
             * bossGroup通常稱為“老板”，接受傳入的連接，
             * workerGroup通常稱為“工人”，一旦老板接受連接并將注冊的連接注冊給工人，便處理已接受連接的流量，
             */
            serverBootstrap.group(bossGroup, workerGroup)
                    /**
                     * 指定IO模型
                     */
                    .channel(NioServerSocketChannel.class)

                    /**
                     * 配置自定義的事件處理器，
                     */
                    .childHandler(new ChannelInitializer<SocketChannel>() {

                        @Autowired
                        private InboundMessageHandler inboundMessageHandler;

                        /**
                         * 初始化channel模型的背景關系
                         * @param socketChannel
                         * @throws Exception
                         */
                        @Override
                        public void initChannel(SocketChannel socketChannel) {
                            /**
                             * 事件處理器責任鏈，可以動態增刪
                             * 可以進行例如協議編碼解碼，心跳，內容長度，粘包分包處理，讀寫處理等，
                             * Netty已經默認提供了多種標準協議的解碼編碼實作，全都在io.netty.handler.codec.*下，如MQTT，HTTP等，
                             */
                            ChannelPipeline pipeline = socketChannel.pipeline();

                            /** 最大內容長度 */
                            pipeline.addLast(new HttpObjectAggregator(1024 * 1024 * 64));

                            /** 心跳時間 */
                            pipeline.addLast("idleStateHandler", new IdleStateHandler(120, 120, 120, TimeUnit.SECONDS));

                            /** 協議編碼 */
                            pipeline.addLast(MqttEncoder.INSTANCE);

                            /** 協議解碼 */
                            pipeline.addLast(new MqttDecoder(1024 * 1024 * 64));

                            /** 訊息處理 */
                            pipeline.addLast(inboundMessageHandler);
                        }
                    })

                    /**
                     * 配置EventLoopGroup模型的引數
                     */
                    .option(ChannelOption.SO_BACKLOG, 128)

                    /**
                     * 配置Channel模型的引數
                     */
                    .childOption(ChannelOption.SO_KEEPALIVE, true);

            /**
             * 系結并開始接受傳入的連接，ChannelFuture支持I/O完成事件監聽，
             */
            ChannelFuture channelFuture = serverBootstrap.bind(1883).sync();

            /**
             * 注冊等待Socket服務器關閉，
             */
            channelFuture.channel().closeFuture().sync();

        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            /**
             * 優雅的關閉并退出服務
             */
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }
}

EventLoopGroup與Channel的實作對應關系如下：

Netty重要組件：

參考檔案

Netty Wiki
Netty 實戰 中文版
Netty設計原理
并發編程網 Netty
linux下select/poll/epoll機制的比較
Linux IO模式及 select、poll、epoll詳解
Netty 系列之 Netty 執行緒模型
深入研究Netty之執行緒模型詳解
Netty學習之IO模型

著作權宣告

• 本文作者： 大魚叔叔
• 本文鏈接： https://www.huangdayu.cn/blog/42
• 著作權宣告： 本文著作權歸作者所有，禁止爬蟲，禁止轉載，禁止一切法律不允許的行為！

標籤：Java

上一篇：C++面向物件高級編程學習筆記！吃灰系列，拿去收藏吧！

下一篇：獲取Spring的ApplicationContext的幾種方式