JDistributer

JDistributer Demo


License
MIT
Install
pip install JDistributer==0.0.2

Documentation

JDistributer

消息队列载体:Redis-Cluster

支持功能:

  1. REQ消息体包含
    1. 生成时间戳
    2. 生成机器
    3. body
  2. RPLY消息体包含
    1. REQ/RSP生成时间戳
    2. REQ/RSP生成机器
    3. RPLY生成时间戳
    4. RPLY生成机器
    5. 状态
    6. 消息
  3. RSP消息提包含
    1. REQ生成时间戳
    2. REQ生成机器
    3. RSP生成时间戳
    4. RSP生成机器
    5. 状态
    6. 消息
  4. 生产者生成消息,接受反馈

一个主题理论上会创建多个redis主题:

  1. JD_REQ_{主题} 组消费模式
  2. JD_REQ_RPLY_{主题} 广播消费模式
  3. 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