AMQP 抽象

Spring AMQP 包含两个模块（每个模块在分发版中都由一个 JAR 表示）：spring-amqp 和 spring-rabbit。'spring-amqp' 模块包含 org.springframework.amqp.core 包。在该包中，您可以找到表示核心 AMQP“模型”的类。我们的目标是提供通用的抽象，这些抽象不依赖于任何特定的 AMQP 代理实现或客户端库。最终用户代码可以在不同的供应商实现之间更具可移植性，因为它可以仅针对抽象层进行开发。然后，这些抽象由特定于代理的模块（如 'spring-rabbit'）实现。目前只有一种 RabbitMQ 实现。但是，除了 RabbitMQ 之外，这些抽象还在 .NET 中使用 Apache Qpid 进行了验证。由于 AMQP 在协议级别运行，原则上，您可以将 RabbitMQ 客户端与任何支持相同协议版本的代理一起使用，但我们目前没有测试任何其他代理。

此概述假设您已经熟悉 AMQP 规范的基本知识。如果不是，请查看其他资源中列出的资源。

`Message`

0-9-1 AMQP 规范没有定义 Message 类或接口。相反，在执行诸如 basicPublish() 之类的操作时，内容作为字节数组参数传递，其他属性作为单独的参数传递。Spring AMQP 将 Message 类定义为更通用 AMQP 域模型表示的一部分。Message 类的目的是将主体和属性封装在一个实例中，以便 API 可以反过来变得更简单。以下示例显示了 Message 类定义

public class Message {

    private final MessageProperties messageProperties;

    private final byte[] body;

    public Message(byte[] body, MessageProperties messageProperties) {
        this.body = body;
        this.messageProperties = messageProperties;
    }

    public byte[] getBody() {
        return this.body;
    }

    public MessageProperties getMessageProperties() {
        return this.messageProperties;
    }
}

MessageProperties 接口定义了几个常见属性，例如“messageId”、“timestamp”、“contentType”等等。您还可以通过调用 setHeader(String key, Object value) 方法使用用户定义的“headers”扩展这些属性。

从版本 1.5.7、1.6.11、1.7.4 和 2.0.0 开始，如果消息主体是序列化后的 Serializable Java 对象，则在执行 toString() 操作（例如在日志消息中）时，它不再被反序列化（默认情况下）。这是为了防止不安全的反序列化。默认情况下，只有 java.util 和 java.lang 类会被反序列化。要恢复到以前的行为，您可以通过调用 Message.addAllowedListPatterns(…) 添加允许的类/包模式。支持简单的 通配符，例如 com.something.、*.MyClass。在日志消息中，无法反序列化的主体由 byte[<size>] 表示。

交换机

Exchange 接口表示 AMQP 交换机，消息生产者发送消息的目标。代理的每个虚拟主机中的每个交换机都有一个唯一的名称以及其他一些属性。以下示例显示了 Exchange 接口

public interface Exchange {

    String getName();

    String getExchangeType();

    boolean isDurable();

    boolean isAutoDelete();

    Map<String, Object> getArguments();

}

如您所见，Exchange 还具有由 ExchangeTypes 中定义的常量表示的“类型”。基本类型包括：direct、topic、fanout 和 headers。在核心包中，您可以找到每种类型的 Exchange 接口的实现。这些 Exchange 类型的行为在处理与队列的绑定方面有所不同。例如，Direct 交换机允许通过固定的路由键（通常是队列的名称）绑定队列。Topic 交换机支持具有路由模式的绑定，这些模式可能包含“*”和“#”通配符，分别表示“正好一个”和“零个或多个”。Fanout 交换机发布到绑定到它的所有队列，而无需考虑任何路由键。有关这些和其他交换机类型的更多信息，请参阅其他资源。

AMQP 规范还要求任何代理都提供一个没有名称的“默认”直接交换机。声明的所有队列都使用其名称作为路由键绑定到该默认 Exchange。您可以在 AmqpTemplate 中了解有关 Spring AMQP 中默认交换机用法的更多信息。

队列

Queue 类表示消息消费者接收消息的组件。与各种 Exchange 类一样，我们的实现旨在成为这种核心 AMQP 类型的抽象表示。以下列表显示了 Queue 类

public class Queue  {

    private final String name;

    private volatile boolean durable;

    private volatile boolean exclusive;

    private volatile boolean autoDelete;

    private volatile Map<String, Object> arguments;

    /**
     * The queue is durable, non-exclusive and non auto-delete.
     *
     * @param name the name of the queue.
     */
    public Queue(String name) {
        this(name, true, false, false);
    }

    // Getters and Setters omitted for brevity

}

请注意，构造函数采用队列名称。根据实现的不同，管理员模板可能会提供生成唯一命名队列的方法。此类队列可用作“回复地址”或其他临时情况。因此，自动生成的队列的“exclusive”和“autoDelete”属性都将设置为“true”。

有关使用命名空间支持（包括队列参数）声明队列的信息，请参阅配置代理中关于队列的部分。

绑定

鉴于生产者发送到交换机，而消费者从队列接收，因此连接队列到交换机的绑定对于通过消息传递连接这些生产者和消费者至关重要。在 Spring AMQP 中，我们定义了一个 Binding 类来表示这些连接。本节回顾了将队列绑定到交换机的基本选项。

您可以使用固定的路由键将队列绑定到 DirectExchange，如下例所示

new Binding(someQueue, someDirectExchange, "foo.bar");

您可以使用路由模式将队列绑定到 TopicExchange，如下例所示

new Binding(someQueue, someTopicExchange, "foo.*");

您可以将队列绑定到 FanoutExchange，而无需路由键，如下例所示

new Binding(someQueue, someFanoutExchange);

我们还提供了一个 BindingBuilder 来促进“流畅 API”风格，如下例所示

Binding b = BindingBuilder.bind(someQueue).to(someTopicExchange).with("foo.*");

为清楚起见，前面的示例显示了 BindingBuilder 类，但是当使用“bind()”方法的静态导入时，这种风格效果很好。

Binding 类的实例本身仅保存有关连接的数据。换句话说，它不是“活动”组件。但是，正如您将在后面的配置代理中看到的那样，AmqpAdmin 类可以使用 Binding 实例在代理上实际触发绑定操作。此外，正如您在同一部分中看到的，您可以使用 Spring 的 @Bean 注解在 @Configuration 类中定义 Binding 实例。还有一个方便的基类可以进一步简化生成与 AMQP 相关的 bean 定义的方法，并识别队列、交换机和绑定，以便在应用程序启动时在 AMQP 代理上声明所有这些内容。

AmqpTemplate 也在核心包中定义。作为参与实际 AMQP 消息传递的主要组件之一，它将在其自己的部分中详细讨论（请参阅 AmqpTemplate）。