這篇文章主要介紹“NettyClient半包粘包處理代碼實例”，在日常操作中，相信很多人在NettyClient半包粘包處理代碼實例問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”NettyClient半包粘包處理代碼實例”的疑惑有所幫助！接下來，請跟著小編一起來學(xué)習(xí)吧！

成都創(chuàng)新互聯(lián)公司主要從事成都做網(wǎng)站、網(wǎng)站制作、網(wǎng)頁設(shè)計、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)朝陽,10年網(wǎng)站建設(shè)經(jīng)驗,價格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):18982081108

前言介紹

Netty開發(fā)中，客戶端與服務(wù)端需要保持同樣的；半包粘包處理，編碼解碼處理、收發(fā)數(shù)據(jù)方式，這樣才能保證數(shù)據(jù)通信正常。在前面NettyServer的章節(jié)中我們也同樣處理了；半包粘包、編碼解碼等，為此在本章節(jié)我們可以把這些知識模塊開發(fā)到NettyClient中。本章節(jié)涉及到的知識點有；LineBasedFrameDecoder、StringDecoder、StringEncoder、ChannelInboundHandlerAdapter等。

開發(fā)環(huán)境

1、jdk1.8【jdk1.7以下只能部分支持netty】
2、Netty4.1.36.Final【netty3.x 4.x 5每次的變化較大，接口類名也隨著變化】
3、telnet 測試【可以現(xiàn)在你的win7機器上測試這個命令，用于鏈接到服務(wù)端的測試命令】

代碼示例

itstack-demo-netty-1-08
└── src
   ├── main
   │   └── java
   │       └── org.itstack.demo.netty.client
   │           ├── MyChannelInitializer.java
   │           ├── MyClientHandler.java
   │           └── NettyClient.java
   └── test
        └── java
            └── org.itstack.demo.netty.test
                └── ApiTest.java

MyChannelInitializer.java

/**
* 蟲洞棧：https://bugstack.cn
* 公眾號：bugstack蟲洞棧  ｛獲取學(xué)習(xí)源碼｝
* Create by fuzhengwei on 2019
*/
public class MyChannelInitializer extends ChannelInitializer<SocketChannel> {

   @Override
   protected void initChannel(SocketChannel channel) throws Exception {
       // 基于換行符號
       channel.pipeline().addLast(new LineBasedFrameDecoder(1024));
       // 解碼轉(zhuǎn)String，注意調(diào)整自己的編碼格式GBK、UTF-8
       channel.pipeline().addLast(new StringDecoder(Charset.forName("GBK")));
       // 解碼轉(zhuǎn)String，注意調(diào)整自己的編碼格式GBK、UTF-8
       channel.pipeline().addLast(new StringEncoder(Charset.forName("GBK")));
       // 在管道中添加我們自己的接收數(shù)據(jù)實現(xiàn)方法
       channel.pipeline().addLast(new MyClientHandler());
   }

}

MyClientHandler.java

/**
* 蟲洞棧：https://bugstack.cn
* 公眾號：bugstack蟲洞棧  ｛獲取學(xué)習(xí)源碼｝
* Create by fuzhengwei on 2019
*/
public class MyClientHandler extends ChannelInboundHandlerAdapter {

   /**
    * 當(dāng)客戶端主動鏈接服務(wù)端的鏈接后，這個通道就是活躍的了。也就是客戶端與服務(wù)端建立了通信通道并且可以傳輸數(shù)據(jù)
    */
   @Override
   public void channelActive(ChannelHandlerContext ctx) throws Exception {
       SocketChannel channel = (SocketChannel) ctx.channel();
       System.out.println("鏈接報告開始");
       System.out.println("鏈接報告信息：本客戶端鏈接到服務(wù)端。channelId：" + channel.id());
       System.out.println("鏈接報告IP:" + channel.localAddress().getHostString());
       System.out.println("鏈接報告Port:" + channel.localAddress().getPort());
       System.out.println("鏈接報告完畢");
       //通知客戶端鏈接建立成功
       String str = "通知服務(wù)端鏈接建立成功" + " " + new Date() + " " + channel.localAddress().getHostString() + "\r\n";
       ctx.writeAndFlush(str);
   }

