在netty中使用native傳輸協議的方法

Posted on by

簡介

對於IO來說，除瞭傳統的block IO,使用最多的就是NIO瞭，通常我們在netty程序中最常用到的就是NIO,比如NioEventLoopGroup,NioServerSocketChannel等。

我們也知道在IO中有比NIO更快的IO方式，比如kqueue和epoll，但是這兩種方式需要native方法的支持，也就是說需要在操作系統層面提供服務。

如果我們在支持Kqueue或者epoll的服務器上，netty是否可以提供對這些優秀IO的支持呢？

答案是肯定的。但是首先kqueue和epoll需要JNI支持，也就是說JAVA程序需要調用本地的native方法。

native傳輸協議的依賴

要想使用kequeue和epoll這種native的傳輸方式，我們需要額外添加項目的依賴,如果是linux環境，則可以添加如下的maven依賴環境：

  <dependencies>
    <dependency>
      <groupId>io.netty</groupId>
      <artifactId>netty-transport-native-epoll</artifactId>
      <version>${project.version}</version>
      <classifier>linux-x86_64</classifier>
    </dependency>
    ...
  </dependencies>

其中version需要匹配你所使用的netty版本號，否則可能出現調用異常的情況。

classifier表示的是系統架構，它的值可以是linux-x86_64，也可以是linux-aarch_64.

如果你使用的mac系統，那麼可以這樣引入：

  <dependencies>
    <dependency>
      <groupId>io.netty</groupId>
      <artifactId>netty-transport-native-kqueue</artifactId>
      <version>${project.version}</version>
      <classifier>osx-x86_64</classifier>
    </dependency>
    ...
  </dependencies>

netty除瞭單獨的個體包之外，還有一個all in one的netty-all包，如果你使用瞭這個all in one的包，那麼不需要額外添加native的依賴。

如果netty提供的系統架構並沒有你正在使用的，那麼你需要手動進行編譯，以下是編譯所依賴的程序包, 如果是在RHEL/CentOS/Fedora系統中，則使用：

sudo yum install autoconf automake libtool make tar \
                 glibc-devel \
                 libgcc.i686 glibc-devel.i686

如果是在Debian/Ubuntu系統中，則使用：

sudo apt-get install autoconf automake libtool make tar \
                     gcc

如果是在MacOS/BSD系統中，則使用：

brew install autoconf automake libtool

netty本地傳輸協議的使用

安裝好依賴包之後，我們就可以在netty中使用這些native傳輸協議瞭。

native傳輸協議的使用和NIO的使用基本一致，我們隻需要進行下面的替換即可。

如果是在liunx系統中，則進行下面的替換：

    NioEventLoopGroup → EpollEventLoopGroup
    NioEventLoop → EpollEventLoop
    NioServerSocketChannel → EpollServerSocketChannel
    NioSocketChannel → EpollSocketChannel

如果是在mac系統中，則進行下面的替換：

    NioEventLoopGroup → KQueueEventLoopGroup
    NioEventLoop → KQueueEventLoop
    NioServerSocketChannel → KQueueServerSocketChannel
    NioSocketChannel → KQueueSocketChannel

這裡還是使用我們熟悉的聊天服務為例，首先看下基於Kqueue的netty服務器端應該怎麼寫：

EventLoopGroup bossGroup = new KQueueEventLoopGroup(1);
        EventLoopGroup workerGroup = new KQueueEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(KQueueServerSocketChannel.class)
             .handler(new LoggingHandler(LogLevel.INFO))
             .childHandler(new NativeChatServerInitializer());

            Channel channel = b.bind(PORT).sync().channel();
            log.info("server channel:{}", channel);
            channel.closeFuture().sync();

和NIO一樣，在服務器端我們需要使用KQueueEventLoopGroup創建兩個EventLoopGroup，一個是bossGroup, 一個是workerGroup。

然後將這兩個group傳入到ServerBootstrap中，並且添加KQueueServerSocketChannel作為channel。

其他的內容和NIO server的內容是一樣的。

接下來我們看下基於Kqueue的netty客戶端改如何跟server端建立連接：

EventLoopGroup group = new KQueueEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group)
             .channel(KQueueSocketChannel.class)
             .handler(new NativeChatClientInitializer());

            // 建立連接
            Channel ch = b.connect(HOST, PORT).sync().channel();
            log.info("client channel: {}", ch);

這裡使用的是KQueueEventLoopGroup，並將KQueueEventLoopGroup放到Bootstrap中，並且為Bootstrap提供瞭和server端一致的KQueueSocketChannel。

然後就是客戶端向channel中寫消息，這裡我們直接從命令行輸入：

// 從命令行輸入
            ChannelFuture lastWriteFuture = null;
            BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
            for (;;) {
                String line = in.readLine();
                if (line == null) {
                    break;
                }
                // 將從命令行輸入的一行字符寫到channel中
                lastWriteFuture = ch.writeAndFlush(line + "\r\n");
                // 如果輸入'再見'，則等待server端關閉channel
                if ("再見".equalsIgnoreCase(line)) {
                    ch.closeFuture().sync();
                    break;
                }
            }

上面代碼的意思是將命令行收到的消息寫入到channel中，如果輸入的是’再見’，則關閉channel。

為瞭能夠處理字符串，這裡用到瞭三個編碼解碼器：

        // 添加行分割器
        pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
        // 添加String Decoder和String Encoder,用來進行字符串的轉換
        pipeline.addLast(new StringEncoder());
        pipeline.addLast(new StringDecoder());

分別是行分割器，字符編碼器和字符解碼器。

運行一下看，程序運行沒問題，客戶端和服務器端可以進行通訊。

總結

這裡我們隻以Kqueue為例介紹瞭netty中native傳輸協議的使用，具體的代碼，大傢可以參考：

learn-netty4

到此這篇關於在netty中使用native傳輸協議的文章就介紹到這瞭,更多相關native傳輸協議內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：