Netty實現SSL雙向驗證完整實例

時間  2019-11-06
標籤 netty 實現 ssl 雙向 驗證 完整 實例 欄目 Netty 简体版
原文   原文鏈接

Netty實現SSL雙向驗證完整實例

博客分類：
netty ssl 自簽證書 

 1、證書準備java

     要使用ssl雙向驗證，就必須先要生成服務端和客戶端的證書，並相互添加信任，具體流程以下(本人調試這個用例的時候，花了不少時間來驗證證書是否正確，以及握手失敗的緣由，這裏證書生成過程只要按流程走，本人能保證絕對沒有問題)算法

如今打開cmd，在哪一個目錄下打開，證書就會放在哪一個目錄下：spring

第一步:   生成Netty服務端私鑰和證書倉庫命令bootstrap

 keytool -genkey -alias securechat -keysize 2048 -validity 365 -keyalg RSA -dname "CN=localhost" -keypass sNetty -storepass sNetty -keystore sChat.jkssession

 

  • -keysize 2048 密鑰長度2048位（這個長度的密鑰目前可認爲沒法被暴力破解）
  • -validity 365 證書有效期365天
  • -keyalg RSA 使用RSA非對稱加密算法
  • -dname "CN=localhost" 設置Common Name爲localhost
  • -keypass sNetty密鑰的訪問密碼爲sNetty
  • -storepass sNetty密鑰庫的訪問密碼爲sNetty（其實這兩個密碼也能夠設置同樣，一般都設置同樣，方便記）
  • -keystore sChat.jks 指定生成的密鑰庫文件爲sChata.jks

第二步：生成Netty服務端自簽名證書socket

             keytool -export -alias securechat -keystore sChat.jks -storepass sNetty -file sChat.ceride

 第三步：生成客戶端的密鑰對和證書倉庫，用於將服務端的證書保存到客戶端的授信證書倉庫中oop

    keytool -genkey -alias smcc -keysize 2048 -validity 365  -keyalg RSA -dname "CN=localhost" -keypass sNetty  -storepass sNetty -keystore cChat.jks

第四步：將Netty服務端證書導入到客戶端的證書倉庫中測試

keytool -import -trustcacerts -alias securechat -file sChat.cer -storepass sNetty -keystore cChat.jksui

若是你只作單向認證，則到此就能夠結束了，若是是雙響認證，則還需繼續往下走

第五步:生成客戶端自簽名證書

  keytool -export -alias smcc -keystore cChat.jks -storepass sNetty -file cChat.cer

最後一步:將客戶端的自簽名證書導入到服務端的信任證書倉庫中：

   keytool -import -trustcacerts -alias smcc -file cChat.cer -storepass sNetty -keystore sChat.jks

            

到這裏，證書就生成完畢了，咱們就能夠獲得兩個jks文件，一個是服務端的sChat.jks  ，一個是客戶端的cChat.jks   ,這兩個文件後面初始化sslCOntext的時候會用到

若是還想了解更多能夠查看

http://dwj147258.iteye.com/blog/2339934

 

2、netty服務端

       下面就直接貼代碼了，首先是實例化SSLContext的類：

 

