Netty學習_Netty框架入門教程：Netty入門之HelloWorld實現

我們可能都學過Socket通信/io/nio/aio等的編程。如果想把Socket真正的用於實際工作中去，那么還需要不斷的完善、擴展和優化。比如很經典的Tcp讀包寫包問題，或者是數據接收的大小，實際的通信讀取與應答的處理邏輯等等。當細節問題需要我們認真的去思考，而這些我們都需要大量的時間和精力，以及豐富的經驗。

 

所以想學好socket通信不是件容易的事情。那么現在，我們就需要學習一門新的技術Netty。

 

我們為什么選擇Netty？原因是它簡單。我們再也不需要去編寫復雜的代碼和邏輯去實現通信；我們再也不需要去考慮性能問題；我們再也不需要考慮編解碼問題、半包讀寫等問題。這些強大的功能Netty已經幫我們實現了，我們只需要使用它即可！

 

Netty是目前最流行的NIO框架，它的健壯性、功能、性能、可定制性和可擴展性在同類框架中都是首屈一指的。

 

Netty已經得到成百上千的商業/商用項目驗證，如Hadoop的RPC框架Avro、以及我們之后學習的JMS框架，強大的RocketMQ、還有主流的分布式通信框架Dubbox等等。

 

Netty5廢棄的原因
Netty5可能底層有一些小問題，可能版本更新太快了，然后他把Netty5起了一個分支叫Netty4.1。

 

Netty架構圖

Netty特性

設計：各種傳輸類型，阻塞和非阻塞的套接字統一的API使用靈活簡單但功能強大的線程模型無連接的DatagramSocket支持鏈邏輯，易於重用。

易於使用：提供大量的文檔例子，處理依賴JDK1.6+，沒有其他任何的依賴關系，某些功能依賴JDK1.7+，其他特定可能有相關依賴，但都是可選的！

性能：比Java APIS更好的吞吐量和更低的延遲，因為線程池和重用所以消耗較小的資源，盡量減少不必要的內存拷貝。

健壯性：健壯性連接快或慢或超載不會導致更多的內存溢出錯誤，在高速的網絡環境中不會不公平的讀或寫

安全性：完整的SSL/TLS和StartTLS支持可以在OSGI等的受限制的環境中運行。

社區：版本發布頻繁，社區活躍。

 

對應Netty的介紹就到這里，下面使用Netty框架實現一個HelloWorld。

 

第一步：下載Netty的jar包

這里使用的是Netty4.1版本。官網下載地址：https://netty.io/downloads.html

 

第二步：新建java工程

1、新建一個java工程，按照下圖新建4個類

2、新建一個lib目錄並把Netty的jar包拷貝到該目錄

3、把jar包添加到環境變量

 

第三步：編寫ServerHandler類代碼，代碼如下

package netty.helloworld;

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

public class ServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("server channel active... ");
    }
    
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            ByteBuf buf = (ByteBuf) msg;
            byte[] req = new byte[buf.readableBytes()];
            buf.readBytes(req);
            String body = new String(req, "utf-8");
            System.out.println("Server :" + body );
            String response = "進行返回給客戶端的響應：" + body;
            ctx.writeAndFlush(Unpooled.copiedBuffer(response.getBytes()));
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        System.out.println("讀完了");
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable t) throws Exception {
        ctx.close();
    }
}

 

第四步：編寫Server類代碼，代碼如下

package netty.helloworld;

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 Server {
    public static void main(String[] args) throws Exception {
        // 1 創建線兩個程組 
        // 一個是用於處理服務器端接收客戶端連接的
        // 一個是進行網絡通信的（網絡讀寫的）
        EventLoopGroup pGroup = new NioEventLoopGroup();
        EventLoopGroup cGroup = new NioEventLoopGroup();
        
        // 2 創建輔助工具類，用於服務器通道的一系列配置
        ServerBootstrap b = new ServerBootstrap();
        b.group(pGroup, cGroup)        // 綁定倆個線程組
        .channel(NioServerSocketChannel.class)        // 指定NIO的模式
        .option(ChannelOption.SO_BACKLOG, 1024)        // 設置tcp緩沖區
        .option(ChannelOption.SO_SNDBUF, 32*1024)    // 設置發送緩沖大小
        .option(ChannelOption.SO_RCVBUF, 32*1024)    // 這是接收緩沖大小
        .option(ChannelOption.SO_KEEPALIVE, true)    // 保持連接
        .childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            protected void initChannel(SocketChannel sc) throws Exception {
                // 3 在這里配置具體數據接收方法的處理
                sc.pipeline().addLast(new ServerHandler());
            }
        });
        
        // 4 進行綁定 
        ChannelFuture cf1 = b.bind(8888).sync();
        // 5 等待關閉
        cf1.channel().closeFuture().sync();
        pGroup.shutdownGracefully();
        cGroup.shutdownGracefully();
    }
}

 

第五步：編寫ClientHandler類代碼，代碼如下

package netty.helloworld;

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

public class ClientHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {}

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        try {
            ByteBuf buf = (ByteBuf) msg;
            
            byte[] req = new byte[buf.readableBytes()];
            buf.readBytes(req);
            
            String body = new String(req, "utf-8");
            System.out.println("Client :" + body );
        } finally {
            ReferenceCountUtil.release(msg);
        }
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {}

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        ctx.close();
    }
}

 

第六步：編寫Client類代碼，代碼如下

package netty.helloworld;

import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
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;

public class Client {
    public static void main(String[] args) throws Exception{
        EventLoopGroup group = new NioEventLoopGroup();
        Bootstrap b = new Bootstrap();
        b.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {
            @Override
            protected void initChannel(SocketChannel sc) throws Exception {
                sc.pipeline().addLast(new ClientHandler());
            }
        });
        
        ChannelFuture cf1 = b.connect("127.0.0.1", 8888).syncUninterruptibly();
        // 發送消息
        byte[] msg = "發送第1條測試消息".getBytes();
        cf1.channel().writeAndFlush(Unpooled.copiedBuffer(msg));
        
        // 等待關閉
        cf1.channel().closeFuture().sync();
        group.shutdownGracefully();
    }
}

 

第七步：啟動Server服務

 

 

最后一步：啟動客戶端

 

 

控制台輸出

 

關於Netty框架學習的第一節課就講到這里，其他更多關於Netty方面的教程后續會陸續更新！！

end -- 1346ac475e98aed

需要索取完整源碼或者其他任何有關技術問題和疑問，直接wxhaox