MQ数据源
datasource -> topic exchange, 数据源已固定格式发入exchange, exchange类型为topic,既可以使用路由route_key, 又可以进行通配. 不要将生产者, 消费者用在同一队列上, 这样耦合度高, 消息无法复用.数据源只关心输入exchange, 对后续消费者无需关心
新加,修改数据源需要备案记录.
消费者一般情况下使用临时队列, 必要情况下使用持久队列. 队列从数据源的exchange中订阅数据.
程序中不要生成持久的exchange, queue. 而是在管理界面生成. 防止程序改动造成的废弃的exchange, queue仍然存在在rabbitmq中.
-
命名统一.
exchangeName: datasource:[sth.sth] queueName: [消费者程序名称]:[exchangeName].[subject] route_key: [exchangeName].[subject] 例: exchangeName: datasource:dispatch.event queueName: autoDispatch:dispatch.event.orderCreate route_key: dispatch.event.orderCreate
poi
exchangeName: datasource:poi
业务事件流
exchangeName: datasource:dispatch.event
日志流
其他
rabbitmq 规范
使用规范
0. 使用原则
- 数据源已固定格式发入exchange, exchange类型为topic.数据源只关心输入exchange.
- 修改数据源, 持久队列, 持久内部exchange需要备案记录.
- 消费者一般非必要情况下使用临时队列. 队列从数据源的exchange中订阅数据.
- 程序中不要生成持久的exchange, queue. 而是在管理界面生成.
1. datasourceExchanges
-
命名
datasource:[datasourceName] 例: datasource:poi datasource:dispatch.event -
记录备案
git@gitlab.supaide.cn:sys/rabbitmq.git datasources.txt 备案说明详见文件内部格式.
2. durable queues, exchanges
-
命名
queueName [appName]:[routingKey] exchangeName x:[appName]:[routingKey] 例: autoDispatch:dispatch.event.orderCreate x:autoDispatch:dispatch.event.* -
记录备案
git@gitlab.supaide.cn:sys/rabbitmq.git durableQueues.txt 备案说明详见文件内部格式.
3. temp queues, exchagnes
-
命名
gen.[appName]:[routingKey] or 默认随机名称 记录备案
无需备案