Java代碼   收藏代碼
  1. package main.java.com.nionetty;  
  2.   
  3. import java.io.FileInputStream;  
  4. import java.io.IOException;  
  5. import java.security.KeyStore;  
  6. import java.security.NoSuchAlgorithmException;  
  7.   
  8. import javax.net.ssl.KeyManager;  
  9. import javax.net.ssl.KeyManagerFactory;  
  10. import javax.net.ssl.SSLContext;  
  11. import javax.net.ssl.TrustManager;  
  12. import javax.net.ssl.TrustManagerFactory;  
  13.   
  14. import org.springframework.core.io.ClassPathResource;  
  15. /** 
  16.  * 初始化sslcontext類 
  17.  * 
  18.  */  
  19. public class ContextSSLFactory {  
  20.       
  21.     private static final SSLContext SSL_CONTEXT_S ;  
  22.       
  23.     private static final SSLContext SSL_CONTEXT_C ;  
  24.       
  25.     static{  
  26.         SSLContext sslContext = null ;  
  27.         SSLContext sslContext2 = null ;  
  28.         try {  
  29.             sslContext = SSLContext.getInstance("SSLv3") ;  
  30.             sslContext2 = SSLContext.getInstance("SSLv3") ;  
  31.         } catch (NoSuchAlgorithmException e1) {  
  32.             e1.printStackTrace();  
  33.         }  
  34.         try{  
  35.             if(getKeyManagersServer() != null && getTrustManagersServer() != null ){  
  36.                 sslContext.init(getKeyManagersServer(), getTrustManagersServer(), null);  
  37.             }  
  38.             if(getKeyManagersClient() != null && getTrustManagersClient() != null){  
  39.                 sslContext2.init(getKeyManagersClient(), getTrustManagersClient(), null);  
  40.             }  
  41.               
  42.         }catch(Exception e){  
  43.             e.printStackTrace() ;  
  44.         }  
  45.         sslContext.createSSLEngine().getSupportedCipherSuites() ;  
  46.         sslContext2.createSSLEngine().getSupportedCipherSuites() ;  
  47.         SSL_CONTEXT_S = sslContext ;   
  48.         SSL_CONTEXT_C = sslContext2 ;  
  49.     }  
  50.     public ContextSSLFactory(){  
  51.           
  52.     }  
  53.     public static SSLContext getSslContext(){  
  54.         return SSL_CONTEXT_S ;  
  55.     }  
  56.     public static SSLContext getSslContext2(){  
  57.         return SSL_CONTEXT_C ;  
  58.     }  
  59.     private static TrustManager[] getTrustManagersServer(){  
  60.         FileInputStream is = null ;  
  61.         KeyStore ks = null ;  
  62.         TrustManagerFactory keyFac = null ;  
  63.           
  64.         TrustManager[] kms = null ;  
  65.         try {  
  66.              // 得到KeyManagerFactory對象. 初始化位默認算法  
  67.             keyFac = TrustManagerFactory.getInstance("SunX509") ;  
  68.             is =new FileInputStream( (new ClassPathResource("main/java/conf/sChat.jks")).getFile() );  
  69.             ks = KeyStore.getInstance("JKS") ;  
  70.             String keyStorePass = "sNetty" ;  
  71.             ks.load(is , keyStorePass.toCharArray()) ;  
  72.             keyFac.init(ks) ;  
  73.             kms = keyFac.getTrustManagers() ;  
  74.         } catch (Exception e) {  
  75.             e.printStackTrace();  
  76.         }  
  77.         finally{  
  78.             if(is != null ){  
  79.                 try {  
  80.                     is.close() ;  
  81.                 } catch (IOException e) {  
  82.                     e.printStackTrace();  
  83.                 }  
  84.             }  
  85.         }  
  86.         return kms ;  
  87.     }  
  88.     private static TrustManager[] getTrustManagersClient(){  
  89.         FileInputStream is = null ;  
  90.         KeyStore ks = null ;  
  91.         TrustManagerFactory keyFac = null ;  
  92.           
  93.         TrustManager[] kms = null ;  
  94.         try {  
  95.              // 得到KeyManagerFactory對象. 初始化位默認算法  
  96.             keyFac = TrustManagerFactory.getInstance("SunX509") ;  
  97.             is =new FileInputStream( (new ClassPathResource("main/java/conf/cChat.jks")).getFile() );  
  98.             ks = KeyStore.getInstance("JKS") ;  
  99.             String keyStorePass = "sNetty" ;  
  100.             ks.load(is , keyStorePass.toCharArray()) ;  
  101.             keyFac.init(ks) ;  
  102.             kms = keyFac.getTrustManagers() ;  
  103.         } catch (Exception e) {  
  104.             e.printStackTrace();  
  105.         }  
  106.         finally{  
  107.             if(is != null ){  
  108.                 try {  
  109.                     is.close() ;  
  110.                 } catch (IOException e) {  
  111.                     e.printStackTrace();  
  112.                 }  
  113.             }  
  114.         }  
  115.         return kms ;  
  116.     }  
  117.     private static KeyManager[] getKeyManagersServer(){  
  118.         FileInputStream is = null ;  
  119.         KeyStore ks = null ;  
  120.         KeyManagerFactory keyFac = null ;  
  121.           
  122.         KeyManager[] kms = null ;  
  123.         try {  
  124.              // 得到KeyManagerFactory對象. 初始化位默認算法  
  125.             keyFac = KeyManagerFactory.getInstance("SunX509") ;  
  126.             is =new FileInputStream( (new ClassPathResource("main/java/conf/sChat.jks")).getFile() );  
  127.             ks = KeyStore.getInstance("JKS") ;  
  128.             String keyStorePass = "sNetty" ;  
  129.             ks.load(is , keyStorePass.toCharArray()) ;  
  130.             keyFac.init(ks, keyStorePass.toCharArray()) ;  
  131.             kms = keyFac.getKeyManagers() ;  
  132.         } catch (Exception e) {  
  133.             e.printStackTrace();  
  134.         }  
  135.         finally{  
  136.             if(is != null ){  
  137.                 try {  
  138.                     is.close() ;  
  139.                 } catch (IOException e) {  
  140.                     e.printStackTrace();  
  141.                 }  
  142.             }  
  143.         }  
  144.         return kms ;  
  145.     }  
  146.     private static KeyManager[] getKeyManagersClient(){  
  147.         FileInputStream is = null ;  
  148.         KeyStore ks = null ;  
  149.         KeyManagerFactory keyFac = null ;  
  150.           
  151.         KeyManager[] kms = null ;  
  152.         try {  
  153.              // 得到KeyManagerFactory對象. 初始化位默認算法  
  154.             keyFac = KeyManagerFactory.getInstance("SunX509") ;  
  155.             is =new FileInputStream( (new ClassPathResource("main/java/conf/cChat.jks")).getFile() );  
  156.             ks = KeyStore.getInstance("JKS") ;  
  157.             String keyStorePass = "sNetty" ;  
  158.             ks.load(is , keyStorePass.toCharArray()) ;  
  159.             keyFac.init(ks, keyStorePass.toCharArray()) ;  
  160.             kms = keyFac.getKeyManagers() ;  
  161.         } catch (Exception e) {  
  162.             e.printStackTrace();  
  163.         }  
  164.         finally{  
  165.             if(is != null ){  
  166.                 try {  
  167.                     is.close() ;  
  168.                 } catch (IOException e) {  
  169.                     e.printStackTrace();  
  170.                 }  
  171.             }  
  172.         }  
  173.         return kms ;  
  174.     }  
  175. }  

 

 

