openeuler/netty

Netty | openEuler 镜像文档

镜像概述和主要用途

本镜像为官方Netty Docker镜像，基于openEuler构建，由openEuler CloudNative SIG维护。Netty是一个异步事件驱动的网络应用框架，旨在快速开发可维护的高性能协议服务器和客户端。该仓库可免费使用，且无用户速率限制。

获取帮助：openEuler CloudNative SIG、openEuler社区

核心功能和特性

• 异步事件驱动：采用非阻塞I/O模型，高效处理并发连接
• 高性能：优化的网络传输机制，适合高吞吐量场景
• 可维护性：模块化设计，便于扩展和定制协议处理逻辑
• 跨架构支持：支持amd64和arm64架构
• 开源免费：基于openEuler，无使用限制和速率限制

支持的标签及对应Dockerfile链接

每个netty镜像标签由Netty版本和基础镜像版本组成，具体如下：

使用场景和适用范围

• 开发高性能网络服务器（如HTTP、WebSocket、MQTT服务器）
• 构建高并发网络客户端应用
• 实现自定义网络协议处理
• 需要处理大量并发连接的分布式系统组件

使用方法和配置说明

1. 拉取镜像

根据需求选择对应的{Tag}，拉取镜像：

bash
docker pull openeuler/netty:{Tag}

2. 添加Netty依赖

Maven:

xml
<dependency>
  <groupId>io.netty</groupId>
  <artifactId>netty-all</artifactId>
  <version>${NETTY_VERSION}</version>
</dependency>

Gradle:

groovy
implementation 'io.netty:netty-all:${NETTY_VERSION}'

3. 编写简单服务器示例

EchoServer.java:

java
public class EchoServer {
    private final int port;
      
    public EchoServer(int port) {
        this.port = port;
    }
      
    public void start() throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
      
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) {
                     ch.pipeline().addLast(new EchoServerHandler());
                 }
             });
      
            ChannelFuture f = b.bind(port).sync();
            f.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
      
    public static void main(String[] args) throws Exception {
        new EchoServer(8080).start(); 
    }
}

EchoServerHandler.java:

java
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        ctx.write(msg);
    }
      
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.flush();
    }
      
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

4. 运行服务器

直接运行EchoServer类的main方法启动服务器。通过以下命令测试：

bash
telnet localhost 8080

输入任意内容，服务器将返回相同的内容（回声功能）。

问题反馈

如有任何问题或需使用特定功能，请在openeuler-docker-images提交issue或pull request。