浅谈消息队列

2019-10-07  本文已影响0人  hellozepp

MQ是什么

市面上的MQ对比

有Broker 重Topic流:kafka,JMS,pulsar
有Broker 轻Topic流: RocketMQ
无Broker: ZeroMQ

更合适的场景

kafka,zeromq,rabbitmq代表了三种完全不同风格的MQ架构;关注点完全不同:

AMQP 是啥

生产者发送key和数据,消费者定义订阅的队列,Broker收到数据之后会通过一定的逻辑计算出key对应的队列,然后把数据交给队列。
这种模式下解耦了key和queue,在这种架构中queue是非常轻量级的(在RabbitMQ中它的上限取决于你的内存),消费者关心的只是自己的queue;生产者不必关心数据最终给谁只要指定key就行了,中间的那层映射在AMQP中叫exchange(交换机)。AMQP中有四种种exchange——Direct exchange:key就等于queue;Fanout exchange:无视key,给所有的queue都来一份;Topic exchange:key可以用“宽字符”模糊匹配queue;最后一个厉害了Headers exchange:无视key,通过查看消息的头部元数据来决定发给那个queue(AMQP头部元数据非常丰富而且可以自定义)。这种结构的架构给通讯带来了很大的灵活性,我们能想到的通讯方式都可以用这四种exchange表达出来。如果你需要一个企业数据总线(在乎灵活性)那么RabbitMQ绝对的值得一用。

上一篇 下一篇

猜你喜欢

热点阅读