服務端啓動類：

 

Java代碼   收藏代碼
  1. package main.java.com.nionetty;  
  2.   
  3. import javax.net.ssl.SSLEngine;  
  4. import javax.print.attribute.standard.MediaSize.Engineering;  
  5.   
  6. import main.java.com.nettyTest.SecureChatServerHandler;  
  7.   
  8. import io.netty.bootstrap.ServerBootstrap;  
  9. import io.netty.channel.ChannelHandlerContext;  
  10. import io.netty.channel.ChannelInitializer;  
  11. import io.netty.channel.ChannelOption;  
  12. import io.netty.channel.ChannelPipeline;  
  13. import io.netty.channel.EventLoopGroup;  
  14. import io.netty.channel.nio.NioEventLoopGroup;  
  15. import io.netty.channel.socket.SocketChannel;  
  16. import io.netty.channel.socket.nio.NioServerSocketChannel;  
  17. import io.netty.handler.logging.LogLevel;  
  18. import io.netty.handler.logging.LoggingHandler;  
  19. import io.netty.handler.ssl.SslHandler;  
  20. import io.netty.handler.timeout.IdleState;  
  21. import io.netty.handler.timeout.IdleStateEvent;  
  22. import io.netty.handler.timeout.IdleStateHandler;  
  23.   
  24. public class NettySocketServer {  
  25.     private static SslHandler sslHandler = null ;  
  26.       
  27.     private EventLoopGroup bossGroup = null ;  
  28.       
  29.     private EventLoopGroup workerGroup = null ;  
  30.       
  31.     public void start(){  
  32.         bossGroup = new NioEventLoopGroup() ;  
  33.         workerGroup = new NioEventLoopGroup() ;  
  34.         try{  
  35.             ServerBootstrap serverStrap = new ServerBootstrap() ;  
  36.             serverStrap.group(bossGroup , workerGroup)  
  37.             .channel(NioServerSocketChannel.class)  
  38.             .option(ChannelOption.SO_BACKLOG, 128)  
  39.             .option(ChannelOption.SO_KEEPALIVE, true)  
  40.             .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 1000 * 5 * 60)  
  41.             .handler(new LoggingHandler(LogLevel.DEBUG))  
  42.             .childHandler(new ChannelInitializer<SocketChannel>() {  
  43.   
  44.                 @Override  
  45.                 protected void initChannel(SocketChannel socketChannel) throws Exception {  
  46.                     ChannelPipeline pie = socketChannel.pipeline() ;  
  47.                     pie.addLast("decoder" , new MyDecoder()) ;  
  48.                     pie.addLast("encoder" , new MyEncoder()) ;  
  49.                     pie.addLast("handler" , new NettySocketSSLHandler()) ;  
  50.                     SSLEngine engine = ContextSSLFactory.getSslContext().createSSLEngine();  
  51.                     engine.setUseClientMode(false);  
  52.                     engine.setNeedClientAuth(true);  
  53.                     pie.addFirst("ssl", new SslHandler(engine));  
  54.                 }  
  55.                   
  56.             });  
  57.             serverStrap.bind(161616).sync() ;  
  58.             System.out.println("服務已開啓");  
  59.         }catch(Exception e){  
  60.             e.printStackTrace() ;  
  61.             bossGroup.shutdownGracefully() ;  
  62.             workerGroup.shutdownGracefully() ;  
  63.         }  
  64.           
  65.     }  
  66.         private SslHandler getSslHandler(){  
  67.             if(sslHandler == null ){  
  68.                 SSLEngine sslEngine = ContextSSLFactory.getSslContext().createSSLEngine() ;  
  69.                 sslEngine.setUseClientMode(false) ;  
  70.                 //false爲單向認證，true爲雙向認證  
  71.                 sslEngine.setNeedClientAuth(true) ;  
  72.                 sslHandler = new SslHandler(sslEngine);  
  73.             }  
  74.             return sslHandler ;  
  75.         }  
  76.         public static void main(String[] args) {  
  77.             new NettySocketServer().start() ;  
  78.         }  
  79.           
  80. }  

 編碼器：

 

 

