消息队列载体: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