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 [b]\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/