Java代碼   收藏代碼
  1. package main.java.com.nionetty;  
  2.   
  3. import io.netty.buffer.ByteBuf;  
  4. import io.netty.channel.ChannelHandlerContext;  
  5. import io.netty.handler.codec.MessageToByteEncoder;  
  6.   
  7. import java.nio.ByteBuffer;  
  8.   
  9. public class MyEncoder extends MessageToByteEncoder<ByteBuffer>{  
  10.   
  11.     @Override  
  12.     protected void encode(ChannelHandlerContext ctx, ByteBuffer message,  
  13.             ByteBuf out) throws Exception {  
  14.   
  15.         if(message==null){  
  16.             return;  
  17.         }     
  18.         if(message.hasArray()){  
  19.             byte[] msg =message.array();  
  20.             if(msg == null || msg.length <= 0){  
  21.                 return;  
  22.             }  
  23.             out.writeBytes(msg) ;  
  24.         }  
  25.     }  
  26.       
  27.   
  28.      
  29. }  

 解碼器：

 

 

Java代碼   收藏代碼
  1. /* 
  2.  * Copyright (C) TD Tech<br> 
  3.  * All Rights Reserved.<br> 
  4.  *  
  5.  */  
  6. package main.java.com.nionetty;  
  7.   
  8. import io.netty.buffer.ByteBuf;  
  9. import io.netty.channel.ChannelHandlerContext;  
  10. import io.netty.handler.codec.ByteToMessageDecoder;  
  11.   
  12. import java.nio.ByteBuffer;  
  13. import java.util.List;  
  14.   
  15. /** 
  16.  * Create Date: 2014-11-4 下午02:42:21<br> 
  17.  * Create Author: lWX232692<br> 
  18.  * Description : 
  19.  */  
  20. public class MyDecoder extends ByteToMessageDecoder {  
  21.   
  22.   
  23.     @Override  
  24.     protected void decode(ChannelHandlerContext ctx, ByteBuf buffer,  
  25.             List<Object> out) throws Exception {  
  26.         //UnpooledUnsafeDirectByteBuf(ridx: 0, widx: 1, cap: 1024)  
  27.         if (buffer != null) {  
  28.             ByteBuffer msg = null;  
  29.             try {  
  30.                 if(buffer.readableBytes() > 0 ){  
  31.                     msg = ByteBuffer.allocate(buffer.readableBytes()) ;  
  32.                     byte[] bb = new byte[buffer.readableBytes()] ;  
  33.                     buffer.readBytes(bb) ;  
  34.                     msg.put(bb);  
  35.                     msg.flip();  
  36.                 }  
  37.             } catch (Exception e) {  
  38.                 e.printStackTrace();  
  39.                 msg = null ;  
  40.             }  
  41.             if (msg != null) {  
  42.                 out.add(msg);  
  43.             }  
  44.         }  
  45.     }  
  46.   
  47.   
  48. }  

