RabbitMQ学习以及与Spring的集成(二)

hq8501

　　本文介绍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对消息进行拉取。