小菜鸟

EventLoop组件分析

发表于 2021-11-01 更新于 2022-02-17 分类于 netty 阅读次数： Valine：
本文字数： 3k 阅读时长 ≈ 3 分钟

EventLoop组件分析

EventLoopGroup是一组EventLoop的抽象，含有多个EventLoop，可以注册channel，用于在事件循环中进行选择，netty为了更好地利用多核cpu资源，一般会有多个EventLoop同时工作，每个EventLoop维护一个Selector实例，EventLoopGroup提供了next方法，来从组内按照一定的规则获取EventLoop来处理任务

// bossGroup用于接收Client端连接,会将请求交给workerGroup
// NioEventLoopGroup中的子线程数默认是cpu核数*2，是一个NioEventLoop线程组，NioEventLoop实现了Executor接口和EventLoop接口，本质是一个Executor
EventLoopGroup bossGroup = new NioEventLoopGroup();
// workerGroup会获取到真正的连接，然后和连接进行通信，workerGroup用于实际业务处理的
EventLoopGroup workerGroup = new NioEventLoopGroup();

阅读全文 »

BootStrap组件分析

发表于 2021-10-29 更新于 2022-02-17 分类于 netty 阅读次数： Valine：
本文字数： 1k 阅读时长 ≈ 1 分钟

BootStrap组件分析

作用是配置整个Netty程序，串联各个组件，Netty中BootStrap类是客户端的启动引导类，ServerBootStrap是服务端的启动引导类

常用方法

// 服务端设置EventLoopGroup
public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup)
  
// 客户端设置EventLoopGroup
public B group(EventLoopGroup group)

// 指定通道的实现
// NioServerSocketChannel  异步的服务端TCP socket连接
// NioSocketChannel    异步的客户端TCP socket连接
// NioDatagramChannel  异步的UDP连接
// NioSctpChannel  异步的客户端Sctp连接
// NioSctpServerChannel  异步的服务端Sctp连接
// 会根据所传入的channelClass来创建channel对象
public B channel(Class<? extends C> channelClass)

//  专属于ServerSocketChannel   bossGroup
public B handler(ChannelHandler handler)
  
// 设置业务处理所用到的handler，自定义    workerGroup
public ServerBootstrap childHandler(ChannelHandler childHandler)
  
// 给Channel通道进行配置  bossGroup
// 传入TCP参数
public <T> B option(ChannelOption<T> option, T value)
  
// 给用来接收的Channel进行配置  workerGroup
public <T> ServerBootstrap childOption(ChannelOption<T> childOption, T value)
  
// 服务端绑定端口
public ChannelFuture bind(int inetPort)
  
// 客户端连接服务器
public ChannelFuture connect(String inetHost, int inetPort)

netty示例

发表于 2021-10-28 更新于 2024-06-19 分类于 netty 阅读次数： Valine：
本文字数： 4.5k 阅读时长 ≈ 4 分钟

netty示例

服务端

public class Server {
    public static void main(String[] args) throws InterruptedException {
          // NioEventLoopGroup是用来处理IO操作的多线程事件循环器
          // 这里使用了两个
        // 一个bossGroup用于接收Client端连接
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        // 一个workerGroup用于处理被接收的数据，一旦bossGroup接收到连接，就会把连接信息注册到worker上
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try{
            // 辅助启动类  对server进行一系列的配置
            ServerBootstrap bootstrap = new ServerBootstrap();
            // 将两个工作线程组加入进来
            bootstrap.group(bossGroup,workerGroup)
                    // 指定NioServerSocketChannel类型的通道
                    .channel(NioServerSocketChannel.class)
                          // ChannelInitializer是一个特殊的处理类，目的是帮助使用者配置一个新的Channel
                    // 使用childHandler绑定具体的事件处理器
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            // 管道中加入处理器
                            // pipeline本质是一个处理网络事件的职责链，负责管理和执行ChannelHandler
                          // pipeline是一个双向链表 包含 AbstractChannelHandlerContext head; 和AbstractChannelHandlerContext tail;
                            socketChannel.pipeline().addLast(new ServerHandler());
                        }
                    })
                    // tcp缓冲区,线程队列等待连接的个数
                          // option是提供给NioServerSocketChannel用于接收进来的连接
                    .option(ChannelOption.SO_BACKLOG,128)
                    // 保持活动连接状态
                          // childOption提供给由父管道ServerChannel接收到的连接
                    .childOption(ChannelOption.SO_KEEPALIVE,true);

            System.out.println("服务器启动");
            // 绑定端口并同步   ChannelFuture继承了Future，异步结果
            ChannelFuture future = bootstrap.bind(8765).sync();
            // 阻塞  防止关闭  只有关闭事件触发才会执行
            future.channel().closeFuture().sync();
        } catch (Exception e){
            e.printStackTrace();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }


    }
}