業務實現類：

 

 

Java代碼   收藏代碼
  1. package main.java.com.nionetty;  
  2.   
  3. import io.netty.channel.Channel;  
  4. import io.netty.channel.ChannelHandlerContext;  
  5. import io.netty.channel.SimpleChannelInboundHandler;  
  6. import io.netty.handler.ssl.SslHandler;  
  7. import io.netty.util.concurrent.Future;  
  8. import io.netty.util.concurrent.GenericFutureListener;  
  9.   
  10. import java.net.InetAddress;  
  11. import java.nio.ByteBuffer;  
  12. import java.util.Arrays;  
  13.   
  14. public class NettySocketSSLHandler extends SimpleChannelInboundHandler<ByteBuffer>{  
  15.      @Override  
  16.         public void channelActive(final ChannelHandlerContext ctx) throws Exception {  
  17.             // Once session is secured, send a greeting and register the channel to the global channel  
  18.             // list so the channel received the messages from others.  
  19.             ctx.pipeline().get(SslHandler.class).handshakeFuture().addListener(  
  20.                     new GenericFutureListener<Future<Channel>>() {  
  21.                         @Override  
  22.                         public void operationComplete(Future<Channel> future) throws Exception {  
  23.                             if(future.isSuccess()){  
  24.                                 System.out.println("握手成功");  
  25.                                 byte[] array = new byte[]{ (byte)7d,  04} ;  
  26.                                 ByteBuffer bu = ByteBuffer.wrap(array) ;  
  27.                                 ctx.channel().writeAndFlush(bu) ;  
  28.                             }else{  
  29.                                 System.out.println("握手失敗");  
  30.                             }  
  31.                             ctx.writeAndFlush(  
  32.                                     "Welcome to " + InetAddress.getLocalHost().getHostName() +  
  33.                                             " secure chat service!\n");  
  34.                             ctx.writeAndFlush(  
  35.                                     "Your session is protected by " +  
  36.                                             ctx.pipeline().get(SslHandler.class).engine().getSession().getCipherSuite() +  
  37.                                             " cipher suite.\n");  
  38.   
  39.                         }  
  40.                     });  
  41.         }  
  42.     @Override  
  43.     public void handlerAdded(ChannelHandlerContext ctx)  
  44.         throws Exception {  
  45.          System.out.println("服務端增長");  
  46.     }  
  47.       
  48.     @Override  
  49.     public void handlerRemoved(ChannelHandlerContext ctx){  
  50.         System.out.println("移除:"+ctx.channel().remoteAddress());  
  51.     }  
  52.     @Override  
  53.     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {  
  54.        System.out.println("Unexpected exception from downstream.");  
  55.         ctx.close();  
  56.     }  
  57.     @Override  
  58.     public void messageReceived(ChannelHandlerContext ctx, ByteBuffer msg) throws Exception {  
  59.         System.out.println("服務端receive msg ");  
  60.         byte[] array = new byte[]{00, 01, 00, 00, 00, 06, 05, 03, (byte)7d, 00, 00, 07} ;  
  61.         ByteBuffer bu = ByteBuffer.wrap(array) ;  
  62.         ctx.channel().writeAndFlush(bu) ;  
  63.     }  
  64.       
  65. }  

 

 

3、客戶端

 

     客戶端實現類

 

 

