## 介紹 Spring AMQP 由幾個模塊組成，這些模塊有：spring-amqp 和 spring-rabbit。spring-amqp 模塊包含 org.springframework.amqp.core 包。在這個包中，你將找到代表核心 AMQP “模式”的類。其目的是提供不依賴的泛型抽象的任何特定的 AMQP broker 實現或客戶端庫。這些抽象由特定的模塊實現，例如 spring-rabbit。目前，只有一個 RabbitMQ 實現。 ## 消息 在 0-8 和 0-9-1 AMQP 規范不定義 Message 類或接口。相反地，當執行如 basicPublish() 方法時，其內容將作為二進制數組傳遞，并附加消息的其他屬性作為單獨的參數。Spring AMQP 將 Message 類定義為更共通的 AMQP 域模型的一部分表示。Message 類的目的是簡單地將內容和屬性封裝在一個單一的實例中，以便 AMQP API 的其余部分可以簡單地調用。 ~~~java 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） 方法來擴展。 ## 交換器 在虛擬主機中，每個交換器將具有唯一的名稱以及一些其他屬性。 ~~~java public interface Exchange { String getName(); String getExchangeType(); boolean isDurable(); boolean isAutoDelete(); Map<String, Object> getArguments(); } ~~~ 它有許多子類：AbstractExchange, CustomExchange, DirectExchange, FanoutExchange, HeadersExchange, TopicExchange。 ## 隊列 Queue 類表示消費者從消息隊列接收消息的組件。 ~~~java 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 } ~~~ ## 綁定 假設一個生產者發送到一個交換器，而一個消費者從一個隊列接收消息。此時，將隊列綁定到交換器對于連接這些生產者和消費者至關重要。在 Spring AMQP 中，我們定義一個 Binding 類來表示這些連接。 你可以使用 DirectExchange 綁定一個隊列。 ~~~java new Binding(someQueue, someDirectExchange, "foo.bar") ~~~ 你可以使用 TopicExchange 綁定一個隊列。 ~~~java new Binding(someQueue, someTopicExchange, "foo.*") ~~~ 你可以使用 FanoutExchange 綁定一個隊列。 ~~~java new Binding(someQueue, someFanoutExchange) ~~~ 同時，也提供了 BindingBuilder 來構建 “流式的 API” 風格。 ~~~java Binding b = BindingBuilder.bind(someQueue).to(someTopicExchange).with("foo.*"); ~~~