Netty 4.1 源代码学习：线程模型

monw3c 发布于2019-08-14 17:17 / 2025人阅读

摘要：前言本文以自带的示例工程为例，简要介绍线程模型示例工程的代码位于很简单，仅包含一个方法用于初始化以及，我们来看看其中和线程模型相关的一些代码在的初始化代码中实例化了两个对象和，它们有着公共基类，这个是线程模型的核心类名让人联想到组合模式，

前言

本文以 netty 4.1 自带的示例工程 netty-example 为例，简要介绍 netty 线程模型

EchoServer

echo server 示例工程的代码位于 example/src/main/java/io.netty.example/echo

EchoClient

EchoClientHandler

EchoServer

EchoServerHandler

EchoServer 很简单，仅包含一个 main 方法用于初始化 netty server 以及 handler，我们来看看其中和线程模型相关的一些代码

// EchoServer.java

public static void main(String[] args) throws Exception {
    ...
    // Configure the server
    EventLoopGroup bossGroup = new NioEventLoopGroup(1);
    EventLoopGroup workerGroup = new NioEventLoopGroup();
    try {
        ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup, workerGroup)
          .channel(NioServerSocketChannel.class)
          ...
    } finally {
        ...
    }
}

EventLoop & EventLoopGroup

在 EchoServer 的初始化代码中实例化了两个对象 bossGroup 和 workerGroup，它们有着公共基类 EventLoopGroup，这个 EventLoopGroup 是 netty 线程模型的核心

EventLoopGroup 类名让人联想到 "组合模式"，所以肯定有个 EventLoop 类，EventLoopGroup 包含一个或多个 EventLoop

变量名 bossGroup 和 workerGroup 让人联想到 "生产者消费者" 模型，即由 bossGroup 产生消息（事件），然后交给 workerGroup 消费。此外我们注意到 bossGroup 和 workerGroup 使用了不同的构造方法，bossGroup 指定了线程个数 1，workerGroup 则没有，为了发挥硬件性能，一般会根据服务器 CPU 核心个数来设定 "工作者" 线程个数，我们跟踪空构造函数，最终会在父类 MultithreadEventExecutorGroup 中找到当未指定线程个数时（nThreads）netty 会根据系统属性 io.netty.eventLoopThreads 和 CPU 核心数来确定合适的值

// MultithreadEventLoopGroup.java

public abstract class MultithreadEventLoopGroup extends   
    MultithreadEventExecutorGroup implements EventLoopGroup {


    private static final int DEFAULT_EVENT_LOOP_THREADS;

    static {
        DEFAULT_EVENT_LOOP_THREADS = Math.max(1, SystemPropertyUtil.getInt(
                "io.netty.eventLoopThreads", Runtime.getRuntime().availableProcessors() * 2));

        if (logger.isDebugEnabled()) {
            logger.debug("-Dio.netty.eventLoopThreads: {}", DEFAULT_EVENT_LOOP_THREADS);
        }
    }

    protected MultithreadEventLoopGroup(int nThreads, Executor executor, Object... args) {
        super(nThreads == 0 ? DEFAULT_EVENT_LOOP_THREADS : nThreads, executor, args);
    }
    ...
}

Channel & EventLoop

上文提到 netty 通常使用两个 EventLoopGroup，一个用于生产一个用于消费，那么这两个 EventLoopGroup 是怎么相互通信（耦合）的呢？

总结

netty 使用 EventLoopGroup 类封装线程池

netty 通常使用两个EventLoopGroup，boss group 和 worker group

boss group 用于网络 IO，包括接收客户端连接，读写 socket 等，boss group 通常使用基于 NIO 的事件循环

worker group 用于处理 boss group 读取的数据，或者说通常包含应用自身的业务逻辑

云服务器 GPU云服务器 netty 多线程线程安全模型 webrtc线程模型 webrtc 线程模型

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/66535.html

Netty 框架总结「ChannelHandler 及 EventLoop」

摘要：随着状态发生变化，相应的产生。这些被转发到中的来采取相应的操作。当收到数据或相关的状态改变时，这些方法被调用，这些方法和的生命周期密切相关。主要由一系列组成的。采用的线程模型，在同一个线程的中处理所有发生的事。「博客搬家」原地址: 简书原发表时间: 2017-05-05 学习了一段时间的 Netty，将重点与学习心得总结如下，本文主要总结ChannelHandler 及 E...

VioletJack 2019-08-15 13:41 评论0 收藏0
彻底理解Netty，这一篇文章就够了

摘要：如果什么事都没得做，它也不会死循环，它会将线程休眠起来，直到下一个事件来了再继续干活，这样的一个线程称之为线程。而请求处理逻辑既可以使用单独的线程池进行处理，也可以跟放在读写线程一块处理。 Netty到底是什么从HTTP说起有了Netty，你可以实现自己的HTTP服务器，FTP服务器，UDP服务器，RPC服务器，WebSocket服务器，Redis的Proxy服务器，MySQL的P...

yy13818512006 2019-08-16 13:49 评论0 收藏0
Netty3文档翻译（二）

摘要：丰富的缓存数据结构使用它自己的缓存来表示字节序列而不是的。针对有一个定义良好的事件模型。有一些协议是多层的建立在其他低级协议基础上。此外，甚至不是完全线程安全的。协议由标准化为。协议缓存整合是一个高效二进制协议的快速实现。 Chapter 2、结构概览这一节我们将确认Netty提供的核心功能是什么，以及它们怎么构成一个完整的网络应用开发堆栈。 1、丰富的缓存数据结构 Netty使用它...

Zhuxy 2019-08-16 16:53 评论0 收藏0
【Netty】学习NioEventLoop

摘要：主从模型主从多线程多个的线程池用于接受客户端的连接。负责多路分离已连接的，读写网络数据，将业务处理功能扔给线程池完成。比如在线程内部进行串行操作，避免多线程竞争造成的性能问题。欢迎关注公众号：【爱编程】如果有需要后台回复2019赠送1T的学习资料哦！！ showImg(https://upload-images.jianshu.io/upload_images/13150128-3c...

tulayang 2019-08-16 17:55 评论0 收藏0
少啰嗦！一分钟带你读懂Java的NIO和经典IO的区别

摘要：的选择器允许单个线程监视多个输入通道。一旦执行的线程已经超过读取代码中的某个数据片段，该线程就不会在数据中向后移动通常不会。 1、引言很多初涉网络编程的程序员，在研究Java NIO（即异步IO）和经典IO（也就是常说的阻塞式IO）的API时，很快就会发现一个问题：我什么时候应该使用经典IO，什么时候应该使用NIO？在本文中，将尝试用简明扼要的文字，阐明Java NIO和经典IO之...

Meils 2019-08-16 18:23 评论0 收藏0