Java代碼   收藏代碼
  1. package main.java.com.nionetty.client;  
  2.   
  3. import java.net.InetSocketAddress;  
  4. import java.net.SocketAddress;  
  5.   
  6. import javax.net.ssl.SSLEngine;  
  7.   
  8. import io.netty.bootstrap.Bootstrap;  
  9. import io.netty.channel.Channel;  
  10. import io.netty.channel.ChannelFuture;  
  11. import io.netty.channel.ChannelInitializer;  
  12. import io.netty.channel.ChannelOption;  
  13. import io.netty.channel.ChannelPipeline;  
  14. import io.netty.channel.EventLoopGroup;  
  15. import io.netty.channel.nio.NioEventLoopGroup;  
  16. import io.netty.channel.socket.SocketChannel;  
  17. import io.netty.channel.socket.nio.NioSocketChannel;  
  18. import io.netty.handler.ssl.SslHandler;  
  19. import main.java.com.nionetty.ContextSSLFactory;  
  20. import main.java.com.nionetty.MyDecoder;  
  21. import main.java.com.nionetty.MyEncoder;  
  22.   
  23. public class NettySocketClient {  
  24.       
  25.     private EventLoopGroup group ;  
  26.       
  27.     private Channel channel = null ;   
  28.     public void connect(String ip , int port){  
  29.         group = new NioEventLoopGroup();  
  30.         try{  
  31.             Bootstrap strap = new Bootstrap();  
  32.             strap.group(group)  
  33.             .channel(NioSocketChannel.class)  
  34.             .option(ChannelOption.TCP_NODELAY, true)  
  35.             .option(ChannelOption.SO_KEEPALIVE , true)  
  36.             .handler(new ChannelInitializer<SocketChannel>() {  
  37.                 @Override  
  38.                 protected void initChannel(SocketChannel socketChannel) throws Exception {  
  39.                     ChannelPipeline pieple = socketChannel.pipeline() ;  
  40.                     pieple.addLast("decoder" , new MyClientDecoder()) ;  
  41.                     pieple.addLast("encoder" , new MyClientEncoder()) ;  
  42.                     pieple.addLast("handler" , new NettySocketSSLClientHandler()) ;  
  43.                      SSLEngine engine = ContextSSLFactory.getSslContext2().createSSLEngine();  
  44.                      engine.setUseClientMode(true);  
  45.                      pieple.addFirst("ssl", new SslHandler(engine));  
  46.                 }  
  47.             });  
  48.         SocketAddress address = new InetSocketAddress(ip, port);  
  49.         final ChannelFuture future = strap.connect(address).sync();  
  50.         channel = future.awaitUninterruptibly().channel();  
  51.         System.out.println("鏈接成功， channel =" + channel.remoteAddress());  
  52.         }catch(Exception e ){  
  53.             e.printStackTrace();  
  54.             group.shutdownGracefully() ;  
  55.         }finally{  
  56.               
  57.         }  
  58.     }  
  59.     private static SslHandler sslHandlerClient = null ;  
  60.     public static SslHandler getSslHandler(){  
  61.         if(sslHandlerClient == null){  
  62.             SSLEngine sslEngine = ContextSSLFactory.getSslContext2().createSSLEngine() ;  
  63.             sslEngine.setUseClientMode(true) ;  
  64.             sslHandlerClient = new SslHandler(sslEngine);  
  65.         }  
  66.         return sslHandlerClient ;  
  67.     }  
  68.     public static void main(String[] args) {  
  69.         new NettySocketClient().connect("192.168.10.256", 161616) ;  
  70.     }  
  71. }  

 編碼器：

 

 

Java代碼   收藏代碼
  1. package main.java.com.nionetty.client;  
  2.   
  3. import io.netty.buffer.ByteBuf;  
  4. import io.netty.channel.ChannelHandlerContext;  
  5. import io.netty.handler.codec.MessageToByteEncoder;  
  6.   
  7. import java.nio.ByteBuffer;  
  8.   
  9. public class MyClientEncoder extends MessageToByteEncoder<ByteBuffer>{  
  10.   
  11.     @Override  
  12.     protected void encode(ChannelHandlerContext ctx, ByteBuffer message,  
  13.             ByteBuf out) throws Exception {  
  14.   
  15.         if(message==null){  
  16.             return;  
  17.         }     
  18.         if(message .hasArray()){  
  19.             byte[] msg =message.array();  
  20.             if(msg == null || msg.length <= 0){  
  21.                 return;  
  22.             }  
  23.             out.writeBytes(msg);  
  24.         }  
  25.     }  
  26.       
  27.   
  28.      
  29. }  

 解碼器：

 

 

