国产免费久久精品99久久,精产国品久久一二三产区区别 ,色综合久久88色综合天天

Google ProtoBuf開發示例

一、簡介

ProtocolBuffer是用于結構化數據串行化的靈活、高效、自動的方法，有如XML，不過它更小、更快、也更簡單。你可以定義自己的數據結構，然后使用代碼生成器生成的代碼來讀寫這個數據結構。你甚至可以在無需重新部署程序的情況下更新數據結構。

二、特點

ProtocolBuffer擁有多項比XML更高級的串行化結構數據的特性，ProtocolBuffer：

· 更簡單

· 小3-10倍

· 快20-100倍

· 更少的歧義

· 可以方便的生成數據存取類

例如，讓我們看看如何在XML中建模Person的name和email字段:

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

對應的ProtocolBuffer報文則如下:

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

三、開發步驟

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

一旦你安裝好了，就可以跟著編程指導( http://code.google.com/apis/protocolbuffers/docs/tutorials.html )來選擇語言-隨后就是使用ProtocolBuffer創建一個簡單的應用了。

2、創建. proto文件，文件中定義你需要做串行化的數據結構信息，下面定義個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、使用google的protoc.exe生成對應的C++文件，在CMD命令框中輸入如下命令（路徑根據實際情況修改）：

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.h和order.pb.cc加入工程中，添加lib庫

# 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;

         // 組裝報文
         xquant::Order order;
         initOrder(&order);

         // 對象序列化為string
         string order_str;
         order.SerializeToString(&order_str);
         cout << order_str << endl;
         // 顯示調式報文
         string order_debug = order.DebugString();
         cout << order_debug << endl;

         // string反序列化為對象
         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) | 評論 (2) | 編輯收藏

MINA服務端與C++客戶端通訊（2）

Java與C++通訊還有編碼轉碼的問題存在，假設通訊編碼采用UTF-8

C++客戶端發送時需要轉碼成UTF-8編碼，接收服務端應答消息后再轉回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;
    }

    // 加通訊協議頭demo
    // client send
    char send[] = {"CXSocket 第一個測試用例."};

    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服務端Demo下載地址：http://download.csdn.net/source/3418326

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

MINA服務端與C++客戶端通訊（1）

最近學習了Apache MINA通訊，在使用過程中碰到了一些問題，記錄下一些心得。

在服務端和客戶端都使用MINA提供的庫時，通訊一切正常，當我把客戶端改為C++代碼時，發現客戶端發送給服務端的二進制流中的整形數據，位置被倒置了。

C++客戶端16進制：0x00000013

MINA服務端16進制：0x13000000

查詢了網上資料后才知道Java在所有平臺上都默認是big-endian，而C++在不同的平臺上有不同的字節序, X86上是little-endian, solaris上是big-endian。

注意問題：

1、字節序

C++在不同的平臺上有不同的字節序, X86上是little-endian, solaris上是big-endian; 而java在所有平臺上都默認是big-endian, 所以在傳輸諸如short,int,long數據時要在C++轉換成網絡序(big-endian)
2、字符編碼

C++上最普遍的是采用mbcs, 而java上是用unicode(并且和標準的unicode還有些區別,可以參考java文檔), 所以除非必須否則不要傳字符串, 可以傳文本文件代替, 一定要傳的話只能自己轉換了
3、內存對齊, 在C/C++的網絡通信程序中經常采用讀寫結構體的方式方便地交換數據, 但是不注意的話結構體內很可能有空隙, 比如struct A{ int a; char c }; struct B{ char a; int b }; 這兩個結構體內都有空隙, 而如果不說明空隙的存在java程序是不會知道的, 就會導致雙方解析時出錯. 要消除空隙應該小心地安排結構體的成員, 不推薦使用#pragma pach(1), 因為沒有通用性
4、位域

除非小心安排, 否則位域導致的結構體大小與平臺相關, int a:4所占用的字節隨平臺和編譯器變化(char a:4相對穩定占1字節)
5、 (可能平臺相關)傳送與接收速度不同當C++向java傳送一個大一些的數據時, 可能C++一邊已經傳完退出了, 而java那邊還沒收完, 導致最后的一部分數據丟失. 所以項目中采用了簡單的確認機制, 任何一方接收完數據就回送1字節的確認, 以防止C++過早退出

