消息中心设计

Kafka

Sender Server

Mongodb

MqInfo

Register

Eureka

Consumer Server

Payload

Message

- messageId: String- thirdId: String(第三方消息ID)- topic: String- messageKey: String(消息业务key)- msgContent: String(原始消息内容)- path: String(消息当前路径)- status: Integer(0已发送，1成功，2异常，3私信)- retry: Integer(当前重发次数)- createTime: Date- updateTime: Date

ConsumerConnect

- id: Long- topic: String- gid: String- tag: String- mqId: Long(broker信息)- status: Integer(连接状态，0未连接，1已连接，2离线)- connectTime: Date- updateTime: Date- callbackUrl: String(回调地址，多个用逗号隔开)

Status

Wx Template Message

Rocket MQ

Api

MQ Broker

Message Init

Task

Message report

ConnectInfo

Statistics（日周月统计）

- id: Long- msgCount: Integer(消息总数)- unusualCount: Integer(异常消息总数)- deadCount: Integer(死信消息)- statisticsDate: Date

RabbitMQ

Sender

Broker

Message Manager&Monitor

Connecters

Pay Message

Other

TopicInfo

ProducerConnect

- id: Long- topic: String- gid: String- tag: String- mqId: Long(broker信息)- status: Integer(连接状态，0未连接，1已连接，2离线)- connectTime: Date- updateTime: Date

Statistics

Business Service

Topic

- id: Long- brokerId: Long(关联MQ的ID)- topic: String(unique)- gid: String- tag: String- createTime: Date- updateTime: Date

ActiveMQ