3.2、實現業務邏輯

  Netty使用上一章介紹的Future、回撥等技術，再加上其他設計，用來響應不同型別的事件。這些後面再討論，目前我們的焦點是收到資料後下一步怎麼做。想要處理收到的資料，必須編寫一個類繼承ChannelInboundHandlerAdapter類，並且重寫messageReceived方法。這個方法會在每次收到資料後呼叫，這個例子裡我們收到的是位元組陣列。EchoServer這裡要做的就是在這個方法裡將收到的內容重新發送給客戶端，請看下面的程式碼。

package com.nan.netty.one;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

import java.nio.charset.Charset;

//Sharable註解可以讓此Handler在不同Channel之間共享
@ChannelHandler.Sharable
public class EchoServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        //Netty的ByteBuf轉成字串
        ByteBuf byteBuf = (ByteBuf) msg;
        System.out.println("Server received: " + byteBuf.getCharSequence(0, byteBuf.readableBytes(), Charset.forName("UTF-8")));
        //收到資料並將資料傳送到客戶端，但是此時資料還沒有刷到對等連線點
        ctx.write(msg);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        //讀操作完成後，將所有寫入的資料(等待中的)重新整理到對等連線點，然後關閉此Channel
        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        //出現異常關閉此Channel
        ctx.close();
    }
}
 

  現在我們先使用第一章寫的BIO的EchoClient連線上面的服務端，可以發現EchoServer的功能已經實現了。

  Netty使用的Handler有更大的解耦性，所以非常容易進行增加，修改或刪除業務邏輯的專案演進。Handler的作用是很明確的，裡面的每個方法都可以重寫以參與到收發的資料的生命週期，但是一般情況下只有channelRead方法是需要重寫的。

3.3、攔截異常

  除了重寫了channelRead方法之外，有一個exceptionCaught方法也被重寫了。這個方法是用來處理異常的，或者其他Throwable的子類。上面的例子中，記錄了異常並關閉掉到客戶端的連線，因為出現異常這個連結的狀態可能是不確定的。一般情況下可能你也會這麼幹，不過有一些場景，需要從錯誤中恢復過來，這就需要發揮你的指揮找到一個聰明的方法去實現。重要的就是你要有一個ChannelHandler實現exceptionCaught方法來處理各種各樣的錯誤。

  Netty提供的這個攔截異常的方法更容易處理不同執行緒發生的錯誤。通過統一的簡單、集中API將不同執行緒發生的錯誤儘可能放在一起處理。

  如果你需要用Netty寫一個實際生產的應用或者一個框架就要知道很多其他ChannelHandler的子類和實現，這些後面會討論。現在只需要記住ChannelHandler的實現會在發生不同的事件呼叫，你可以繼承或實現它們來參與事件的生命週期。

四、編寫EchoClient

• 連線服務端
• 傳送資料到服務端
• 等待服務端返回相同的資料
• 關閉連線

4.1、客戶端啟動器

  客戶端的啟動器和服務端的啟動器很類似。有一點區別，伺服器啟動器一般只需要埠號，而客戶端需要服務端的IP地址和埠，因為它要去連線這個IP和埠。

package com.nan.netty.one;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;

import java.net.InetSocketAddress;

public class EchoClient {
    private final String host;
    private final int port;

    public EchoClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void start() throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            //建立客戶端啟動器例項
            Bootstrap b = new Bootstrap();
            //使用NioEventLoopGroup接收事件，和服務端一樣，這裡使用NIO傳輸
            b.group(group)
                    .channel(NioSocketChannel.class)
                    .remoteAddress(new InetSocketAddress(host, port))
                    //指定ChannelHandler，一旦連線簡歷就會建立Channel
                    .handler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) throws Exception {
                            //指定EchoClientHandler處理業務邏輯
                            ch.pipeline().addLast(new EchoClientHandler());
                        }
                    });
            //同步連線服務端
            ChannelFuture f = b.connect().sync();
            //阻塞程式碼只到客戶端關閉
            f.channel().closeFuture().sync();
        } finally {
            //關閉啟動器並釋放資源
            group.shutdownGracefully().sync();
        }
    }

    public static void main(String[] args) throws Exception {
        new EchoClient("localhost", 9999).start();
    }
}

  我們列一下客戶端的重點：

• 建立一個啟動器例項啟動客戶端
• 使用NioEventLoopGroup處理事件，包括新連線、讀寫資料等
  
• InetSocketAddress裡面的地址和埠就是要連線的服務端的地址和埠
  
• 還註冊了一個Handler作為連線成功後的回撥，目前還沒寫這個Handler，所以程式碼會在IDE裡報錯
• 上面的步驟完成之後，呼叫ServerBootstrap.connect()方法去連線服務端
  

4.2、客戶端業務邏輯

  這裡實現的客戶端邏輯儘量簡單，裡面用到的一些類的細節會在後面的章節詳解。

  客戶端的Handler首先繼承了SimpleChannelInboundHandler，然後重寫了下面三個方法，這三個方法對我們現在而言都是有用的。

• channelActive()- 連線服務端成功後回撥
  
• channelRead0()- 從服務端收到資料後回撥
  
• exceptionCaught()- 出現異常時回撥
  

package com.nan.netty.one;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.util.CharsetUtil;

//不同Channel之間共享此Handler
@ChannelHandler.Sharable
public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        //連線成功後向服務端傳送資料
        ctx.writeAndFlush(Unpooled.copiedBuffer("Hello server 110", CharsetUtil.UTF_8));
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
        //列印從服務端收到的資料，然後關閉連線
        System.out.println("Received from server: " + msg.getCharSequence(0, msg.readableBytes(), CharsetUtil.UTF_8));
        ctx.close();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        //列印遇到的異常，然後關閉連線
        cause.printStackTrace();
        ctx.close();
    }
}

五、總結

這一章我們使用Netty實現了一個簡單的服務端和客戶端，對於啟動，配置，讀寫資料以及捕獲異常都有介紹，現在對於Netty算是有一些基本的瞭解，這些知識對於後面的學習是個很好的基礎。