2. 程式人生 > >netty9---使用編碼解碼器

netty9---使用編碼解碼器

阿新 • • 發佈：2018-05-20
-- 定義 work etc ddr RR ech channel urn

客戶端：

package com.client;

import java.net.InetSocketAddress;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.jboss.netty.bootstrap.ClientBootstrap;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFuture;

 
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
import com.cn.codc.RequestEncoder;
import com.cn.codc.ResponseDecoder;
import com.cn.model.Request;

 
import com.cn.module.fuben.request.FightRequest;
/**
 * netty客戶端入門
 */
public class Client {

    public static void main(String[] args) throws InterruptedException {
        
        //服務類
        ClientBootstrap bootstrap = new  ClientBootstrap();
        
        //線程池
        ExecutorService boss = Executors.newCachedThreadPool();
        ExecutorService worker 
 
= Executors.newCachedThreadPool();
        
        //socket工廠
        bootstrap.setFactory(new NioClientSocketChannelFactory(boss, worker));
        
        //管道工廠
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            
            @Override
            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline pipeline = Channels.pipeline();
                pipeline.addLast("decoder", new ResponseDecoder());//Response解碼器
                pipeline.addLast("encoder", new RequestEncoder());//Request編碼器
                pipeline.addLast("hiHandler", new HiHandler());//通過ResponseDecoder解碼的是一個Response對象。
                return pipeline;
            }
        });
        
        //連接服務端
        ChannelFuture connect = bootstrap.connect(new InetSocketAddress("127.0.0.1", 10101));
        Channel channel = connect.sync().getChannel();
        
        System.out.println("client start");
        
        Scanner scanner = new Scanner(System.in);
        while(true){
            System.out.println("請輸入");
            int fubenId = Integer.parseInt(scanner.nextLine());
            int count = Integer.parseInt(scanner.nextLine());
            
            FightRequest fightRequest = new FightRequest();
            fightRequest.setFubenId(fubenId);
            fightRequest.setCount(count);
            
            Request request = new Request();
            request.setModule((short) 1);//請求第一個模塊的
            request.setCmd((short) 1);
            request.setData(fightRequest.getBytes());//fightRequest是數據體data
            //發送請求
            channel.write(request);
        }
    }

}
package com.client;

import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.channel.ExceptionEvent;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelHandler;

import com.cn.model.Response;
import com.cn.model.StateCode;
import com.cn.module.fuben.request.FightRequest;
import com.cn.module.fuben.response.FightResponse;
/**
 * 消息接受處理類
 */
public class HiHandler extends SimpleChannelHandler {

    /**
     * 接收消息
     */
    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
            Response message = (Response)e.getMessage();//解碼出來的之後是Response對象，然後進行業務處理

            if(message.getModule() == 1){
                
                if(message.getCmd() == 1){
                    FightResponse fightResponse = new FightResponse();
                    fightResponse.readFromBytes(message.getData());
                    
                    System.out.println("gold:" + fightResponse.getGold());
                    
                }else if(message.getCmd() == 2){
                    
                }
                
            }else if (message.getModule() == 1){
                
                
            }
    }

    /**
     * 捕獲異常
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
        System.out.println("exceptionCaught");
        super.exceptionCaught(ctx, e);
    }

    /**
     * 新連接
     */
    @Override
    public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelConnected");
        super.channelConnected(ctx, e);
    }

    /**
     * 必須是鏈接已經建立，關閉通道的時候才會觸發
     */
    @Override
    public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelDisconnected");
        super.channelDisconnected(ctx, e);
    }

    /**
     * channel關閉的時候觸發
     */
    @Override
    public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelClosed");
        super.channelClosed(ctx, e);
    }
}

服務端：

package com.server;

import java.net.InetSocketAddress;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.jboss.netty.bootstrap.ServerBootstrap;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
import org.jboss.netty.handler.codec.string.StringDecoder;
import org.jboss.netty.handler.codec.string.StringEncoder;

import com.cn.codc.RequestDecoder;
import com.cn.codc.ResponseEncoder;
/**
 * netty服務端入門
 */
public class Server {

    public static void main(String[] args) {

        //服務類
        ServerBootstrap bootstrap = new ServerBootstrap();
        
        //boss線程監聽端口，worker線程負責數據讀寫
        ExecutorService boss = Executors.newCachedThreadPool();
        ExecutorService worker = Executors.newCachedThreadPool();
        
        //設置niosocket工廠
        bootstrap.setFactory(new NioServerSocketChannelFactory(boss, worker));
        
        //設置管道的工廠
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            
            @Override
            public ChannelPipeline getPipeline() throws Exception {

                ChannelPipeline pipeline = Channels.pipeline();
                pipeline.addLast("decoder", new RequestDecoder());//Request的解碼器
                pipeline.addLast("encoder", new ResponseEncoder());//Response的編碼器
                pipeline.addLast("helloHandler", new HelloHandler());
                return pipeline;
            }
        });
        bootstrap.bind(new InetSocketAddress(10101));
        System.out.println("start!!!");
    }
}
package com.server;

