消息中心设计
2020-08-19 20:06:50 19 举报
消息中心
作者其他创作
大纲/内容
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
0 条评论
回复 删除
下一页