一种业务使用一个topic,具体业务类型等使用tag进行区分,tag后加下划线,加上对应的系统名称。
业务流程 |
主队列名 |
---|---|
产品 | product_main_topic |
订单 | order_main_topic |
支付 | pay_main_topic |
配送 | express_main_topic |
售后 | after_sale_main_topic |
子系统名称 |
topic |
---|---|
产品中心 | |
订单中心 | order_topic |
结算中心 | settlement_topic |
配送中心 | |
积分中心 | |
用户中心 | user_topic |
客服中心 | |
话务中心 | call_topic |
消息中心 | |
数据中心 | data_topic |
报表中心 | report_topic |
日志topic | log_topic |
eg:
订单业务
topic: order_topic
tag: order_status_log_tag_app(订单状态变更日志,后缀加上系统名称)、order_price_log_tag_app(订单算价日志,后缀加上系统名称),
一个系统是一个producerGroup(生产者组)。
不同的消费处理逻辑必须在不同的consumerGroup中,因为同一个消费者组之间可以进行故障转移,保证消息被及时消费。
项目名 | producerGroup | topic | tag | consumerGroup | 备注 |
---|---|---|---|---|---|
app | app_producer_group | policy_topic | policy_expense_tag_app | policy_expense_group | 费用统计报表 |
push_data_topic | push_failure_data_tag_app | push_failure_data_group | 推送失败数据到智通 | ||
call_topic | call_tape_log_tag_app | call_tape_log_group | 录音文件数据 | ||
report_topic | insurance_report_tag_app | insurance_report_group | 核保报表 | ||
order_topic | order_price_log_tag_app | order_price_log_group | 订单算价日志到es | ||
order_check_insurance_log_tag_app | order_check_insurance_log_group | 订单核保日志到es | |||
order_insurance_end_date_log_tag_app | order_insurance_end_date_log_group | 订单获取保险起期日志到es | |||
admin | admin_producer_group | policy_topic |
policy_expense_tag_admin | policy_expense_group | 费用统计报表 |
job | job_producer_group |