mirror of
https://github.com/msgpack/msgpack-c.git
synced 2025-04-19 23:50:40 +02:00
1bfcf55469
msgpack::unpacked is a typedef of the msgpack::object_handle. I recommend using msgpack::object_handle. It can be used not only holding unpacked msgpack objects but also msgpack::objects that are created by any types. Replaced unpack() APIs in test codes and examples. They used to use old APIs.
98 lines
2.5 KiB
C++
98 lines
2.5 KiB
C++
// MessagePack for C++ example
|
|
//
|
|
// Copyright (C) 2008-2015 FURUHASHI Sadayuki and KONDO Takatoshi
|
|
//
|
|
// Distributed under the Boost Software License, Version 1.0.
|
|
// (See accompanying file LICENSE_1_0.txt or copy at
|
|
// http://www.boost.org/LICENSE_1_0.txt)
|
|
//
|
|
|
|
#include <msgpack.hpp>
|
|
#include <string>
|
|
#include <iostream>
|
|
#include <sstream>
|
|
|
|
// This example uses obsolete APIs
|
|
// See protocol_new.cpp
|
|
namespace myprotocol {
|
|
using namespace msgpack::type;
|
|
using msgpack::define;
|
|
|
|
struct Get : define< tuple<uint32_t, std::string> > {
|
|
Get() { }
|
|
Get(uint32_t f, const std::string& k) :
|
|
define_type(msgpack_type(f, k)) { }
|
|
uint32_t& flags() { return msgpack::type::get<0>(*this); }
|
|
std::string& key() { return msgpack::type::get<1>(*this); }
|
|
};
|
|
|
|
struct Put : define< tuple<uint32_t, std::string, raw_ref> > {
|
|
Put() { }
|
|
Put(uint32_t f, const std::string& k, const char* valref, uint32_t vallen) :
|
|
define_type(msgpack_type( f, k, raw_ref(valref,vallen) )) { }
|
|
uint32_t& flags() { return msgpack::type::get<0>(*this); }
|
|
std::string& key() { return msgpack::type::get<1>(*this); }
|
|
raw_ref& value() { return msgpack::type::get<2>(*this); }
|
|
};
|
|
|
|
struct MultiGet : define< std::vector<Get> > {
|
|
};
|
|
}
|
|
|
|
|
|
int main(void)
|
|
{
|
|
// send Get request
|
|
std::stringstream stream;
|
|
{
|
|
myprotocol::Get req;
|
|
req.flags() = 0;
|
|
req.key() = "key0";
|
|
msgpack::pack(stream, req);
|
|
}
|
|
|
|
stream.seekg(0);
|
|
|
|
// receive Get request
|
|
{
|
|
std::string buffer(stream.str());
|
|
|
|
msgpack::object_handle oh =
|
|
msgpack::unpack(buffer.data(), buffer.size());
|
|
msgpack::object o = oh.get();
|
|
|
|
myprotocol::Get req;
|
|
o.convert(req);
|
|
std::cout << "received: " << o << std::endl;
|
|
}
|
|
|
|
|
|
stream.str("");
|
|
|
|
|
|
// send MultiGet request
|
|
{
|
|
myprotocol::MultiGet req;
|
|
req.push_back( myprotocol::Get(1, "key1") );
|
|
req.push_back( myprotocol::Get(2, "key2") );
|
|
req.push_back( myprotocol::Get(3, "key3") );
|
|
msgpack::pack(stream, req);
|
|
}
|
|
|
|
stream.seekg(0);
|
|
|
|
// receive MultiGet request
|
|
{
|
|
std::string buffer(stream.str());
|
|
|
|
msgpack::object_handle oh =
|
|
msgpack::unpack(buffer.data(), buffer.size());
|
|
msgpack::object o = oh.get();
|
|
|
|
|
|
myprotocol::MultiGet req;
|
|
o.convert(req);
|
|
std::cout << "received: " << o << std::endl;
|
|
}
|
|
}
|