Emx::MsgTopicSubscriberAsync::Config结构体 参考

启动异步订阅时携带的配置参数 更多...

#include "MsgTopic.hpp"

Emx::MsgTopicSubscriberAsync::Config 的协作图:

Public 属性
EuvLoop *	loop
	需要绑定的loop 更多...
bool	sendByPack
	true代表根据包的数量判断，false代表根据字节数判断 更多...
int32_t	maxSend
	TopicServer针对此订阅端缓存的最大数据量，单位由‘sendByPack’决定，-1表示无限制 更多...
std::vector< uint32_t >	topicArray
	需要订阅的topic数组 更多...
char *	buffer
	需要提供一个buffer来接收数据 更多...
int32_t	size
	buffer的大小 更多...
Callback	OnConnected
	注册一个当与MsgTopicServer成功建立连接后的回调 更多...
Callback	OnDisConnected
	注册一个当与MsgTopicServer断开连接后的回调 更多...
RecvMsgCallback	OnRecvMsg
	注册一个用于接收响应消息的回调 更多...

详细描述

注解

每个订阅端在TopicServer上都对应着一个发送端，可以通过sendByPack和maxSend字段控制这个发送端 缓存的大小，缓存过大当订阅端处理不即时时可能会占用很多内存，分配过小可能导致丢掉一些订阅信息

类成员变量说明

loop

EuvLoop* Emx::MsgTopicSubscriberAsync::Config::loop

sendByPack

bool Emx::MsgTopicSubscriberAsync::Config::sendByPack

maxSend

int32_t Emx::MsgTopicSubscriberAsync::Config::maxSend

topicArray

std::vector<uint32_t> Emx::MsgTopicSubscriberAsync::Config::topicArray

buffer

char* Emx::MsgTopicSubscriberAsync::Config::buffer

size

int32_t Emx::MsgTopicSubscriberAsync::Config::size

OnConnected

Callback Emx::MsgTopicSubscriberAsync::Config::OnConnected

OnDisConnected

Callback Emx::MsgTopicSubscriberAsync::Config::OnDisConnected

OnRecvMsg

RecvMsgCallback Emx::MsgTopicSubscriberAsync::Config::OnRecvMsg