Description:
JDistributer 0.0.2
JDistributer
消息队列载体：Redis-Cluster
支持功能：
REQ消息体包含
生成时间戳
生成机器
body
RPLY消息体包含
REQ/RSP生成时间戳
REQ/RSP生成机器
RPLY生成时间戳
RPLY生成机器
状态
消息
RSP消息提包含
REQ生成时间戳
REQ生成机器
RSP生成时间戳
RSP生成机器
状态
消息
生产者生成消息，接受反馈
一个主题理论上会创建多个redis主题：
JD_REQ_{主题} 组消费模式
JD_REQ_RPLY_{主题} 广播消费模式
JD_RSP_{主题} 广播消费模式
生产者产生消息：
enum RequestStatus{
REQUEST_SENDED,
REQUEST_REPLIED,
SUCCESS,
FAILED
};
class ProductStatus{
public:
RequestStatus status;
std::string message;
};
using ProductStatusPtr = std::shared_ptr<ProductStatus>;
ProductStatusPtr async_product(Message, OnSuccessFunc, OnFailedFunc);
class RequestStatus(Enum):
REQUEST_SENDED,
REQUEST_REPLIED,
SUCCESS,
FAILED
License
For personal and professional use. You cannot resell or redistribute these repositories in their original state.
Customer Reviews
There are no reviews.