6、(可能平臺相關)java在同C++建立連接后以及在C++向java傳送完一段數據后, java若向C++傳送一段數據則第一次傳送的數據C++只能收到一個字節, 第一次過后恢復正常

C++整形轉換代碼如下：

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 閱讀(4001) | 評論 (2) | 編輯收藏

IOCP完成端口源代碼

關于IOCP完成端口的介紹有很多，這里就不介紹概念了。

如果不考慮跨平臺問題，在Windows下IOCP（I/O Completion Port，I/O完成端口）是性能最好的一種I/O模型。

以下是本人開發的IO完成端口服務器/客戶端介紹：

名稱：x-net

版本：1.0.0

特點：針對TCP網絡通訊進行封裝，使用widows下效率最高的IOCP通訊方式，工程包括服務端和客戶端。
可應用于即時網絡通訊、跨平臺網絡通訊等。
功能：
1、支持多用戶并發連接通訊，理論支持10000+在線用戶，實際運行5000+左右
2、支持自定義通訊頭協議，代碼里實現了一個簡單的組包拆包功能
3、支持轉發通訊包服務
4、支持文件下載上傳

說明:
使用了開源日志庫log4cplus，網址：http://log4cplus.sourceforge.net/
簡單用例見test目錄：
test.vcxproj -- VS2010工程
test_2005.vcproj -- VS2005工程

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

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

C++經典開源項目

個人覺得比較經典的C++ 開源項目，整理如下：

1 、log4cplus

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

網址：http://log4cplus.sourceforge.net/

2 、Glog

Google Glog 是一個C++ 語言的應用級日志記錄框架，提供了 C++ 風格的流操作和各種助手宏。

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

3 、memcached

memcached 是一套分布式的快取系統，當初是Danga Interactive 為了LiveJournal 所發展的，但目前被許多軟件（如MediaWiki ）所使用。這是一套開放源代碼軟件，以BSD license 授權釋出。

memcached 缺乏認證以及安全管制，這代表應該將memcached 服務器放置在防火墻后。

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

4 、 TinyXML

TinyXML 是目前非常流行的一款基于DOM 模型的XML 解析器，簡單易用且小巧玲瓏，非常適合存儲簡單數據，配置文件，對象序列化等數據量不是很大的操作

網址：http://www.grinninglizard.com/tinyxml/

5 、OpenSSL

OpenSSL 包含一個命令行工具用來完成OpenSSL 庫中的所有功能，更好的是，它可能已經安裝到你的系統中了。

OpenSSL 是一個強大的安全套接字層密碼庫，Apache 使用它加密HTTPS ，OpenSSH 使用它加密SSH ，但是，你不應該只將其作為一個庫來使用，它還是一個多用途的、跨平臺的密碼工具。

網址：http://www.openssl.org/source/

6 、xerces

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

網址：http://xerces.apache.org/xerces-c/download.cgi

7 、Boost

Boost 庫是一個經過千錘百煉、可移植、提供源代碼的C++ 庫，作為標準庫的后備，是C++ 標準化進程的發動機之一。 Boost 庫由C++標準委員會庫工作組成員發起，在C++ 社區中影響甚大，其成員已近2000 人。 Boost 庫為我們帶來了最新、最酷、最實用的技術，是不折不扣的“ 準” 標準庫。

網址：http://www.boost.org/

8、Zlib

Zlib 軟件包包含 zlib 庫，很多程序中的壓縮或者解壓縮函數都會用到這個庫

網址：http://www.zlib.net/

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

國風的Blog

隨筆檔案

最新隨筆

最新評論

2012年4月13日

Google ProtoBuf開發示例

2011年7月5日

MINA服務端與C++客戶端通訊（2）

MINA服務端與C++客戶端通訊（1）

2011年7月4日

IOCP完成端口源代碼

2011年6月24日

C++經典開源項目

常用鏈接

我參與的團隊

評論排行榜

閱讀排行榜