Java代碼   收藏代碼
  1. /* 
  2.  * Copyright (C) TD Tech<br> 
  3.  * All Rights Reserved.<br> 
  4.  *  
  5.  */  
  6. package main.java.com.nionetty.client;  
  7.   
  8. import io.netty.buffer.ByteBuf;  
  9. import io.netty.channel.ChannelHandlerContext;  
  10. import io.netty.handler.codec.ByteToMessageDecoder;  
  11.   
  12. import java.nio.ByteBuffer;  
  13. import java.util.List;  
  14.   
  15. /** 
  16.  * Create Date: 2014-11-4 下午02:42:21<br> 
  17.  * Create Author: lWX232692<br> 
  18.  * Description : 
  19.  */  
  20. public class MyClientDecoder extends ByteToMessageDecoder {  
  21.   
  22.   
  23.     @Override  
  24.     protected void decode(ChannelHandlerContext ctx, ByteBuf buffer,  
  25.             List<Object> out) throws Exception {  
  26.         //UnpooledUnsafeDirectByteBuf(ridx: 0, widx: 1, cap: 1024)  
  27.         if (buffer != null) {  
  28.             ByteBuffer msg = null;  
  29.             try {  
  30.                 if(buffer.readableBytes() > 0 ){  
  31.                     msg = ByteBuffer.allocate(buffer.readableBytes()) ;  
  32.                     byte[] bb = new byte[buffer.readableBytes()] ;  
  33.                     buffer.readBytes(bb) ;  
  34.                     msg.put(bb);  
  35.                     msg.flip();  
  36.                 }  
  37.             } catch (Exception e) {  
  38.                 e.printStackTrace();  
  39.                 msg = null ;  
  40.             }  
  41.             if (msg != null) {  
  42.                 out.add(msg);  
  43.             }  
  44.         }  
  45.     }  
  46.   
  47.   
  48. }  

 業務handler:

Java代碼   收藏代碼
  1. /* 
  2.  * Copyright (C) TD Tech<br> 
  3.  * All Rights Reserved.<br> 
  4.  *  
  5.  */  
  6. package main.java.com.nionetty.client;  
  7.   
  8. import io.netty.buffer.ByteBuf;  
  9. import io.netty.channel.ChannelHandlerContext;  
  10. import io.netty.handler.codec.ByteToMessageDecoder;  
  11.   
  12. import java.nio.ByteBuffer;  
  13. import java.util.List;  
  14.   
  15. /** 
  16.  * Create Date: 2014-11-4 下午02:42:21<br> 
  17.  * Create Author: lWX232692<br> 
  18.  * Description : 
  19.  */  
  20. public class MyClientDecoder extends ByteToMessageDecoder {  
  21.   
  22.   
  23.     @Override  
  24.     protected void decode(ChannelHandlerContext ctx, ByteBuf buffer,  
  25.             List<Object> out) throws Exception {  
  26.         //UnpooledUnsafeDirectByteBuf(ridx: 0, widx: 1, cap: 1024)  
  27.         if (buffer != null) {  
  28.             ByteBuffer msg = null;  
  29.             try {  
  30.                 if(buffer.readableBytes() > 0 ){  
  31.                     msg = ByteBuffer.allocate(buffer.readableBytes()) ;  
  32.                     byte[] bb = new byte[buffer.readableBytes()] ;  
  33.                     buffer.readBytes(bb) ;  
  34.                     msg.put(bb);  
  35.                     msg.flip();  
  36.                 }  
  37.             } catch (Exception e) {  
  38.                 e.printStackTrace();  
  39.                 msg = null ;  
  40.             }  
  41.             if (msg != null) {  
  42.                 out.add(msg);  
  43.             }  
  44.         }  
  45.     }  
  46.   
  47.   
  48. }  

 測試經過，搞了由於在網上沒有找到完整的實例，因此由於一個小問題，找了兩天都沒有找到緣由，但願看到的同窗可以有所收穫

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程