1. 程式人生 > 實用技巧 >Netty入門教程——認識Netty

Netty入門教程——認識Netty

什麼是Netty?
Netty 是一個利用 Java 的高階網路的能力,隱藏其背後的複雜性而提供一個易於使用的 API 的客戶端/伺服器框架。
Netty 是一個廣泛使用的 Java 網路程式設計框架(Netty 在 2011 年獲得了Duke's Choice Award,見https://www.java.net/dukeschoice/2011)。它活躍和成長於使用者社群,像大型公司 Facebook 和 Instagram 以及流行 開源專案如 Infinispan, HornetQ, Vert.x, Apache Cassandra 和 Elasticsearch 等,都利用其強大的對於網路抽象的核心程式碼。

以上是摘自《Essential Netty In Action》這本書,本文的內容也是本人讀了這本書之後的一些整理心得,如有不當之處歡迎大蝦們指正

Netty和Tomcat有什麼區別?
Netty和Tomcat最大的區別就在於通訊協議,Tomcat是基於Http協議的,他的實質是一個基於http協議的web容器,但是Netty不一樣,他能通過程式設計自定義各種協議,因為netty能夠通過codec自己來編碼/解碼位元組流,完成類似redis訪問的功能,這就是netty和tomcat最大的不同。

有人說netty的效能就一定比tomcat效能高,其實不然,tomcat從6.x開始就支援了nio模式,並且後續還有APR模式——一種通過jni呼叫apache網路庫的模式,相比於舊的bio模式,併發效能得到了很大提高,特別是APR模式,而netty是否比tomcat效能更高,則要取決於netty程式作者的技術實力了。

為什麼Netty受歡迎?
如第一部分所述,netty是一款收到大公司青睞的框架,在我看來,netty能夠受到青睞的原因有三:

併發高
傳輸快
封裝好
Netty為什麼併發高
Netty是一款基於NIO(Nonblocking I/O,非阻塞IO)開發的網路通訊框架,對比於BIO(Blocking I/O,阻塞IO),他的併發效能得到了很大提高,兩張圖讓你瞭解BIO和NIO的區別:
阻塞IO的通訊方式

非阻塞IO的通訊方式

從這兩圖可以看出,NIO的單執行緒能處理連線的數量比BIO要高出很多,而為什麼單執行緒能處理更多的連線呢?原因就是圖二中出現的Selector。
當一個連線建立之後,他有兩個步驟要做,第一步是接收完客戶端發過來的全部資料,第二步是服務端處理完請求業務之後返回response給客戶端。NIO和BIO的區別主要是在第一步。
在BIO中,等待客戶端發資料這個過程是阻塞的,這樣就造成了一個執行緒只能處理一個請求的情況,而機器能支援的最大執行緒數是有限的,這就是為什麼BIO不能支援高併發的原因。
而NIO中,當一個Socket建立好之後,Thread並不會阻塞去接受這個Socket,而是將這個請求交給Selector,Selector會不斷的去遍歷所有的Socket,一旦有一個Socket建立完成,他會通知Thread,然後Thread處理完資料再返回給客戶端——這個過程是不阻塞的,這樣就能讓一個Thread處理更多的請求了。
下面兩張圖是基於BIO的處理流程和netty的處理流程,輔助你理解兩種方式的差別:
BIO的處理流程

NIO的處理流程
除了BIO和NIO之外,還有一些其他的IO模型,下面這張圖就表示了五種IO模型的處理流程:

五種常見的IO模型
BIO,同步阻塞IO,阻塞整個步驟,如果連線少,他的延遲是最低的,因為一個執行緒只處理一個連線,適用於少連線且延遲低的場景,比如說資料庫連線。
NIO,同步非阻塞IO,阻塞業務處理但不阻塞資料接收,適用於高併發且處理簡單的場景,比如聊天軟體。
多路複用IO,他的兩個步驟處理是分開的,也就是說,一個連線可能他的資料接收是執行緒a完成的,資料處理是執行緒b完成的,他比BIO能處理更多請求。
訊號驅動IO,這種IO模型主要用在嵌入式開發,不參與討論。
非同步IO,他的資料請求和資料處理都是非同步的,資料請求一次返回一次,適用於長連線的業務場景。
以上摘自Linux IO模式及 select、poll、epoll詳解

Netty為什麼傳輸快
Netty的傳輸快其實也是依賴了NIO的一個特性——零拷貝。我們知道,Java的記憶體有堆記憶體、棧記憶體和字串常量池等等,其中堆記憶體是佔用記憶體空間最大的一塊,也是Java物件存放的地方,一般我們的資料如果需要從IO讀取到堆記憶體,中間需要經過Socket緩衝區,也就是說一個數據會被拷貝兩次才能到達他的的終點,如果資料量大,就會造成不必要的資源浪費。
Netty針對這種情況,使用了NIO中的另一大特性——零拷貝,當他需要接收資料的時候,他會在堆記憶體之外開闢一塊記憶體,資料就直接從IO讀到了那塊記憶體中去,在netty裡面通過ByteBuf可以直接對這些資料進行直接操作,從而加快了傳輸速度。
下兩圖就介紹了兩種拷貝方式的區別,摘自Linux 中的零拷貝技術,第 1 部分
傳統資料拷貝
零拷貝
上文介紹的ByteBuf是Netty的一個重要概念,他是netty資料處理的容器,也是Netty封裝好的一個重要體現,將在下一部分做詳細介紹。

為什麼說Netty封裝好?
要說Netty為什麼封裝好,這種用文字是說不清的,直接上程式碼:

阻塞I/O
public class PlainOioServer {

public void serve(int port) throws IOException {
    final ServerSocket socket = new ServerSocket(port);     //1
    try {
        for (;;) {
            final Socket clientSocket = socket.accept();    //2
            System.out.println("Accepted connection from " + clientSocket);

            new Thread(new Runnable() {                        //3
                @Override
                public void run() {
                    OutputStream out;
                    try {
                        out = clientSocket.getOutputStream();
                        out.write("Hi!\r\n".getBytes(Charset.forName("UTF-8")));                            //4
                        out.flush();
                        clientSocket.close();                //5

                    } catch (IOException e) {
                        e.printStackTrace();
                        try {
                            clientSocket.close();
                        } catch (IOException ex) {
                            // ignore on close
                        }
                    }
                }
            }).start();                                        //6
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}

}
非阻塞IO
public class PlainNioServer {
public void serve(int port) throws IOException {
ServerSocketChannel serverChannel = ServerSocketChannel.open();
serverChannel.configureBlocking(false);
ServerSocket ss = serverChannel.socket();
InetSocketAddress address = new InetSocketAddress(port);
ss.bind(address); //1
Selector selector = Selector.open(); //2
serverChannel.register(selector, SelectionKey.OP_ACCEPT); //3
final ByteBuffer msg = ByteBuffer.wrap("Hi!\r\n".getBytes());
for (;