import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.channel.ExceptionEvent;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelHandler;

import com.cn.model.Request;
import com.cn.model.Response;
import com.cn.model.StateCode;
import com.cn.module.fuben.request.FightRequest;
import com.cn.module.fuben.response.FightResponse;
/**
 * 消息接受處理類
 */
public class HelloHandler extends SimpleChannelHandler {

    /**
     * 接收消息
     */
    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {

        Request message = (Request)e.getMessage();
        
        if(message.getModule() == 1){
            
            if(message.getCmd() == 1){
                
                FightRequest fightRequest = new FightRequest();
                fightRequest.readFromBytes(message.getData());
                
                System.out.println("fubenId:" +fightRequest.getFubenId() + "   " + "count:" + fightRequest.getCount());
                
                //回寫數據
                FightResponse fightResponse = new FightResponse();
                fightResponse.setGold(9999);
                
                Response response = new Response();
                response.setModule((short) 1);
                response.setCmd((short) 1);
                response.setStateCode(StateCode.SUCCESS);
                response.setData(fightResponse.getBytes());
                ctx.getChannel().write(response);
            }else if(message.getCmd() == 2){
            }
        }else if (message.getModule() == 1){
        }
    }

    /**
     * 捕獲異常
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
        System.out.println("exceptionCaught");
        super.exceptionCaught(ctx, e);
    }

    /**
     * 新連接
     */
    @Override
    public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelConnected");
        super.channelConnected(ctx, e);
    }

    /**
     * 必須是鏈接已經建立，關閉通道的時候才會觸發
     */
    @Override
    public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelDisconnected");
        super.channelDisconnected(ctx, e);
    }

    /**
     * channel關閉的時候觸發
     */
    @Override
    public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
        System.out.println("channelClosed");
        super.channelClosed(ctx, e);
    }
}

網絡傳的是字節數據不是字符。

Netty之自定義數據包協議：
give me a coffee give me a tea (2條信息)

give me a coffeegive me a tea 粘包現象（2條信息粘在一起）

give me
a coffeegive me a tea 分包現象（第一條消息分開了，第一條後部分又粘到了第二條消息）

粘包和分包出現的原因是：沒有一個穩定數據結構（沒有確定一個請求傳遞哪些數據）

分割符：
give me a coffee|give me a tea|
give me a coffee|
give me a tea|

長度 + 數據：
16give me a coffee13give me a tea（讀取16個就封裝成一個請求，投遞到業務層去）
16give me a coffee
13give me a tea

netty9---使用編碼解碼器

相關推薦

netty9---使用編碼解碼器

-- 定義 work etc ddr RR ech channel urn 客戶端： package com.client; import java.net.InetSocketAddress; import java.util.Scanner; import java

機器學習（ML）十二之編碼解碼器、束搜尋與注意力機制

編碼器—解碼器（seq2seq） 在自然語言處理的很多應用中，輸入和輸出都可以是不定長序列。以機器翻譯為例，輸入可以是一段不定長的英語文字序列，輸出可以是一段不定長的法語文字序列，例如 英語輸入：“They”、“are”、“watching”、“.” 法語輸出：“Ils”、“regardent”、“.”

seq2seq編碼器與解碼器 --學習筆記

0、網路圖結構 從上圖可以看出，編碼是一個RNN網路，當然可以是一個單向RNN也可以是一個雙向RNN，C是一個context為背景變數，將輸入資訊進行編碼彙總得到一個資訊。接著由這個背景變數作為解碼的輸入，加上隱藏變數和輸出變數，得到結果在進行對映，依次得到序列的每個預測結果。

netty自定義編碼器和解碼器（粘包處理）

這裡的實現方式是：將訊息分為兩部分，也就是訊息頭和訊息尾，訊息頭中寫入要傳送資料的總長度，通常是在訊息頭的第一個欄位使用int值來標識傳送資料的長度。 首先我們寫一個Encoder，我們繼承自Me

編碼器-解碼器模型--本人實現

代碼 bsp 解碼 lee 結構 技術 模型 alt 編碼 看到官方文檔的example實現，Jason Brownlee博士博客。編碼器-解碼器模型，感覺被實現的不好！ 1. 變量命名煩亂； 2. 有大量的重復結構的代碼； 3. 引用遙遠的非全局變量。 反正本人是鼠目寸光

UnicodeEncodeError：'gbk'編解碼器無法對位置43的字元u'\ u200e'進行編碼：非法multib

原連結：HTTP：//www.crifan.com/unicodeencodeerror_gbk_codec_can_not_encode_character_in_position_illegal_multibyte_sequence/【問題】蟒蛇中已獲取網頁：的HTML原

