mirror of
https://github.com/msgpack/msgpack-c.git
synced 2025-04-20 07:51:34 +02:00
104 lines
2.8 KiB
C++
104 lines
2.8 KiB
C++
// MessagePack for C++ example
|
|
//
|
|
// Copyright (C) 2008-2015 FURUHASHI Sadayuki and KONDO Takatoshi
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
//
|
|
|
|
#include <msgpack.hpp>
|
|
#include <string>
|
|
#include <iostream>
|
|
#include <sstream>
|
|
|
|
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::unpacked result;
|
|
msgpack::unpack(result, buffer.data(), buffer.size());
|
|
msgpack::object o = result.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::unpacked result;
|
|
msgpack::unpack(result, buffer.data(), buffer.size());
|
|
msgpack::object o = result.get();
|
|
|
|
|
|
myprotocol::MultiGet req;
|
|
o.convert(req);
|
|
std::cout << "received: " << o << std::endl;
|
|
}
|
|
}
|