本文介绍RabbitMQ的一些基本概念。
RabbitMQ服务可以安装在独立服务器上,通过配置的账户和ip访问使用。也就是说,RabbitMQ和使用它的应用可以部署在不同的服务器上。RabbitMQ的账户配置可以在其web后台的admin板块配置。
Virtual Host
virtual host直译就是虚拟主机,RabbitMQ作为一个比较成熟的消息中间件,当然可以为不同的应用提供不同的服务空间。这就是virtual host的作用,用以区分不同应用的资源。不同的virtual host管理各自的exchanges、queue和bindings。我们在新建账户时需要指定对应的virtual host,这就意味着使用这个账户进行连接的应用只能使用该virtual host下的资源。当然了,一个virtual host是可以有多个账户的。
Exchanges
交换机们。在RabbitMQ中,发送的消息最终会发送到queue(消息队列)。但是我们不是通过直接指定某个queue进行消息发送,而是需要通过Exchange,根据其指定的规则进行转发,这是为了增加程序的可开发性。既然是通过Exchange转发,那么Exchange和queue之间就存在一个绑定关系,这个绑定关系需要通过xml等预先配置好。根据Exchange转发的规则不同产生了四种Exchange类型。分别是Direct exchange,Fanout exchange,Topic exchange,Headers exchange。
Direct exchange通过一个key值进行消息转发。绑定queue到Direct exchange的时,需要指定该queue的一个key值。我们发送消息时,除了消息本身,还需发送一个key。Direct exchange就会根据该key查询有无对应的queue。有,则转发到对应的queue,完成发送过程。两个不同的queue使用同一个key进行绑定也是可以的,符合条件的消息会一起发送给两个queue。
Fanout exchange是直接将消息转发到所有绑定到它的queue上。发送消息时只需要发送消息体。
Topic exchange规则稍稍有点复杂。一个queue是通过一个pattern绑定到Topic exchange的。一个pattern其实也是一串字符,但是它可以包含两个特殊符号。*和#。举例来说,绑定一个了queue A到Topic exchange并指定pattern是"animal.bird.*",那么在发送消息时,如果发送的key是"animal.bird.somebird",则这个消息就可以转发到queue A。而"animal.fish.somefish"或者"animal.bird"这样就不行,相当于*表示了一个占位符。至于"#",它表示省略。举例来说,queue B绑定到Topic exchange指定pattern是"animal.#",那么key是"animal.bird.somebird"、"animal.bird"、"animal.fish"的消息可以发送的queue B。
Headers exchange还没研究。
Queues
消息队列。消息队列是消息的载体,我们可以在应用中定义多个消息队列。消息在被消耗之前,是存储在queue中的,而queue的创建和维护是在RabbitMQ服务器上的。所以没被消耗的消息占用的是消息服务器的内存而不是应用的内存。一个queue可以绑定到任意个exchange中。
Consumers
消息消费者。消息的消费可以有两种方式进行。一种是定义queue的listener,只要消息发送到queue就会触发对应listener的onMessage()方法,相当于消息的push。值得注意的是,一个queue可以定义多个对应的consumer,一个consumer也可以监听多个queue。另一种是消息的pull,我们通过可以指定queue的name对消息进行拉取。