【APACHE MINA2.0開發之二】自定義實現SERVER/CLIENT端的編解碼工廠（自定義編碼與解碼器）！

在上一篇博文中已經簡單介紹過“過濾器”的概念，那麼在Mina 中的協議編解碼器通過過濾器 ProtocolCodecFilter 構造,這個過濾器的構造方法需 要一個 ProtocolCodecFactory,這從前面註冊 TextLineCodecFactory 的程式碼就可以看出來。 Protoc

Java EE HTML5 WebSocket 編碼器與解碼器的例子

至少原文要保留,原味沒有了.也就沒意思了, In this tutorial we will implement a Java EE ServerEndpoint message Encoder and Decoder in order to convert HTML5

seq2seq通俗理解----編碼器和解碼器(TensorFlow實現)

1. 什麼是seq2seq 在⾃然語⾔處理的很多應⽤中，輸⼊和輸出都可以是不定⻓序列。以機器翻譯為例，輸⼊可以是⼀段不定⻓的英語⽂本序列，輸出可以是⼀段不定⻓的法語⽂本序列，例如： 英語輸⼊：“They”、“are”、“watching”、“.” 法語輸出：“Ils”、“regardent”、“.” 當輸⼊和

JS實現—Base64編碼解碼，帶16進制顯示

ech encode break 復制代碼 bre zab idt pts image 代碼如下： <!DOCTYPE html> <html> <head> <meta name="viewport" conte

哈夫曼編碼解碼 C++實現

錯誤 urn using 過程 簡單 cin n) struct ren 哈夫曼編碼是一個通過哈夫曼樹進行的一種編碼，一般情況下，以字符：‘0’與‘1’表示。編碼的實現過程很簡單，只要實現哈夫曼樹，通過遍歷哈夫曼樹，這裏我們從每一個葉子結點開始向上遍歷，如果該結點為父節點的

C++ Builder 源碼：使用 LAV 解碼器的播放器

bsp filters mov 文件 nbsp 支持的格式 spl knowledge aac 這個程序理論上支持所有 LAV 解碼器 (LAVFilters/LAVSplitter) 支持的格式，支持 (不限於) 播放以下後綴的文件： ? 視頻 (*.mkv, *.ts

二維碼解碼器Zbar+VS2010開發環境配置（使用opencv庫）

nbsp () imread cfg 如何配置 lib eight ann dev Zbar條碼解碼器是一個開源的二維碼（包括條形碼）解碼器，可以識別來至於視頻流，圖像文件、手持掃碼器和視頻設備（如攝像頭）等二維碼識別，支持EAN-13/UPC-A, UPC-E, EAN-

C#對字符串進行編碼解碼

odin div 字符串 編碼解碼 odi encode cnblogs 進行 viewbag 以UTF8編碼格式為例： 1 //編碼 2 ViewBag.FileURL = HttpUtility.UrlEncode(UriString, Encoding.UTF8);

ffmpeg實時編碼解碼部分代碼

分代 pac rgb ng- cte qpi truct tcp conn 程序分為編碼端和解碼端，兩端通過tcp socket通信，編碼端一邊編碼一邊將編碼後的數據發送給解碼端。解碼端一邊接收數據一邊將解碼得到的幀顯示出來。 代碼中的編碼端編碼的是實時屏幕截圖

最簡單的基於FFmpeg的移動端樣例：IOS 視頻解碼器

視頻播放 contex avcodec video pad align b+ getc tar =====================================================最簡單的基於FFmpeg的移動端樣例系列文章列表：最簡單的基於FFm

JS對URL字符串進行編碼/解碼分析

rdquo 說明 cbe 字符值 name ide 就會 aca img 雖然escape()、encodeURI()、encodeURIComponent()三種方法都能對一些影響URL完整性的特殊 字符進行過濾。但後兩者是將字符串轉換為UTF-8的方式來傳輸，解決了頁面

常見編碼解碼腳本

table 我們 edi except 函數 運行 div clas href 在平時我們會遇到各種各樣的編碼，在這裏，我總結了一些常見的編碼，並不是很全 嘗試著做了個編碼解碼的匯總，並且寫了個腳本出來，由於python功底不是很強，所以可能會有不到之處，還望各位多多指正

Deep Learning基礎--線性解碼器、卷積、池化

sparse pca 過程 條件 連接 移動 .cn 計算過程 htm 本文主要是學習下Linear Decoder已經在大圖片中經常采用的技術convolution和pooling，分別參考網頁http://deeplearning.stanford.edu/wiki/i

ffmpeg所有的解碼器（decoders）

ffmpeg ffmpeg exe Decoders: V..... = Video(視頻流） A..... = Audio（音頻流） S..... = Subtitle（字幕流） .F.... = Frame-level multithreading ..S... = Slice-level m