消息队列技术架构

kafka技术架构

queue

接口

消费组A

订阅者2

1.应用场景：物联网设备传感器通讯2.支持协议：MQTT协议

1.exchange-交换机（路由算法也取决于exchange的类型和规则）、queue-消息容器2.exchange-交换机类型：Direct、Fanout、Topic、Headers   Direct会使用一个routing key来做路由，它会把消息路由给那些绑定到该exchange上并且routingkey相等的队列上目的：  这是默认的交互机类型 ，当一个消息需要发送给一个队列时，通常使用这种类型的交互机。   Fanout会把消息路由给所有绑定到该交互机上的队列。如果提供的有routing  key的话，routingkey也会被忽视。目的：  这非常适用于发布-订阅模式下广播特性。   Topic会把消息路由给那些匹配routing key的队列。目的：  这比较适用于处理那些基于某些条件下广播给特定队列的场景。   Headers在路由消息时，是基于消息头来做出抉择的。目的：  这适用于那些点对点发送一些包含部分已知条件的消息

订阅者3

消费者1

Exchange

第三方推送

消费者2

生产者3

消息队列

消费组B

发布者1

发布者2

数据库

MQTT技术架构

生产者2

消费者3

消息队列服务器

MQTT服务器

消费组C

topic2

应用

传感器设备1

topic1

RabbitMQ技术架构

动态主题

订阅者1

生产者1