Netty入門（一）環境搭建及使用

一、項目創建

　　在 Eclipse 中右鍵，新建->項目->Maven->Maven Project->下一步->選擇 quickstart

　　

　　下一步->設置如圖（參數自取）

　　

　　點擊完成。

 　　項目會自動創建 pom.xml 文件，打開該文件，點擊 Dependencies標簽->Add..，設置如圖（參數由 Netty 版本決定）：

　　

　　點擊 OK，保存文件，觀察 Maven Dependencies 下，

　　

　　netty 的 jar 包已經添加完畢。到此為止，項目配置完畢了，下面就來添加代碼吧。

 

二、實現一個簡單的服務端 demo

1. 首選我們需要自定義一個類處理服務器接收到的消息

package com.coder.server;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;
import io.netty.util.ReferenceCountUtil;

/**
 * 輸出接收到的消息
 * @author Coder
 *
 */
public class HelloServerHandler extends ChannelInboundHandlerAdapter {
    /**
     * 收到數據時調用
     */
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        try {
            ByteBuf in = (ByteBuf)msg;
            System.out.print(in.toString(CharsetUtil.UTF_8));
        } finally {
            // 拋棄收到的數據
            ReferenceCountUtil.release(msg);
        }
        
//        ctx.write(msg);
//        ctx.flush();
    }
    
    /**
     * 當Netty由於IO錯誤或者處理器在處理事件時拋出異常時調用
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        // 當出現異常就關閉連接
        cause.printStackTrace();
        ctx.close();
    }
}

　　該類主要是實現了接收客戶端發來的消息，並輸出到控制台。

 

2. 然后我們就能實現一個簡單的服務端程序了

　　Netty 服務器的通信步驟為：

1.  創建兩個NIO線程組，一個專門用於接收來自客戶端的連接，另一個則用於處理已經被接收的連接。
2.  創建一個ServerBootstrap對象，配置Netty的一系列參數，例如接受傳出數據的緩存大小等。
3.  創建一個用於實際處理數據的類ChannelInitializer，進行初始化的准備工作，比如設置接受傳出數據的字符集、格式以及實際處理數據的接口。
4.  綁定端口，執行同步阻塞方法等待服務器端啟動即可。

package com.coder.server;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class HelloServer {
    private int port;
    
    public HelloServer(int port) {
        this.port = port;
    }
    
    public void run() throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup();        // 用來接收進來的連接
        EventLoopGroup workerGroup = new NioEventLoopGroup();    // 用來處理已經被接收的連接
        System.out.println("准備運行端口：" + port);
        
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
            .channel(NioServerSocketChannel.class)            // 這里告訴Channel如何接收新的連接
            .childHandler( new ChannelInitializer<SocketChannel>() {
                @Override
                protected void initChannel(SocketChannel ch) throws Exception {
                    // 自定義處理類
                    ch.pipeline().addLast(new HelloServerHandler());
                }
            })
            .option(ChannelOption.SO_BACKLOG, 128)
            .childOption(ChannelOption.SO_KEEPALIVE, true);
            
            // 綁定端口，開始接收進來的連接
            ChannelFuture f = b.bind(port).sync();
            
            // 等待服務器socket關閉
            f.channel().closeFuture().sync();
        } catch (Exception e) {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }
    
    public static void main(String[] args) throws Exception {
        int port = 10110;
        new HelloServer(port).run();
    }

}

 　　那么，這便是一個可執行的服務端程序了。運行后控制台輸出如下：

　　

 

三、測試 

 　　我們可以去自定義客戶端程序，這里為了方便使用 telnet 充當客戶端。

　　需要注意的是，Windows 默認是沒有開啟 telnet 客戶端的，需要我們手動開啟。

　　菜單->控制面板->程序->打開或關閉Windows功能，設置如圖：

　　

　　這樣我們就能用 telnet 客戶端了。

　　在 cmd 窗口輸入命令如下：

　　

　　打開窗口如下：

　　

　　這時候我們在該窗口輸入什么，eclipse 控制台也會對應輸出相應內容。如下：

　　

　　注意：telnet 窗口會看不到輸入的字符，只要輸入 ctrl+L 就可以看到輸入的字符了。