• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            2012年4月13日

            一、簡(jiǎn)介

            ProtocolBuffer是用于結(jié)構(gòu)化數(shù)據(jù)串行化的靈活、高效、自動(dòng)的方法,有如XML,不過(guò)它更小、更快、也更簡(jiǎn)單。你可以定義自己的數(shù)據(jù)結(jié)構(gòu),然后使用代碼生成器生成的代碼來(lái)讀寫這個(gè)數(shù)據(jù)結(jié)構(gòu)。你甚至可以在無(wú)需重新部署程序的情況下更新數(shù)據(jù)結(jié)構(gòu)。

            二、特點(diǎn)

            ProtocolBuffer擁有多項(xiàng)比XML更高級(jí)的串行化結(jié)構(gòu)數(shù)據(jù)的特性,ProtocolBuffer

            ·   更簡(jiǎn)單

            ·   3-10

            ·   20-100

            ·   更少的歧義

            ·   可以方便的生成數(shù)據(jù)存取類

            例如,讓我們看看如何在XML中建模Personnameemail字段:

            <person>
                <name>John Doe</name>
                <email>jdoe@example.com</email>
            </person>

            對(duì)應(yīng)的ProtocolBuffer報(bào)文則如下:

            #ProtocolBuffer的文本表示
            #
            這不是正常時(shí)使用的二進(jìn)制數(shù)據(jù)
            person {
                name: "John Doe"
                email: "jdoe@example.com"
            }

            三、開發(fā)步驟

            1、下載包( http://code.google.com/p/protobuf/downloads/ ),包含了JavaPythonC++ProtocolBuffer編譯器,用于生成你需要的IO類。構(gòu)建和安裝你的編譯器,跟隨README的指令就可以做到。

            一旦你安裝好了,就可以跟著編程指導(dǎo)( http://code.google.com/apis/protocolbuffers/docs/tutorials.html )來(lái)選擇語(yǔ)言-隨后就是使用ProtocolBuffer創(chuàng)建一個(gè)簡(jiǎn)單的應(yīng)用了。

            2、創(chuàng)建. proto文件,文件中定義你需要做串行化的數(shù)據(jù)結(jié)構(gòu)信息,下面定義個(gè)Order. Proto

            package xquant;
            option java_package = "com.xquant";
            option java_outer_classname = "Order";
             
            message Order {
              required int32 action = 1;
              required string serialNo = 2;        
              required string version = 3;
              optional string operator = 4;
              required string code = 5;
              required string name = 6;
              required string price = 7;
              required string amount = 8;
            }

             

             

            3、使用googleprotoc.exe生成對(duì)應(yīng)的C++文件,在CMD命令框中輸入如下命令(路徑根據(jù)實(shí)際情況修改):

            F:\projects\c++\protobuf-2.4.1\examples>protoc --cpp_out=F:\projects\c++\protobu

            f-2.4.1\examples order.proto

            生成文件:

            order.pb.h

            order.pb.cc

            4、新建C++工程Demo,把order.pb.horder.pb.cc加入工程中,添加lib庫(kù)

            #   pragma comment(lib, "libprotobuf.lib")

            代碼如下:

             

            #include "stdafx.h"
            #include <iostream>
            #include <fstream>
            #include <string>
            #include "order.pb.h"
            using namespace std;
             
            void initOrder(xquant::Order* order) {
              order->set_action(100);
              order->set_serialno("100abc");       
              order->set_version("1.00.003");
              string code = "TF0001";
              order->set_code(code);
              string name = "test";
              order->set_name(name);
              order->set_price("10.01");
              order->set_amount("10000000.00");
            }
             
            int _tmain(int argc, _TCHAR* argv[])
            {
                     GOOGLE_PROTOBUF_VERIFY_VERSION;
             
                     // 組裝報(bào)文
                     xquant::Order order;
                     initOrder(&order);
             
                     // 對(duì)象序列化為string
                     string order_str;
                     order.SerializeToString(&order_str);
                     cout << order_str << endl;
                     // 顯示調(diào)式報(bào)文
                     string order_debug = order.DebugString();
                     cout << order_debug << endl;
             
                     // string反序列化為對(duì)象
                     xquant::Order order_2;
                     order_2.ParseFromString(order_str);
                     cout << order_2.code() << endl;
                     cout << order_2.name() << endl;
             
                     google::protobuf::ShutdownProtobufLibrary();
             
                     getchar();
             
                     return 0;
            }

             

             

            posted @ 2012-04-13 11:25 chugf 閱讀(8485) | 評(píng)論 (2)編輯 收藏


            2011年7月5日

            Java與C++通訊還有編碼轉(zhuǎn)碼的問(wèn)題存在,假設(shè)通訊編碼采用UTF-8

            C++客戶端發(fā)送時(shí)需要轉(zhuǎn)碼成UTF-8編碼,接收服務(wù)端應(yīng)答消息后再轉(zhuǎn)回Unicode或者GBK編碼

            下面給出完成的C++客戶端通訊示例:

            void Transcoding(LPCTSTR src, UINT srcCode, string& dest, UINT destCode)   
            {   
                
            int len = MultiByteToWideChar(srcCode, 0, src, -1, NULL, 0);     
                WCHAR
            * srcTemp = new WCHAR[len];     
                MultiByteToWideChar(srcCode, 
            0, src, -1, srcTemp, len);     
                len 
            = WideCharToMultiByte(destCode, 0, srcTemp, -1, NULL, 0, NULL, NULL);     
                
            char* destTemp = new char[len];     
                WideCharToMultiByte(destCode, 
            0, srcTemp, -1, destTemp, len, NULL, NULL);     
              
                dest 
            = destTemp;   
              
                delete []srcTemp;     
                delete []destTemp;     
            }  
              
            int _tmain(int argc, _TCHAR* argv[])  
            {  
                
            // client connect  
                CXSocket client;  
                client.initWinSocket();  
                client.setAddress(
            "127.0.0.1");  
                client.setPort(
            1234);  
                client.setProtoType(TCP);  
                
            int ret = client.connect();  
                
            if(ret < 0)  
                {  
                    getchar();  
                    
            return 0;  
                }  
              
                
            // 加通訊協(xié)議頭demo  
                
            // client send  
                char send[] = {"CXSocket 第一個(gè)測(cè)試用例."};  
              
                
            string utf8;  
                Transcoding(send, CP_ACP, utf8, CP_UTF8);  
              
                XNET::TPacketHeader sendHeader;  
                sendHeader.m_HeaderSig 
            = 0xABCD;  
                swap_2(sendHeader.m_HeaderSig);  
                sendHeader.m_Length 
            = (int)utf8.length();  
                swap_4(sendHeader.m_Length);  
              
                
            char buffer[1024= {0};  
                memcpy(buffer, 
            &sendHeader, XNET::TCP_HEADLEN);  
                memcpy(
            &buffer[XNET::TCP_HEADLEN], utf8.c_str(), utf8.length());  
                client.sendBuf(buffer, (
            int)(XNET::TCP_HEADLEN + utf8.length()));  
              
                
            // client recv  
                XNET::TPacketHeader recvHeader;  
                client.receiveBuf(
            &recvHeader, XNET::TCP_HEADLEN);  
                swap_2(recvHeader.m_HeaderSig);  
                swap_4(recvHeader.m_Length);  
                
            char* recv = new char[recvHeader.m_Length + 1];  
                memset(recv, 
            0, recvHeader.m_Length + 1);  
                client.receiveBuf(recv, recvHeader.m_Length);  
                
            string ansi;  
                Transcoding(recv, CP_UTF8, ansi, CP_ACP);  
              
                client.close();  
                client.uninitWinSocket();  
              
                getchar();  
              
                
            return 0;  
            }  

            CXSocket類下載地址:http://code.google.com/p/x-net/

            MINA服務(wù)端Demo下載地址:http://download.csdn.net/source/3418326

            posted @ 2011-07-05 15:31 chugf 閱讀(3444) | 評(píng)論 (5)編輯 收藏

            最近學(xué)習(xí)了Apache MINA通訊,在使用過(guò)程中碰到了一些問(wèn)題,記錄下一些心得。

            在服務(wù)端和客戶端都使用MINA提供的庫(kù)時(shí),通訊一切正常,當(dāng)我把客戶端改為C++代碼時(shí),發(fā)現(xiàn)客戶端發(fā)送給服務(wù)端的二進(jìn)制流中的整形數(shù)據(jù),位置被倒置了。

            C++客戶端16進(jìn)制  :0x00000013

            MINA服務(wù)端16進(jìn)制:0x13000000

            查詢了網(wǎng)上資料后才知道Java在所有平臺(tái)上都默認(rèn)是big-endian,而C++在不同的平臺(tái)上有不同的字節(jié)序, X86上是little-endian, solaris上是big-endian。

            注意問(wèn)題:

            1、字節(jié)序

            C++在不同的平臺(tái)上有不同的字節(jié)序, X86上是little-endian, solaris上是big-endian; 而java在所有平臺(tái)上都默認(rèn)是big-endian, 所以在傳輸諸如short,int,long數(shù)據(jù)時(shí)要在C++轉(zhuǎn)換成網(wǎng)絡(luò)序(big-endian)
            2、字符編碼

            C++上最普遍的是采用mbcs, 而java上是用unicode(并且和標(biāo)準(zhǔn)的unicode還有些區(qū)別,可以參考java文檔), 所以除非必須否則不要傳字符串, 可以傳文本文件代替, 一定要傳的話只能自己轉(zhuǎn)換了
            3、 內(nèi)存對(duì)齊, 在C/C++的網(wǎng)絡(luò)通信程序中經(jīng)常采用讀寫結(jié)構(gòu)體的方式方便地交換數(shù)據(jù), 但是不注意的話結(jié)構(gòu)體內(nèi)很可能有空隙, 比如struct A{ int a; char c }; struct B{ char a; int b }; 這兩個(gè)結(jié)構(gòu)體內(nèi)都有空隙, 而如果不說(shuō)明空隙的存在java程序是不會(huì)知道的, 就會(huì)導(dǎo)致雙方解析時(shí)出錯(cuò). 要消除空隙應(yīng)該小心地安排結(jié)構(gòu)體的成員, 不推薦使用#pragma pach(1), 因?yàn)闆]有通用性
            4、 位域

            除非小心安排, 否則位域?qū)е碌慕Y(jié)構(gòu)體大小與平臺(tái)相關(guān), int a:4所占用的字節(jié)隨平臺(tái)和編譯器變化(char a:4相對(duì)穩(wěn)定占1字節(jié))
            5、 (可能平臺(tái)相關(guān))傳送與接收速度不同
            當(dāng)C++向java傳送一個(gè)大一些的數(shù)據(jù)時(shí), 可能C++一邊已經(jīng)傳完退出了, 而java那邊還沒收完, 導(dǎo)致最后的一部分?jǐn)?shù)據(jù)丟失. 所以項(xiàng)目中采用了簡(jiǎn)單的確認(rèn)機(jī)制, 任何一方接收完數(shù)據(jù)就回送1字節(jié)的確認(rèn), 以防止C++過(guò)早退出

            6、(可能平臺(tái)相關(guān))java在同C++建立連接后以及在C++向java傳送完一段數(shù)據(jù)后, java若向C++傳送一段數(shù)據(jù)則第一次傳送的數(shù)據(jù)C++只能收到一個(gè)字節(jié), 第一次過(guò)后恢復(fù)正常


            C++整形轉(zhuǎn)換代碼如下:

            void swap_4(unsigned long &x)  
            {  
                x 
            = (x << 24|  
                ((x 
            << 8& 0x00ff0000u|  
                ((x 
            >> 8& 0x0000ff00u|  
                (x 
            >> 24);  
            }  
              
            int _tmain(int argc, _TCHAR* argv[])  
            {  
                   
                 unsigned 
            long len = 19;  
                 swap_4(len);  
            }

            posted @ 2011-07-05 15:27 chugf 閱讀(4002) | 評(píng)論 (2)編輯 收藏


            2011年7月4日

            關(guān)于IOCP完成端口的介紹有很多,這里就不介紹概念了。

            如果不考慮跨平臺(tái)問(wèn)題,在Windows下IOCP(I/O Completion Port,I/O完成端口)是性能最好的一種I/O模型。

            以下是本人開發(fā)的IO完成端口服務(wù)器/客戶端介紹:

            名稱:x-net

            版本:1.0.0

            特點(diǎn):針對(duì)TCP網(wǎng)絡(luò)通訊進(jìn)行封裝,使用widows下效率最高的IOCP通訊方式,工程包括服務(wù)端和客戶端。
                  可應(yīng)用于即時(shí)網(wǎng)絡(luò)通訊、跨平臺(tái)網(wǎng)絡(luò)通訊等。
            功能:
                  1、支持多用戶并發(fā)連接通訊,理論支持10000+在線用戶,實(shí)際運(yùn)行5000+左右
                  2、支持自定義通訊頭協(xié)議,代碼里實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的組包拆包功能
                  3、支持轉(zhuǎn)發(fā)通訊包服務(wù)
                  4、支持文件下載上傳

            說(shuō)明:
            使用了開源日志庫(kù)log4cplus,網(wǎng)址:http://log4cplus.sourceforge.net/
            簡(jiǎn)單用例見test目錄:
            test.vcxproj             -- VS2010工程
            test_2005.vcproj   -- VS2005工程

            源代碼下載地址:http://code.google.com/p/x-net/

            posted @ 2011-07-04 11:40 chugf 閱讀(4155) | 評(píng)論 (13)編輯 收藏


            2011年6月24日

            個(gè)人覺得比較經(jīng)典的C++ 開源項(xiàng)目,整理如下:

             

            1 log4cplus

            log4cplus 是C++ 編寫的開源的日志系統(tǒng), 功能非常全面。C++ 版的log4j

            網(wǎng)址:http://log4cplus.sourceforge.net/

             

            2 Glog

            Google Glog 是一個(gè)C++ 語(yǔ)言的應(yīng)用級(jí)日志記錄框架,提供了 C++ 風(fēng)格的流操作和各種助手宏。

            SVN :http://google-glog.googlecode.com/svn/trunk

             

            3 memcached

            memcached 是一套分布式的快取系統(tǒng),當(dāng)初是Danga Interactive 為了LiveJournal 所發(fā)展的,但目前被許多軟件(如MediaWiki )所使用。這是一套開放源代碼軟件,以BSD license 授權(quán)釋出。

            memcached 缺乏認(rèn)證以及安全管制,這代表應(yīng)該將memcached 服務(wù)器放置在防火墻后。

            SVN :http://code.sixapart.com/svn/memcached

             


            4 
             TinyXML

            TinyXML 是目前非常流行的一款基于DOM 模型的XML 解析器,簡(jiǎn)單易用且小巧 玲瓏,非常適合存儲(chǔ)簡(jiǎn)單數(shù)據(jù),配置文件,對(duì)象序列化等數(shù)據(jù)量不是很大的操作

            網(wǎng)址:http://www.grinninglizard.com/tinyxml/

             

            5 OpenSSL

            OpenSSL 包含一個(gè)命令行工具用來(lái)完成OpenSSL 庫(kù)中的所有功能,更好的是,它可能已經(jīng)安裝到你的系統(tǒng)中了。

            OpenSSL 是一個(gè)強(qiáng)大的安全套接字層密碼庫(kù),Apache 使用它加密HTTPS ,OpenSSH 使用它加密SSH ,但是,你不應(yīng)該只將其作為一個(gè)庫(kù)來(lái)使用,它還是一個(gè)多用途的、跨平臺(tái)的密碼工具。

            網(wǎng)址:http://www.openssl.org/source/

             

            6 xerces

            Xerces是由Apache組織所推動(dòng)的一項(xiàng)XML文檔解析開源項(xiàng)目,它目前有多種語(yǔ)言版本包括JAVA、C++、PERL、COM等。

              網(wǎng)址http://xerces.apache.org/xerces-c/download.cgi

             

            7 Boost

            Boost 庫(kù)是一個(gè)經(jīng)過(guò)千錘百煉、可移植、提供源代碼的C++ 庫(kù),作為標(biāo)準(zhǔn)庫(kù)的后備,是C++ 標(biāo)準(zhǔn)化進(jìn)程的發(fā)動(dòng)機(jī)之一。 Boost 庫(kù)由C++標(biāo)準(zhǔn)委員會(huì)庫(kù)工作組成員發(fā)起,在C++ 社區(qū)中影響甚大,其成員已近2000 人。 Boost 庫(kù)為我們帶來(lái)了最新、最酷、最實(shí)用的技術(shù),是不折不扣的 準(zhǔn) 標(biāo)準(zhǔn)庫(kù)。

            網(wǎng)址:http://www.boost.org/


            8、Zlib

            Zlib 軟件包包含 zlib 庫(kù),很多程序中的壓縮或者解壓縮函數(shù)都會(huì)用到這個(gè)庫(kù)

            網(wǎng)址:http://www.zlib.net/

             

            posted @ 2011-06-24 13:59 chugf 閱讀(3677) | 評(píng)論 (1)編輯 收藏


            僅列出標(biāo)題  

            posts - 5, comments - 22, trackbacks - 0, articles - 0

            Copyright © chugf

            久久亚洲精品国产精品婷婷| 一本色道久久HEZYO无码| 久久青青草原精品国产软件| 中文精品久久久久人妻不卡| 99久久夜色精品国产网站| 一级女性全黄久久生活片免费 | 国产精品九九九久久九九| 久久久精品视频免费观看| 久久亚洲精精品中文字幕| 亚洲国产成人久久一区久久 | 日本加勒比久久精品| 久久久久久国产精品免费无码| 精品久久人人妻人人做精品| 亚洲色欲久久久综合网| 久久久久一本毛久久久| 国产午夜精品理论片久久影视| 国产精品久久久久蜜芽| 久久精品国产亚洲一区二区三区| 国产精品久久久久久久久鸭| 77777亚洲午夜久久多喷| 色偷偷88欧美精品久久久| 国产成人AV综合久久| 999久久久无码国产精品| 亚洲精品乱码久久久久久蜜桃不卡 | 久久福利青草精品资源站| 亚洲国产精品无码久久| 欧美国产成人久久精品| 亚洲国产成人精品女人久久久| 99热精品久久只有精品| 精品久久777| 青青草国产精品久久| 久久综合久久久| 亚洲国产精品久久久久久| 日本三级久久网| 久久免费线看线看| 91精品国产高清久久久久久91| 国产产无码乱码精品久久鸭| 久久久久久无码Av成人影院| 国内精品久久久久久99| 国产婷婷成人久久Av免费高清| 国产精品久久久久久久久|