AMQP 抽象

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

本概述假定您已经熟悉 AMQP 规范的基础知识。如果没有，请查看 Other Resources 中列出的资源spring-doc.cn

`Message`

0-9-1 AMQP 规范未定义类或接口。相反，在执行诸如之类的操作时，内容将作为字节数组参数传递，而其他属性将作为单独的参数传入。 Spring AMQP 将类定义为更通用的 AMQP 域模型表示的一部分。该类的目的是将 body 和 properties 封装在单个实例中，以便 API 反过来可以更简单。以下示例显示了类定义：MessagebasicPublish()MessageMessageMessagespring-doc.cn

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;
    }
}

该接口定义了几个常见属性，例如 'messageId'、'timestamp'、'contentType' 等。您还可以通过调用该方法使用用户定义的 'headers' 来扩展这些属性。MessagePropertiessetHeader(String key, Object value)spring-doc.cn

从版本、、和、开始，如果消息体是序列化的 java 对象，则在执行操作（例如在日志消息中）时（默认情况下）不再反序列化它。这是为了防止不安全的反序列化。默认情况下，只有和类被反序列化。要恢复到以前的行为，您可以通过调用 . 支持简单的通配符，例如 . 无法反序列化的正文在 log messages 中表示。1.5.71.6.111.7.42.0.0SerializabletoString()java.utiljava.langMessage.addAllowedListPatterns(…)*com.something.*, *.MyClassbyte[<size>]

交换

该接口表示 AMQP Exchange，这是消息生成者发送到的对象。代理的虚拟主机中的每个 Exchange 都有一个唯一的名称以及一些其他属性。以下示例显示了该接口：ExchangeExchangespring-doc.cn

public interface Exchange {

    String getName();

    String getExchangeType();

    boolean isDurable();

    boolean isAutoDelete();

    Map<String, Object> getArguments();

}

如您所见，an 也有一个由中定义的常量表示的 'type'。基本类型包括：、、和。在 core 包中，您可以找到每种类型的接口实现。这些类型在处理队列绑定的方式方面的行为各不相同。例如，交换允许队列由固定的路由键（通常是队列的名称）绑定。交换支持具有路由模式的绑定，这些模式可能包括分别表示“恰好一”和“零或多”的“*”和“#”通配符。交换发布到绑定到它的所有队列，而不考虑任何路由键。有关这些类型和其他 Exchange 类型的更多信息，请参阅 AMQP Exchanges。ExchangeExchangeTypesdirecttopicfanoutheadersExchangeExchangeDirectTopicFanoutspring-doc.cn

从版本 3.2 开始，为了方便起见，在应用程序配置阶段引入了该类型。它提供了 exchange type 等选项。允许配置或交换定义参数。必须在代理上启用相应的 RabbitMQ 插件。有关一致哈希交换的用途、逻辑和行为的更多信息，请参阅官方 RabbitMQ 文档。ConsistentHashExchangex-consistent-hashhash-headerhash-propertyrabbitmq_consistent_hash_exchangespring-doc.cn

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

队列

该类表示消息使用者从中接收消息的组件。与各种类一样，我们的实现旨在成为此核心 AMQP 类型的抽象表示。下面的清单显示了该类：QueueExchangeQueuespring-doc.cn

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

}

请注意，构造函数采用队列名称。根据实现， admin 模板可能会提供生成唯一命名队列的方法。此类队列可用作 “reply-to” 地址或其他临时情况。因此，自动生成的队列的 'exclusive' 和 'autoDelete' 属性都将设置为 'true'。spring-doc.cn

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

捆绑

鉴于生产者向交换发送数据，而使用者从队列接收数据，则将队列连接到交换的绑定对于通过消息收发连接这些生产者和使用者至关重要。在 Spring AMQP 中，我们定义了一个类来表示这些连接。本节回顾将队列绑定到 exchanges 的基本选项。Bindingspring-doc.cn

您可以将队列绑定到具有固定路由键的，如下例所示：DirectExchangespring-doc.cn

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

您可以使用路由模式将队列绑定到，如下例所示：TopicExchangespring-doc.cn

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

您可以将队列绑定到没有路由键的，如下例所示：FanoutExchangespring-doc.cn

new Binding(someQueue, someFanoutExchange);

我们还提供了一个 a 来促进 “Fluent API” 样式，如下例所示：BindingBuilderspring-doc.cn

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

为清楚起见，前面的示例显示了该类，但是当对 'bind（）' 方法使用静态导入时，这种样式效果很好。BindingBuilder

该类的实例本身仅保存有关连接的数据。换句话说，它不是一个 “active” 组件。但是，正如您稍后将在配置 Broker 中看到的那样，该类可以使用实例来实际触发 Broker 上的绑定操作。此外，正如你在同一节中看到的那样，你可以通过在类中使用 Spring 的 Comments 来定义实例。还有一个方便的基类，它进一步简化了生成与 AMQP 相关的 bean 定义的方法，并识别队列、交换和绑定，以便在应用程序启动时在 AMQP 代理上声明它们。BindingAmqpAdminBindingBinding@Bean@Configurationspring-doc.cn

在 core 包中也定义了。作为实际 AMQP 消息传递中涉及的主要组件之一，它将在其自己的部分中详细讨论（参见 AmqpTemplate）。AmqpTemplatespring-doc.cn