ET9_WebGL_Dev/Cpp/Platform/Rpc/RpcCommunicator.h

#ifndef RPC_RPCCOMMUNICATOR_H
#define RPC_RPCCOMMUNICATOR_H

#include <google/protobuf/service.h>
#include <boost/unordered_map.hpp>
#include <boost/asio.hpp>
#include <boost/format.hpp>
#include <boost/noncopyable.hpp>
#include "Base/Marcos.h"
#include "Base/Typedef.h"
#include "Rpc/RpcTypedef.h"

namespace Egametang {

struct RpcMeta
{
	// message长度
	std::size_t size;

	// 消息id, 用于处理异步回调
	std::size_t id;

	// 消息opcode, 是proto的full_path哈希值
	std::size_t method;

	RpcMeta(): size(0), id(0), method(0)
	{
	}

	std::string ToString()
	{
		boost::format format("size: %1%, id: %2%, method: %3%\n");
		return boost::str(format % size % id % method);
	}
};

class RpcCommunicator: public boost::noncopyable
{
private:
	boost::asio::io_service& io_service;
	boost::asio::ip::tcp::socket socket;

public:
	explicit RpcCommunicator(boost::asio::io_service& io_service);
	virtual ~RpcCommunicator();
	boost::asio::ip::tcp::socket& Socket();

	virtual void Stop();

	// recieve response
	void RecvMeta(RpcMetaPtr meta, StringPtr message);
	void RecvMessage(RpcMetaPtr meta, StringPtr message, const boost::system::error_code& err);
	void RecvDone(RpcMetaPtr meta, StringPtr message, const boost::system::error_code& err);
	virtual void OnRecvMessage(RpcMetaPtr meta, StringPtr message);

	// send request
	void SendMeta(RpcMetaPtr meta, StringPtr message);
	void SendMessage(RpcMetaPtr meta, StringPtr message, const boost::system::error_code& err);
	void SendDone(RpcMetaPtr meta, StringPtr message, const boost::system::error_code& err);
	virtual void OnSendMessage(RpcMetaPtr meta, StringPtr message);
};

} // namespace Egametang

#endif // RPC_RPCCOMMUNICATOR_H