异步非阻塞响应端

#include "MsgRpc.hpp"

类 Emx::MsgRpcRep 继承关系图:

Emx::MsgRpcRep 的协作图:

类
struct	Config
	启动异步响应监听时携带的配置参数更多...

Public 类型
using	Callback = std::function< void()>
	连接状态回调更多...

using	RecvReqCallback = std::function< ErrCodeE(uint32_t module, uint32_t method, int32_t chn, const char *data, int32_t size, std::string &out)>
	接收到RPC请求回调更多...

Public 成员函数
	MsgRpcRep ()

ErrCodeE	CreateMsgRpcRep (Config &cfg)
	创建异步消息响应体更多...

void	DestroyMsgRpcRep ()
	销毁请求体更多...

Public 成员函数继承自 Emx::EuvPipeClientBase
	EuvPipeClientBase ()

virtual	~EuvPipeClientBase ()

Public 成员函数继承自 Emx::EuvStmClientBase
	EuvStmClientBase (EuvStreamInf *stm)

virtual	~EuvStmClientBase ()

ErrCodeE	Create (EuvLoop &loop, char buffer, int32_t size, const char serverIp, uint16_t serverPort, const char *localIp=nullptr, uint16_t localPort=0)
	创建客户端并连接服务端更多...

void	Destroy ()
	断开链接并销毁客户端更多...

ErrCodeE	Send (std::shared_ptr< std::string > &data)
	向服务端发送数据更多...

void	PauseRecv ()
	停止接收，调用后将不会收到数据更多...

ErrCodeE	ResumeRecv ()
	开始接收数据/重新开始接收数据更多...

bool	IsReceiving ()
	获取当前客户端是否正在监听接收更多...

std::string	GetSockName ()
	获取本地地址更多...

std::string	GetPeerName ()
	获取对方地址更多...

Protected 成员函数
void	OnConnect () override

void	OnDisConnect () override

void	OnRecv (const char *data, int32_t size) override

Protected 成员函数继承自 Emx::EuvStmClientBase
virtual void	OnSendDone (ErrCodeE e, const char *buffer, int32_t size)
	当调用Send函数发送的数据成功发送至服务端，或出现错误时触发次回调更多...

成员类型定义说明

◆ Callback

using Emx::MsgRpcRep::Callback = std::function<void()>

◆ RecvReqCallback

using Emx::MsgRpcRep::RecvReqCallback = std::function<ErrCodeE(uint32_t module, uint32_t method, int32_t chn, const char *data, int32_t size, std::string &out)>

参数

module	[in] 请求的模块
method	[in] 请求的方法
chn	[in] 请求的通道
data	[in] 请求携带的数据
size	[in] 请求携带的数据大小
out	[out] 返回的数据

构造及析构函数说明

◆ MsgRpcRep()

Emx::MsgRpcRep::MsgRpcRep ( )

inline

成员函数说明

◆ CreateMsgRpcRep()

ErrCodeE Emx::MsgRpcRep::CreateMsgRpcRep ( Config & cfg )

参数

cfg [in] 配置参数

返回: ErrCodeE

◆ DestroyMsgRpcRep()

void Emx::MsgRpcRep::DestroyMsgRpcRep ( )

inline

◆ OnConnect()

void Emx::MsgRpcRep::OnConnect ( )

inlineoverrideprotectedvirtual

实现了 Emx::EuvStmClientBase.

◆ OnDisConnect()

void Emx::MsgRpcRep::OnDisConnect ( )

inlineoverrideprotectedvirtual

实现了 Emx::EuvStmClientBase.

◆ OnRecv()

void Emx::MsgRpcRep::OnRecv	(	const char *	data,
		int32_t	size
	)

overrideprotectedvirtual

重载 Emx::EuvStmClientBase .

类

Public 类型

Public 成员函数

Protected 成员函数