Cmake + protobuf-c + python自定义协议通信

mahonglin123456

　　Cmake是一套跨平台的工程构建工具
　　sudo apt-get install cmake
　　一个Cmake的例子
　　生成一个demo工程，包括一个hello.cpp文件（在demo工程下）

#include <stdio.h>
int main(int argc, char **argv)
{
printf("Hello world!\n");
return 0;
}
　　Cmake构建该工程
　　Cmake需要CMakeLists.txt文件来配置，在demo目录下创建CMakeLists.txt文件

PROJECT (Test)
SET(SRC_LIST hello.cpp)
ADD_EXECUTABLE(test ${SRC_LIST})
　　构建项目
　　cmake .
　　便会生成相应的Makefile文件
　　Protobuf
　　安装protobuf-c
　　需要先安装google protobuf
　　http://code.google.com/p/protobuf/downloads/list
　　./configure
　　make
　　make check
　　make install
　　下载
　　http://code.google.com/p/protobuf-c/downloads/list
　　./configure --prefix=$HOME/install
　　make
　　make install
　　A typical reason for this behaviour is a stale ld.so.cache; try to run ldconfig to update it after making sure that /usr/local/lib is listed in /etc/ld.so.conf.
　　make不过时可能需要执行 ldconfig 命令
　　To install into /usr like a normal package would, use --prefix=/usr
　　protobuf-c Simple complete example
　　protobuf-c works by taking a.proto file, and generating both .h and .c files for use in C programs.
　　amessage.proto

message AMessage
{
required int32 a=1;
optional int32 b=2;
}

 　　Generate .h and .c files from the command-line in your current working directory:
　　protoc-c --c_out=. amessage.proto 
　　Serialize/pack Deserialize/upack the AMessage as follows:
　　amessage_demo.c

#include <stdio.h>
#include <stdlib.h>
#include "amessage.pb-c.h"
int main (int argc, const char * argv[])
{
AMessage msg = AMESSAGE__INIT; // AMessage
AMessage *rmsg;
void *buf;                     // Buffer to store serialized data
unsigned len;                  // Length of serialized data
if (argc != 2 && argc != 3)
{   // Allow one or two integers
fprintf(stderr,"usage: amessage a \n");
return 1;
}
msg.a = atoi(argv[1]);                                   // Put an int in msg
if (argc == 3) { msg.has_b = 1; msg.b = atoi(argv[2]); } // Add another
len = amessage__get_packed_size(&msg);                   // This is calculated packing length
buf = malloc(len);        // Allocated memory for packed/encode serialized data
amessage__pack(&msg,buf); // Put it in buf now
fprintf(stderr,"Writing %d serialized bytes\n",len); // See the length of message
fwrite(buf,len,1,stdout); // Write to stdout to allow direct command line piping
rmsg = amessage__unpack(NULL, len, buf);
printf("Received: a=%d", rmsg->a);
printf(" b=%d", rmsg->b);
printf("\n");
amessage__free_unpacked(rmsg, NULL);
free(buf); // Free the allocated serialized buffer
return 0;
}
　　编译：
　　gcc amessage_demo.c amessage.pb-c.c -o amessage_demo -lprotobuf-c
　　效果：
　　./amessage_demo 10 2
　　Writing: 4 serialized bytes
　　Received: a=10 b=2
　　安装protobuf-python环境：
　　cd protobuf目录下python目录
　　python setup.py install
　　Protobuf-c RPC service and Protobuf python client
　　首先写一个结构，重点是加上service这样会生成相应的service方法
　　rpc.proto

package demo;
message SearchRequest {
required string keyword = 1;
}
message SearchResponse {
required string result = 1;
}
service RpcService {
rpc Search (SearchRequest) returns (SearchResponse);
}

 　　在service中要实现的方法
　　ProtobufCService *protbuf_c_rpc_client_new
　　ProtobufC_RPC_Server *protobuf_c_rpc_server_new
　　python实现protobuf rpc
　　protobuf-socket-rpc
　　python protobuf rpc using tcp/ip sockets
　　http://code.google.com/p/protobuf-socket-rpc/downloads/list
　　在源码中有实例
　　Note: 在.proto文件中加入
　　option py_generic_services = true;
　　ruby实现protobuf rpc
　　gem install ruby_protobuf
　　rpc.proto

package demo;
message SearchRequest {
required string keyword = 1;
}
message SearchResponse {
required string result = 1;
}
service RpcService {
rpc Search (SearchRequest) returns (SearchResponse);
}

 　　rproto rpc.proto
　　rpc_service.rb

require 'rubygems'
require 'protobuf/rpc/server'  
require 'protobuf/rpc/handler'  
require 'rpc.pb'  
class Demo::SearchHandler < Protobuf::Rpc::Handler  
request Demo::SearchRequest  
response Demo::SearchResponse  
def self.process_request(request, response)  
if request.keyword == 'google'  
response.result = 'www.google.com'  
elsif request.keyword == 'freewheel'  
response.result = 'www.freewheel.tv'  
else  
response.result = ''  
end  
end  
end  
class Demo::RpcService < Protobuf::Rpc::Server  
def setup_handlers  
@handlers = {  
:search => Demo::SearchHandler,  
}   
end  
end  
 　　client_search.rb

#!/usr/bin/env ruby
require 'rubygems'  
require 'protobuf/rpc/client'  
require 'rpc.pb'
# build request  
request1 = Demo::SearchRequest.new  
request1.keyword = 'google'  
request2 = Demo::SearchRequest.new  
request2.keyword = 'freewheel'  
# create blunk response  
response1 = Demo::SearchResponse.new  
response2 = Demo::SearchResponse.new  
# execute rpc  
Protobuf::Rpc::Client.new('localhost', 9999).call :search, request1, response1  
Protobuf::Rpc::Client.new('localhost', 9999).call :search, request2, response2  
p response1.result  
p response2.result  
 　　ruby start_rpc_service
　　ruby client_search.rb  
　　未完成...
　　ps:
　　http://code.google.com/p/protobuf/