   /**
    * 當(dāng)客戶端主動斷開服務(wù)端的鏈接后，這個通道就是不活躍的。也就是說客戶端與服務(wù)端的關(guān)閉了通信通道并且不可以傳輸數(shù)據(jù)
    */
   @Override
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {
       System.out.println("斷開鏈接" + ctx.channel().localAddress().toString());
   }

   @Override
   public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
       //接收msg消息{與上一章節(jié)相比，此處已經(jīng)不需要自己進行解碼}
       System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " 接收到消息：" + msg);
       //通知客戶端鏈消息發(fā)送成功
       String str = "客戶端收到：" + new Date() + " " + msg + "\r\n";
       ctx.writeAndFlush(str);
   }

   /**
    * 抓住異常，當(dāng)發(fā)生異常的時候，可以做一些相應(yīng)的處理，比如打印日志、關(guān)閉鏈接
    */
   @Override
   public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
       ctx.close();
       System.out.println("異常信息：\r\n" + cause.getMessage());
   }

}

NettyClient.java

/**
* 蟲洞棧：https://bugstack.cn
* 公眾號：bugstack蟲洞棧  ｛獲取學(xué)習(xí)源碼｝
* Create by fuzhengwei on 2019
*/
public class NettyClient {

   public static void main(String[] args) {
       new NettyClient().connect("127.0.0.1", 7397);
   }

   private void connect(String inetHost, int inetPort) {
       EventLoopGroup workerGroup = new NioEventLoopGroup();
       try {
           Bootstrap b = new Bootstrap();
           b.group(workerGroup);
           b.channel(NioSocketChannel.class);
           b.option(ChannelOption.AUTO_READ, true);
           b.handler(new MyChannelInitializer());
           ChannelFuture f = b.connect(inetHost, inetPort).sync();
           System.out.println("itstack-demo-netty client start done. {關(guān)注公眾號：bugstack蟲洞棧，獲取源碼}");
           f.channel().closeFuture().sync();
       } catch (InterruptedException e) {
           e.printStackTrace();
       } finally {
           workerGroup.shutdownGracefully();
       }
   }

}

測試結(jié)果

啟動模擬器NetAssist 設(shè)置TCP Server

啟動客戶端NettyClient

執(zhí)行結(jié)果

/**
* 蟲洞棧：https://bugstack.cn
* 公眾號：bugstack蟲洞棧  ｛獲取學(xué)習(xí)源碼｝
* Create by fuzhengwei on 2019
*/
public class NettyClient {

   public static void main(String[] args) {
       new NettyClient().connect("127.0.0.1", 7397);
   }

   private void connect(String inetHost, int inetPort) {
       EventLoopGroup workerGroup = new NioEventLoopGroup();
       try {
           Bootstrap b = new Bootstrap();
           b.group(workerGroup);
           b.channel(NioSocketChannel.class);
           b.option(ChannelOption.AUTO_READ, true);
           b.handler(new MyChannelInitializer());
           ChannelFuture f = b.connect(inetHost, inetPort).sync();
           System.out.println("itstack-demo-netty client start done. {關(guān)注公眾號：bugstack蟲洞棧，獲取源碼}");
           f.channel().closeFuture().sync();
       } catch (InterruptedException e) {
           e.printStackTrace();
       } finally {
           workerGroup.shutdownGracefully();
       }
   }

}

到此，關(guān)于“NettyClient半包粘包處理代碼實例”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

當(dāng)前標(biāo)題：NettyClient半包粘包處理代碼實例
URL地址：http://www.yijiale78.com/article10/gdcddo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動態(tài)網(wǎng)站、建站公司、、定制開發(fā)、網(wǎng)站建設(shè)、網(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)