Netty：高性能非同步事件驅動的網路應用框架

Netty 簡介

Netty 是由 JBoss 開源的一個 Java 網路應用框架，專為快速開發高性能、高可靠性的網路伺服器與客戶端程式而設計。它採用非同步、事件驅動的架構模型，能夠輕鬆處理成千上萬的並發連線，是構建高吞吐量、低延遲網路應用的首選工具。

核心特性

• 非同步非阻塞 I/O：基於 Java NIO，單一執行緒即可處理大量連線，避免傳統阻塞 I/O 的執行緒開銷。
• 事件驅動模型：透過 Channel、EventLoop、ChannelHandler 等核心元件，將網路事件（連線建立、資料讀寫、異常發生等）轉化為可處理的事件流。
• 零拷貝：利用 Direct Buffer 與 FileRegion 實現資料在核心態與使用者態間的高效傳輸，減少記憶體拷貝次數。
• 內建協議支援：提供 HTTP、WebSocket、Protobuf、Thrift 等常用協議的編解碼器，開箱即用。
• 擴充性強：透過 ChannelPipeline 動態組裝處理器，靈活實現自訂協議與業務邏輯。

典型應用場景

• 高併發的即時通訊系統（IM、聊天室）
• 遊戲伺服器、即時行情推送
• 微服務間的 RPC 通訊（如 Dubbo、gRPC 底層常用 Netty）
• 物聯網裝置接入、MQTT 代理伺服器

快速上手範例

// 啟動一個簡單的 Echo Server
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
     .channel(NioServerSocketChannel.class)
     .childHandler(new ChannelInitializer<SocketChannel>() {
         @Override
         protected void initChannel(SocketChannel ch) {
             ch.pipeline().addLast(new EchoServerHandler());
         }
     });
    ChannelFuture f = b.bind(8080).sync();
    f.channel().closeFuture().sync();
} finally {
    bossGroup.shutdownGracefully();
    workerGroup.shutdownGracefully();
}

專案資源

原始碼範例：https://github.com/windwant/netty-test