1、消息的确认

　　RabbitMQ需要对每一条发送的消息进行确认。消费者必须通过AMQP的basic.ack命令显式地向RabbitMQ发送一个确认，或者在订阅到队列的时候就将auto_ack参数设置为true。当auto_ack为true时，一旦消费者接收消息，RabbitMQ会自动视其确认了消息。需要注意的是消费者对消息的确认和告诉生产者消息已经被接收了这两件事毫不相关。以此，消费者通过确认命令告诉RabbitMQ它已经确认地接收到消息，同时RabbitMQ才能安全的把消息从队列中删除。

　　如果消费者受到一条消息，然后确认之前从RabbitMQ断开连接（或者从队列上取消订阅），RabbitMQ会认为这条消息没有分发，然后重新分发给下一个订阅的消费者。如果你的应用程序崩溃了，这样做可以确保消息会被发送给另一个消费者处理。另一方面，如果应用程序有bug而忘记确认消息的话，RabbitMQ将不会给该消费者发送更多的消息。这是因为在上一条消息被确认之前，Rabbit会认为这个消费者没有准备好接收下一条消息。利用这一点，可以防止rabbit持续不断的消息涌向你的应用而导致过载。

　　在收到消息后，如果想要拒接而不是确认收到消息，有两种做法：

　　（1）、把消费者从RabbitMQ服务器断开连接，这会导致RabbitMQ自动重新把消息入队并发送给另一个消费者，这样做的好处是所有的RabbitMQ版本都支持。缺点是，这样的连接、断开连接的方式会额外增加RabbitMQ的负担。

　　（2）、如果使用的是RabbitMQ2.0.0或更高版本，可以使用AMQP的basic.reject命令。顾名思义：basic.reject允许消费者拒绝RabbitMQ发送消息。如果把reject命令的requeue设置为true的话，RabbitMQ会将消息重新发送给下一个订阅者。如果设置为false的话，RabbitMQ会立即把消息从队列中移除，而不会把它发送给新的消费者。

2、如何创建队列

　　RabbitMQ的消费者和生产者都能创建队列，通过queue.declare方法来创建。如果消费者在同一信道上订阅了一个队列，则它不能在声明队列，必须先取消订阅后，将信道置为传输模式。消费者订阅和绑定时都需要队列名，如果你创建队列时没有设置名字，rabbit会自动声明一个队列名称，并在queue.declare命令中返回。

　　如果你创建一个已经存在的队列，那么rabbit将不做任何事情。rabbit的queue.declare可以检测队列是否存在，如果队列存在，则返回成功，不存在则返回错误。

　　由生产者还是由消费者创建队列？答案是双向的，原因是消费者不能订阅不存在的队列，而发布者不能发布到消息不存在的队列，这有可能会造成消息的丢失。当然也可以通过其它方式来控制未发布的消息，而让消费者一端负责创建队列。

　　队列存在的意义：

　　（1）、为消息提供住所，消息再次等待消费

　　（2）、对负载均衡来说，队列是绝佳的方案。只需附加一堆消费者，并让RabbitMQ以循环的方式均匀地分配发来的消息

　　（3）、队列是RabbitMQ中消息的最后重点（除非消息进入黑洞）

3、交换器

　　路由键：消息绑定到交换器上的规则。

　　消息根据规则由交换机将消息投递到相对应的队列。如果路由消息不匹配任何绑定，消息将进入黑洞。

　　交换机有四种：direct、fanout、topic和header。其中headers和direct交换器完全一致，但性能比较差，很少用。

• 　　direct交换器：如果路由键匹配，消息就会被投递到对应的队列。

　　服务器必须实现direct类型交换器，包括一个空白字符串命名的默认交换器。当声明一个队列时，它会自动绑定到默认交换器，并以队列名称作为路由键.

• 　　fanout交换器：当发送一套消息到fanout交换器时，它会把消息投递给所有附加在此交换器上的队列。

• 　　topic交换器：这类交换器可以使来自不同源头的消息能够达到同一队列。

　　备注：图片取网上