這篇文章給大家分享的是有關(guān)怎么使用Netty搭建服務(wù)端和客戶端的內(nèi)容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

成都創(chuàng)新互聯(lián)公司是一家專注于網(wǎng)站設(shè)計制作、成都網(wǎng)站設(shè)計與策劃設(shè)計,許昌網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)公司做網(wǎng)站,專注于網(wǎng)站建設(shè)十載,網(wǎng)設(shè)計領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:許昌等地區(qū)。許昌做網(wǎng)站價格咨詢:18980820575

服務(wù)端

public class PrintServer {

  public void bind(int port) throws Exception {
    EventLoopGroup bossGroup = new NioEventLoopGroup();           //1
    EventLoopGroup workerGroup = new NioEventLoopGroup();          //2
    try {
      ServerBootstrap b = new ServerBootstrap();             //3
      b.group(bossGroup, workerGroup)                   //4                     
          .channel(NioServerSocketChannel.class)           //5
          .option(ChannelOption.SO_BACKLOG, 1024)           //6
          .childHandler(new ChannelInitializer<SocketChannel>() {   //7
            @Override
            protected void initChannel(SocketChannel ch) throws Exception {
              ch.pipeline().addLast(new PrintServerHandler());
            }
          });

      ChannelFuture f = b.bind(port).sync();       //8
      
      f.channel().closeFuture().sync();          //9
    } finally {
      // 優(yōu)雅退出，釋放線程池資源
      bossGroup.shutdownGracefully();
      workerGroup.shutdownGracefully();
    }
  }


  /**
   * @param args
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
    int port = 8080;
    new TimeServer().bind(port);
  }
}

我們來分析一下上面的這段代碼（下面的每一點對應(yīng)上面的注釋）

1~2：首先我們創(chuàng)建了兩個NioEventLoopGroup實例，它是一個由Netty封裝好的包含NIO的線程組。為什么創(chuàng)建兩個？我想經(jīng)過前面的學(xué)習(xí)大家應(yīng)該都清楚了。對，因為Netty的底層是IO多路復(fù)用，bossGroup 是用于接收客戶端的連接，原理就是一個實現(xiàn)的Selector的Reactor線程。而workerGroup用于進行SocketChannel的網(wǎng)絡(luò)讀寫。

3：創(chuàng)建一個ServerBootstrap對象，可以把它想象成Netty的入口，通過這類來啟動Netty，將所需要的參數(shù)傳遞到該類當(dāng)中，大大降低了的開發(fā)難度。

4：將兩個NioEventLoopGroup實例綁定到ServerBootstrap對象中。

5：創(chuàng)建Channel（典型的channel有NioSocketChannel，NioServerSocketChannel，OioSocketChannel，OioServerSocketChannel，EpollSocketChannel，EpollServerSocketChannel），這里創(chuàng)建的是NIOserverSocketChannel，它的功能可以理解為當(dāng)接受到客戶端的連接請求的時候，完成TCP三次握手，TCP物理鏈路建立成功。并將該“通道”與workerGroup線程組的某個線程相關(guān)聯(lián)。

6：設(shè)置參數(shù)，這里設(shè)置的SO_BACKLOG，意思是客戶端連接等待隊列的長度為1024.

7：建立連接后的具體Handler。就是我們接受數(shù)據(jù)后的具體操作，例如：記錄日志，對信息解碼編碼等。

8：綁定端口，同步等待成功

9：等待服務(wù)端監(jiān)聽端口關(guān)閉

綁定該服務(wù)端的Handler

public class PrintServerHandler extends ChannelHandlerAdapter {

  @Override
  public void channelRead(ChannelHandlerContext ctx, Object msg)
    throws Exception {
  ByteBuf buf = (ByteBuf) msg;                    //1
  byte[] req = new byte[buf.readableBytes()]; 
  buf.readBytes(req); //將緩存區(qū)的字節(jié)數(shù)組復(fù)制到新建的req數(shù)組中
  String body = new String(req, "UTF-8");
  System.out.println(body);
  String response= "打印成功";
  ByteBuf resp = Unpooled.copiedBuffer(response.getBytes());           
  ctx.write(resp);                          //2
  }  

  @Override
  public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
  ctx.flush();                            //3
  }


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

PrintServerHandler 繼承 ChannelHandlerAdapter ，在這里它的功能為 打印客戶端發(fā)來的數(shù)據(jù)并且返回客戶端打印成功。

我們只需要實現(xiàn)channelRead，exceptionCaught，前一個為接受消息具體邏輯的實現(xiàn)，后一個為發(fā)生異常后的具體邏輯實現(xiàn)。

1：我們可以看到，接受的消息被封裝為了Object ，我們將其轉(zhuǎn)換為ByteBuf ，前一章的講解中也說明了該類的作用。我們需要讀取的數(shù)據(jù)就在該緩存類中。

2~3：我們將寫好的數(shù)據(jù)封裝到ByteBuf中，然后通過write方法寫回到客戶端，這里的3調(diào)用flush方法的作用為，防止頻繁的發(fā)送數(shù)據(jù)，write方法并不直接將數(shù)據(jù)寫入SocketChannel中，而是把待發(fā)送的數(shù)據(jù)放到發(fā)送緩存數(shù)組中，再調(diào)用flush方法發(fā)送數(shù)據(jù)。

客戶端

public class PrintClient {

  public void connect(int port, String host) throws Exception {
  EventLoopGroup group = new NioEventLoopGroup();         //1
  try {
    Bootstrap b = new Bootstrap();               //2
     b.group(group)                       //3
      .channel(NioSocketChannel.class)            //4
      .option(ChannelOption.TCP_NODELAY, true)        //5
      .handler(new ChannelInitializer<SocketChannel>() {   //6
      @Override
      public void initChannel(SocketChannel ch)        
        throws Exception {
        ch.pipeline().addLast(new PrintClientHandler());
      }
      });

    ChannelFuture f = b.connect(host, port).sync();       //7
    f.channel().closeFuture().sync();              //8
  } finally {
    // 優(yōu)雅退出，釋放NIO線程組
    group.shutdownGracefully();
  }
  }

  /**
   * @param args
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
  int port = 8080;
  new TimeClient().connect(port, "127.0.0.1");
  }
}

我們繼續(xù)來分析一下上面的這段代碼（下面的每一點對應(yīng)上面的注釋）

1：區(qū)別于服務(wù)端，我們在客戶端只創(chuàng)建了一個NioEventLoopGroup實例，因為客戶端你并不需要使用I/O多路復(fù)用模型，需要有一個Reactor來接受請求。只需要單純的讀寫數(shù)據(jù)即可

2：區(qū)別于服務(wù)端，我們在客戶端只需要創(chuàng)建一個Bootstrap對象，它是客戶端輔助啟動類，功能類似于ServerBootstrap。

3：將NioEventLoopGroup實例綁定到Bootstrap對象中。

4：創(chuàng)建Channel（典型的channel有NioSocketChannel，NioServerSocketChannel，OioSocketChannel，OioServerSocketChannel，EpollSocketChannel，EpollServerSocketChannel），區(qū)別與服務(wù)端，這里創(chuàng)建的是NIOSocketChannel.

5：設(shè)置參數(shù)，這里設(shè)置的TCP_NODELAY為true，意思是關(guān)閉延遲發(fā)送，一有消息就立即發(fā)送，默認為false。

6：建立連接后的具體Handler。注意這里區(qū)別與服務(wù)端，使用的是handler()而不是childHandler()。handler和childHandler的區(qū)別在于，handler是接受或發(fā)送之前的執(zhí)行器；childHandler為建立連接之后的執(zhí)行器。

7：發(fā)起異步連接操作

8：當(dāng)代客戶端鏈路關(guān)閉

綁定該客戶端的Handler

public class PrintClientHandler extends ChannelHandlerAdapter {

  private static final Logger logger = Logger
    .getLogger(TimeClientHandler.class.getName());

  private final ByteBuf firstMessage;

  /**
   * Creates a client-side handler.
   */
  public TimeClientHandler() {
  byte[] req = "你好服務(wù)端".getBytes();
  firstMessage = Unpooled.buffer(req.length);                 //1
  firstMessage.writeBytes(req);

  }

