RabbitMQ使用简谈

powrexly 2018-06-24

最近简单看了一下RabbitMQ,这里简单总结一下。(先写到现在学习的,有错误的话后面再改正)

相较于其他MQ,RMQ更加成熟稳定,所以有更大的学习的价值。

相较于ZMQ只是一个网络组件,RMQ是一个独立的服务,使用时需要服务器和RMQserver之间进行通信。RMQ服务器保证了消息的持久化和消息的正确发送。

相较于ZMQ简单的直接根据连接类型(订阅、消费)等直接生成socket,RMQ多了exchange(路由)、queue、routingkey等概念,其实这些概念都是为了创建和构架网络结构服务的。

像ZMQ一样,RMQ中路由和管道(channel)也不是一一对应的,一个管道可以声明多个路由。但是在产生管道的时候,会默认绑定一个空字符的路由(名称为“”,它的类型是direct),这个路由是不需要绑定。另外,如果已知一个队列(queue),则不需要在程序中专门声明这个队列。但是如果声明了队列,则告诉服务,如果这个队列不存在的话,则创建该队列。routingkey(路由键)是和消息的过滤相关的,只有符合client指定的路由键才能被client接收到。路由键是在绑定queue(队列)的时候指定的,所以在绑定队列的时候,也就确定了client想要接收的消息类型。

RMQ的路由有direct、fanout和topic三种类型。direct和ZMQ中的消费模式对应,一个消息只能发送给所有绑定了和消息相同routingkey的consumer中的一个,consumer之间时竞争的关系。fanout对应了publish/subscribe类型,服务会忽略路由键,将消息发给和路由连接的所有的consumer。topic其实和direct有些相似,只是他过滤路由键时不是精确地比较。

几个问题:

1、如果队列服务挂了,怎么保证消息不丢失?

可以在创建消息时,指定duration为true,即是指定将消息持久化到硬盘,这样,即是服务重启了,消息也不会丢失。

2、怎样保证消息被consumer正确处理过了?

可以指定consumer手动回复ack,这样每处理完一个消息,consumer就回复一个ack,告诉服务已经处理完,否则服务会再次发送消息。消息什么时候会被重新发送,这里没有超时的设置,只有处理的consumer挂掉之后,服务器才会重新发送消息。

3、怎样保证发送的消息比例符合服务器处理能力?

有时候不同服务器处理消息的能力是不同的,怎样保证消息恰好和处理能力相同?可以设置路由器的qos(每次发送的消息数量),这样服务器每次处理完消息后,服务才会再次发送消

息。

参考:

https://blog.csdn.net/qq_34021712/article/details/72567801

相关推荐