# MQ数据源
08 二月 2016
<!-- more -→
# MQ数据源
datasource → topic exchange
数据源只关心输入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
exchangeName: datasource:poi
exchangeName: datasource:dispatch.event
数据源已固定格式发入exchange, exchange类型为topic.数据源只关心输入exchange.
修改数据源, 持久队列, 持久内部exchange需要备案记录.
消费者一般非必要情况下使用临时队列. 队列从数据源的exchange中订阅数据.
程序中不要生成持久的exchange, queue. 而是在管理界面生成.
命名
datasource:[datasourceName]
例: datasource:poi datasource:dispatch.event
记录备案
git@gitlab.supaide.cn:sys/rabbitmq.git datasources.txt
备案说明详见文件内部格式.
命名
queueName [appName]:[routingKey]
exchangeName x:[appName]:[routingKey]
例: autoDispatch:dispatch.event.orderCreate x:autoDispatch:dispatch.event.*
记录备案
git@gitlab.supaide.cn:sys/rabbitmq.git durableQueues.txt
备案说明详见文件内部格式.
命名
gen.[appName]:[routingKey]
or
默认随机名称
记录备案
无需备案