  @Override
  public void channelActive(ChannelHandlerContext ctx) {
  ctx.writeAndFlush(firstMessage);                      //2       
  }

  @Override
  public void channelRead(ChannelHandlerContext ctx, Object msg)       //3
    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("服務(wù)端回應(yīng)消息 : " + body);
  }

  @Override
  public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {  //4
  // 釋放資源
  System.out.println("Unexpected exception from downstream : "
    + cause.getMessage());
  ctx.close();
  }
}

PrintClientHandler 繼承 ChannelHandlerAdapter ，在這里它的功能為 發(fā)送數(shù)據(jù)并打印服務(wù)端發(fā)來的數(shù)據(jù)。

我們只需要實現(xiàn)channelActive，channelRead，exceptionCaught，第一個為建立連接后立即執(zhí)行，后兩個與一個為接受消息具體邏輯的實現(xiàn)，另一個為發(fā)生異常后的具體邏輯實現(xiàn)。

1：將發(fā)送的信息封裝到ByteBuf中。

2：發(fā)送消息。

3：接受客戶端的消息并打印

4：發(fā)生異常時，打印異常信息，釋放客戶端資源

感謝各位的閱讀！關(guān)于“怎么使用Netty搭建服務(wù)端和客戶端”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

網(wǎng)頁題目：怎么使用Netty搭建服務(wù)端和客戶端
轉(zhuǎn)載來源：http://www.chinadenli.net/article24/iepcje.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供全網(wǎng)營銷推廣、Google、定制開發(fā)、軟件開發(fā)、做網(wǎng)站、外貿(mào)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)