Netty入門官方例子

參考鏈接：https://blog.csdn.net/wocjy/article/details/78661464

 

maven依賴：

<!-- Netty開始 -->
<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
<dependency>
   <groupId>io.netty</groupId>
   <artifactId>netty-all</artifactId>
   <version>4.1.6.Final</version>
</dependency>
<!-- Netty結束 -->

官方並沒有使用Hello World來作為一個例子，而是采用RFC的DISCARD，這個協議定義了就是接收到請求后什么也不干。

第一步編寫DiscardServerHandler類:

package io.netty.example.discard;
 
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.ReferenceCountUtil;
//ChannelInboundHandlerAdapter實現自ChannelInboundHandler
//ChannelInboundHandler提供了不同的事件處理方法你可以重寫
public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
    /* 
     * @作者:CJY
     * @說明:該方法用於接收從客戶端接收的信息
     * @時間:2017-4-2下午12:25:05
     * @see io.netty.channel.ChannelInboundHandlerAdapter#channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object)
     * @param ctx
     * @param msg
     * @throws Exception
     */
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg)
            throws Exception {
        //Discard the received data silently
        //ByteBuf是一個引用計數對象實現ReferenceCounted，他就是在有對象引用的時候計數+1，無的時候計數-1，當為0對象釋放內存
        ByteBuf in=(ByteBuf)msg;
        try {
            while(in.isReadable()){
                System.out.println((char)in.readByte());
                System.out.flush();
            }
        } finally {
            ReferenceCountUtil.release(msg);
        }
    }
    
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
            throws Exception {
        cause.printStackTrace();
        ctx.close();
    }
}

第二步編寫DiscardServer:

package io.netty.example.discard;
 
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 DiscardServer {
    private int port;
    public DiscardServer(int port){
        this.port = port;
    }
    
    public void run() throws Exception{
        //Group：群組，Loop：循環，Event：事件，這幾個東西聯在一起，相比大家也大概明白它的用途了。
        //Netty內部都是通過線程在處理各種數據，EventLoopGroup就是用來管理調度他們的，注冊Channel，管理他們的生命周期。
        //NioEventLoopGroup是一個處理I/O操作的多線程事件循環
        //bossGroup作為boss,接收傳入連接
        //因為bossGroup僅接收客戶端連接，不做復雜的邏輯處理，為了盡可能減少資源的占用，取值越小越好
        EventLoopGroup bossGroup=new NioEventLoopGroup(1);
        //workerGroup作為worker，處理boss接收的連接的流量和將接收的連接注冊進入這個worker
        EventLoopGroup workerGroup=new NioEventLoopGroup();
        try {
            //ServerBootstrap負責建立服務端
            //你可以直接使用Channel去建立服務端，但是大多數情況下你無需做這種乏味的事情
            ServerBootstrap b=new ServerBootstrap();
            b.group(bossGroup, workerGroup)
            //指定使用NioServerSocketChannel產生一個Channel用來接收連接
            .channel(NioServerSocketChannel.class)
            //ChannelInitializer用於配置一個新的Channel
            //用於向你的Channel當中添加ChannelInboundHandler的實現
            .childHandler(new ChannelInitializer<SocketChannel>() {
                public void initChannel(SocketChannel ch) throws Exception {
                    //ChannelPipeline用於存放管理ChannelHandel
                    //ChannelHandler用於處理請求響應的業務邏輯相關代碼
                    ch.pipeline().addLast(new DiscardServerHandler());
                };
            })
            //對Channel進行一些配置
            //注意以下是socket的標准參數
            //BACKLOG用於構造服務端套接字ServerSocket對象，標識當服務器請求處理線程全滿時，用於臨時存放已完成三次握手的請求的隊列的最大長度。如果未設置或所設置的值小於1，Java將使用默認值50。
            //Option是為了NioServerSocketChannel設置的，用來接收傳入連接的
            .option(ChannelOption.SO_BACKLOG, 128)
            //是否啟用心跳保活機制。在雙方TCP套接字建立連接后（即都進入ESTABLISHED狀態）並且在兩個小時左右上層沒有任何數據傳輸的情況下，這套機制才會被激活。
            //childOption是用來給父級ServerChannel之下的Channels設置參數的
            .childOption(ChannelOption.SO_KEEPALIVE, true);
            // Bind and start to accept incoming connections.
            ChannelFuture f=b.bind(port).sync();
            // Wait until the server socket is closed.
            // In this example, this does not happen, but you can do that to gracefully
            // shut down your server.
            //sync()會同步等待連接操作結果，用戶線程將在此wait()，直到連接操作完成之后，線程被notify(),用戶代碼繼續執行
            //closeFuture()當Channel關閉時返回一個ChannelFuture,用於鏈路檢測
            f.channel().closeFuture().sync();
        }finally{
            //資源優雅釋放
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
    
    public static void main(String[] args) {
        int port=8088;
        try {
            new DiscardServer(port).run();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

三.測試

打開Window的命令行，輸入telnet命令:telnet localhost 8088,如果能夠正確連接就代表成功，在新打開的命令窗口隨意輸入字符，如果在myeclipse當中能夠正確輸出在console當中，就代表程序正常。

 

 

進入編輯狀態

 

 輸入hello world

 

ctrl+]回顯內容

 

 

 回車，進入編輯狀態

 

 

 

后台可以輸出：

 

 

 

   telnet配置使用鏈接：https://www.cnblogs.com/nongzihong/p/11855918.html