序言：簡單開發前端傳送訊息，後端接收訊息並返回。

1、故事牽引

今天通過一個故事來講解netty，主要講client和server端和下面的主要實現類。

客戶要去ktv唱歌，進入ktv之前，門口會有招待服務生，然後招待服務生看到客戶之後，會安排你們給ktv內部服務生給你們安排房間，讓後帶你們進入ktv房間唱歌，準備開始唱歌就要開啟音樂，選好歌曲，開啟燈光等因素，之後這個期間你們可能會讓唱歌的服務生來助唱，讓會跳舞的服務生給你們跳舞，甚至讓服務生帶來酒或者吃的，直到你們唱歌結束付完錢離開為止，整個過程就算結束。

專有名詞解釋：

client端：客戶

server端：ktv

mainGroup或者boosGroup:主執行緒組，相當於招待服務生

subGroup或者workerGroup：子執行緒組，相當於內部服務生

ServerBootstrap ：客戶進入ktv之前到離開ktv之後的整個流程

HelloServerInitializer：進入ktv房間準備點歌，初始化，準備點歌的環境以及東西

CustomHandler ：分別代表唱歌服務生、端茶送水服務生、跳舞服務生等等

1、NIO圖

2、server端

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;

/**
 * @Description: 實現客戶端傳送一個請求，伺服器會返回 hello netty
 */
public class HelloServer {

   public static void main(String[] args) throws Exception {

      // 定義一對執行緒組
      // 主執行緒組, 用於接受客戶端的連線，但是不做任何處理，跟老闆一樣，不做事
      EventLoopGroup bossGroup = new NioEventLoopGroup();
      // 從執行緒組, 老闆執行緒組會把任務丟給他，讓手下執行緒組去做任務
      EventLoopGroup workerGroup = new NioEventLoopGroup();
      
      try {
         // netty伺服器的建立, ServerBootstrap 是一個啟動類
         ServerBootstrap serverBootstrap = new ServerBootstrap();
         serverBootstrap.group(bossGroup, workerGroup)        // 設定主從執行緒組
                     .channel(NioServerSocketChannel.class) // 設定nio的雙向通道
                     .childHandler(new HelloServerInitializer()); // 子處理器，用於處理workerGroup
         
         // 啟動server，並且設定8088為啟動的埠號，同時啟動方式為同步
         ChannelFuture channelFuture = serverBootstrap.bind(8088).sync();
         
         // 監聽關閉的channel，設定位同步方式
         channelFuture.channel().closeFuture().sync();
      } finally {
         bossGroup.shutdownGracefully();
         workerGroup.shutdownGracefully();
      }
   }
}

3、建立處理器

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;
/**
 * @Description: 初始化器，channel註冊後，會執行裡面的相應的初始化方法
 */
public class HelloServerInitializer extends ChannelInitializer<SocketChannel> {

   @Override
   protected void initChannel(SocketChannel channel) throws Exception {
      // 通過SocketChannel去獲得對應的管道
      ChannelPipeline pipeline = channel.pipeline();
      
      // 通過管道，新增handler
      // HttpServerCodec是由netty自己提供的助手類，可以理解為攔截器
      // 當請求到服務端，我們需要做解碼，響應到客戶端做編碼
      pipeline.addLast("HttpServerCodec", new HttpServerCodec());
      
      // 新增自定義的助手類，返回 "hello netty~"
      pipeline.addLast("customHandler", new CustomHandler());
   }
}

4、建立助手類

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.DefaultFullHttpResponse;
import io.netty.handler.codec.http.FullHttpResponse;
import io.netty.handler.codec.http.HttpHeaderNames;
import io.netty.handler.codec.http.HttpObject;
import io.netty.handler.codec.http.HttpRequest;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.HttpVersion;
import io.netty.util.CharsetUtil;

/**
 * @Description: 建立自定義助手類
 */
// SimpleChannelInboundHandler: 對於請求來講，其實相當於[入站，入境]
public class CustomHandler extends SimpleChannelInboundHandler<HttpObject> {

   @Override
   protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) 
         throws Exception {
      // 獲取channel
      Channel channel = ctx.channel();
      
      if (msg instanceof HttpRequest) {
         // 顯示客戶端的遠端地址
         System.out.println(channel.remoteAddress());
         
         // 定義傳送的資料訊息
         ByteBuf content = Unpooled.copiedBuffer("Hello netty~", CharsetUtil.UTF_8);
         
         // 構建一個http response
         FullHttpResponse response = 
               new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
                     HttpResponseStatus.OK, 
                     content);
         // 為響應增加資料型別和長度
         response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain");
         response.headers().set(HttpHeaderNames.CONTENT_LENGTH, content.readableBytes());
         
         // 把響應刷到客戶端
         ctx.writeAndFlush(response);
      }
      
   }

   @Override
   public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
      System.out.println("channel。。。註冊");
      super.channelRegistered(ctx);
   }

   @Override
   public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
      System.out.println("channel。。。移除");
      super.channelUnregistered(ctx);
   }

   @Override
   public void channelActive(ChannelHandlerContext ctx) throws Exception {
      System.out.println("channel。。。活躍");
      super.channelActive(ctx);
   }

   @Override
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {
      System.out.println("channel。。。不活躍");
      super.channelInactive(ctx);
   }

   @Override
   public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
      System.out.println("channeld讀取完畢。。。");
      super.channelReadComplete(ctx);
   }

   @Override
   public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
      System.out.println("使用者事件觸發。。。");
      super.userEventTriggered(ctx, evt);
   }

   @Override
   public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
      System.out.println("channel可寫更改");
      super.channelWritabilityChanged(ctx);
   }

   @Override
   public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
      System.out.println("補貨到異常");
      super.exceptionCaught(ctx, cause);
   }

   @Override
   public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
      System.out.println("助手類新增");
      super.handlerAdded(ctx);
   }

   @Override
   public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
      System.out.println("助手類移除");
      super.handlerRemoved(ctx);
   }
}

5、pom檔案

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.25.Final</version>
</dependency>

6、啟動main函式

開啟瀏覽器：localhost:8088,出現下面錯誤情況，如果用postman工具的話，就會發現不報錯，因為瀏覽器會自動關閉。

解決方案：將super.exceptionCauht(ctx,case)；註釋掉就好了

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

相關推薦