MQ使用规范举例

素颜马尾好姑娘i 2022-04-10 03:54 238阅读 0赞

一种业务使用一个topic，具体业务类型等使用tag进行区分，tag后加下划线，加上对应的系统名称。

<table> 
 <thead> 
  <tr> 
   <th> <p>业务流程</p> </th> 
   <th> <p>主队列名</p> </th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>产品</td> 
   <td>product_main_topic</td> 
  </tr> 
  <tr> 
   <td>订单</td> 
   <td>order_main_topic</td> 
  </tr> 
  <tr> 
   <td>支付</td> 
   <td>pay_main_topic</td> 
  </tr> 
  <tr> 
   <td>配送</td> 
   <td>express_main_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">售后</td> 
   <td colspan="1">after_sale_main_topic</td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <thead> 
  <tr> 
   <th> <p>子系统名称</p> </th> 
   <th> <p>topic</p> </th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>产品中心</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td>订单中心</td> 
   <td>order_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">结算中心</td> 
   <td colspan="1">settlement_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">配送中心</td> 
   <td colspan="1">&nbsp;</td> 
  </tr> 
  <tr> 
   <td colspan="1">积分中心</td> 
   <td colspan="1">&nbsp;</td> 
  </tr> 
  <tr> 
   <td colspan="1">用户中心</td> 
   <td colspan="1">user_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">客服中心</td> 
   <td colspan="1">&nbsp;</td> 
  </tr> 
  <tr> 
   <td colspan="1">话务中心</td> 
   <td colspan="1">call_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">消息中心</td> 
   <td colspan="1">&nbsp;</td> 
  </tr> 
  <tr> 
   <td colspan="1">数据中心</td> 
   <td colspan="1">data_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">报表中心</td> 
   <td colspan="1">report_topic</td> 
  </tr> 
  <tr> 
   <td colspan="1">日志topic</td> 
   <td colspan="1">log_topic</td> 
  </tr> 
 </tbody> 
</table>

eg：

订单业务

topic:  order\_topic

tag:  order\_status\_log\_tag\_app(订单状态变更日志，后缀加上系统名称)、order\_price\_log\_tag\_app（订单算价日志，后缀加上系统名称），

一个系统是一个producerGroup（生产者组）。

不同的消费处理逻辑必须在不同的consumerGroup中，因为同一个消费者组之间可以进行故障转移，保证消息被及时消费。

<table> 
 <tbody> 
  <tr> 
   <th>项目名</th> 
   <th colspan="1">producerGroup</th> 
   <th>topic</th> 
   <th>tag</th> 
   <th colspan="1">consumerGroup</th> 
   <th colspan="1">备注</th> 
  </tr> 
  <tr> 
   <td>app</td> 
   <td>app_producer_group</td> 
   <td>policy_topic</td> 
   <td>policy_expense_tag_app</td> 
   <td colspan="1">policy_expense_group</td> 
   <td colspan="1">费用统计报表</td> 
  </tr> 
  <tr> 
   <td>push_data_topic</td> 
   <td colspan="1">push_failure_data_tag_app</td> 
   <td colspan="1">push_failure_data_group</td> 
   <td colspan="1">推送失败数据到智通</td> 
  </tr> 
  <tr> 
   <td>call_topic</td> 
   <td colspan="1">call_tape_log_tag_app</td> 
   <td colspan="1">call_tape_log_group</td> 
   <td colspan="1">录音文件数据</td> 
  </tr> 
  <tr> 
   <td colspan="1">report_topic</td> 
   <td colspan="1">insurance_report_tag_app</td> 
   <td colspan="1">insurance_report_group</td> 
   <td colspan="1">核保报表</td> 
  </tr> 
  <tr> 
   <td>order_topic</td> 
   <td>order_price_log_tag_app</td> 
   <td colspan="1">order_price_log_group</td> 
   <td colspan="1">订单算价日志到es</td> 
  </tr> 
  <tr> 
   <td colspan="1">order_check_insurance_log_tag_app</td> 
   <td colspan="1">order_check_insurance_log_group</td> 
   <td colspan="1">订单核保日志到es</td> 
  </tr> 
  <tr> 
   <td colspan="1">order_insurance_end_date_log_tag_app</td> 
   <td colspan="1">order_insurance_end_date_log_group</td> 
   <td colspan="1">订单获取保险起期日志到es</td> 
  </tr> 
  <tr> 
   <td colspan="1">admin</td> 
   <td colspan="1">admin_producer_group</td> 
   <td colspan="1"> <pre>policy_topic</pre> </td> 
   <td colspan="1">policy_expense_tag_admin</td> 
   <td colspan="1">policy_expense_group</td> 
   <td colspan="1">费用统计报表</td> 
  </tr> 
  <tr> 
   <td colspan="1">job</td> 
   <td colspan="1">job_producer_group</td> 
   <td colspan="1">&nbsp;</td> 
   <td colspan="1">&nbsp;</td> 
   <td colspan="1">&nbsp;</td> 
   <td colspan="1">&nbsp;</td> 
  </tr> 
 </tbody> 
</table>