Typed rpc-like messaging

Async tcp request/response client & server, RPC-like. Mainly designed for exchange message between c++ server nodes.

features:

* define protocols in native c++ table
* transfer native cpp data-structs, such as list, map etc.
* C/S(Request/Response) Model

dependencies：

* c++11 meta-programming
* Boost.Asio
* Boost.Serialization
* Boost.Pool
* Boost.Intrusive
* Boost.Interprocess
* Boost.MSM
* ...

Echo example:

Message table

typedef Message::Table<
    ___reserved___
  , Message::Pair< Request<std::string>, Response<std::string> >
  , Message::Pair< Request<int, std::string>, Response<int, std::string> >
  , Message::Pair< Request<std::map<int,std::string>>, Response<std::map<int,std::string>> >
> Message_table;

Server side

struct Message_handle : service_def<Message_handle,Message_table> //::: server-side
{
    /// echo back all messages decl in Message_table
    template <typename Reply, typename...T>
    void operator()(Reply reply, T&& ...t) const
    {
        reply(std::forward<T>(t)...);
    }
    Message_handle(ip::tcp::socket* s) : service_def<Message_handle,Message_table>(s) {}
};

client side

template <typename Data>
void echo_test(ip::address host, unsigned short port, int n_req, Data&& data)
{
    boost::asio::io_service io_s;
    Echo::Client cli(io_s, host, port);

    int n_rsp = 0;
    {
        auto handle_resp = [&n_rsp,&data](Data const& u) { ENSURE(u==data); ++n_rsp; };
        boost::timer::auto_cpu_timer t;
        for (int i=0; i < n_req; ++i) {
            cli.async_do(handle_resp , data);
        }
        io_s.run();
    }
    ENSURE(n_req==n_rsp, n_req, n_rsp, data);

    std::cout << n_req <<" "<< cli.sockets.size() <<"\n";
}

see examples/echo.cpp

run test

test with gcc-4.8.
$
$ cd examples
$ export BOOST_ROOT=~/boost_1_57_0
$ b2
$ bin/echo -l 33333
$ bin/echo 127.0.0.1 33333
$