【RabbitMQ 三】Java客户端开发

本文引用的代码源自《RabbitMQ实战指南》

关键的类和接口主要有Channel、Connection、ConnectionFactory、Consumer等，它们主要的作用如下：

• Channel：实现AMQP协议层的操作
• Connection：开启信道（Channel）、注册事件处理器、关闭连接

与RabbitMQ相关的开发工作，也主要围绕Channel、Connection这两个类展开

1.连接RabbitMQ：创建Connection

知道了RabbitMQ的IP地址、端口号、用户名、密码后，可以通过以下代码连接RabbitMQ，

2.创建信道

在创建完Connection以后，就建立了当前服务与RabbitMQ的连接。下一步就是使用Connection对象建立信道

Channel channel = conn.createChannel()
1

创建完Channel之后，可以使用Channel对象来发送、接收消息

注意：一个Connection可以创建多个Channel对象，但是Channel对象不是线程安全的。也就是说，最好为每个线程创建一个Channel

一般来说，调用connectionFactory.newConnection()或者connection.createChannel()以后，Connection和Channel就处于开启状态了。如果在后续使用channel的过程中，Connection或者Channel关闭了，程序会抛出异常

3.声明交换器、绑定队列

在绑定交换器和队列前，要确保先声明交换器和队列，即前两行所示

• channel.exchangeDeclare是声明一个交换器。这里传入参数的意思是：声明一个名为exchangeName的交换器，交换器类型为direct，并且这是一个可持久化的交换器（第三个入参=true）。可持久化的意思是交换器信息会存入2磁盘，服务器重启后不会丢失交换器的信息

• channel.queueDeclare是声明一个队列，不带任何入参是声明一个由RabbitMQ命名的、非持久化队列

• channel.queueBind是绑定交换器和队列

既然交换器和队列存在绑定操作，也就必然存在解绑操作，可以通过queueUnbind方法来解绑

4.创建队列的时机

虽然RabbitMQ使用交换器和队列来处理消息，但因为消息只存储在队列中，所以交换器实际不消耗服务器资源，只有队列会消耗服务器资源。

换句话说，是否在代码里创建队列也可以见仁见智：

1. 动态创建：如果服务器资源充足，那么RabbitMQ官方建议生产者和消费者都应该显式建立队列。这样做可以确保交换器和队列是正确绑定匹配的（避免发送消息的交换器没有绑定任何队列、或者发送消息的路由键匹配不上队列，导致消息丢失）
2. 静态创建：如果业务已经充分确定了队列长度，可以在上线前在服务器上以RabbitMQ命令创建好队列，这样业务层就不用再声明队列了

5.发送消息

发送消息可以使用channel.basicPulish方法，例如：

以上代码意思是：

1. 将消息发送到exchangeName交换器汇总
2. 交换器根据routingKey将消息存储到RabbitMQ的相应队列中
3. 消息内容是messageBodyBytes

除了byte数组，还可以使用channel.basicPulish的重载方法，发送具有特殊格式的消息

6.消费消息

RabbitMQ有两种消费消息的方式：push（推）、pull（拉）

6.1 Push

Push模式下，消费者持续订阅队列，一般要实现Consumer接口或继承DefaultConsumer类

消费动作是调用channel.basicConsume来实现

以上调用channel.basicConsume的意思是：

1. 从queueName队列中订阅消息
2. autoAck=true时，消费者需要在接收到消息后显式地进行ack操作（调用channel.basicAck）
3. 当前消费者从队列中订阅消息的同时，也可能有其他消费者订阅相同的队列，使用consumerTag来区分多个消费者
4. 最后一个入参，传入了一个DefaultConsumer的匿名实现类，这其实是消费者的回调方法。当消费者收到订阅队列的消息时，会执行重写的handleDelivery方法

6.2 Pull

Pull模式下，通过channel.basicGet方法获取单条消息

6.3 Push和Pull的区别

• Push顾名思义是“推送”，指的是只要消费者订阅了队列，队列就会源源不断向消费者推送消息（只要队列中存在消息）
• Pull顾名思义是“拉取”，指的是虽然消费者订阅了队列，但是什么时候消费、要消费多少消息，完全取决于消费者的意愿
• 如果想要提高吞吐量，可以选择Push模式；并不能在for循环内调用pull来代替push，这样会严重影响RabbitMQ的性能