Cmake + protobuf-c + python自定义协议通信
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); // Put an int in msg
if (argc == 3) { msg.has_b = 1; msg.b = atoi(argv); } // 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/
页:
[1]