溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
一、什么是 RabbitMQ
RabbitMQ 是實現 AMQP（高級消息隊列協議）的消息中間件的一種，最初起源于金融系統，用于在分布式系統中存儲轉發消息，在易用性、擴展性、高可用性等方面表現不俗。消息中間件主要用于組件之間的解耦，消息的發送者無需知道消息使用者的存在，反之亦然。
RabbitMQ 是由 Erlang 語言開發，安裝 RabbitMQ 服務需要先安裝 Erlang 語言包。
二、如何與 Spring 集成
1. 我們都需要哪些 Jar 包？
拋開單獨使用 Spring 的包不說，引入 RabbitMQ 我們還需要兩個：
<!-- RabbitMQ --> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.5.1</version> </dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.4.5.RELEASE</version> </dependency>
2. 使用外部參數文件 application.properties：
mq.host=127.0.0.1 mq.username=queue mq.password=1234 mq.port=8001 # 統一XML配置中易變部分的命名 mq.queue=test_mq
易變指的是在實際項目中，如果測試與生產環境使用的同一個 RabbitMQ 服務器。那我們在部署時直接修改 properties 文件的參數即可，防止測試與生產環境混淆。
修改 applicationContext.xml 文件，引入我們創建的 properties 文件
<context:property-placeholder location="classpath:application.properties"/> <util:properties id="appConfig" location="classpath:application.properties"></util:properties>
3. 連接 RabbitMQ 服務器
<!-- 連接配置 -->
<rabbit:connection-factory id="connectionFactory" host="${mq.host}" username="${mq.username}"
password="${mq.password}" port="${mq.port}" />
<rabbit:admin connection-factory="connectionFactory"/>
4. 聲明一個 RabbitMQ Template
5. 在 applicationContext.xml 中聲明一個交換機，name 屬性需配置到 RabbitMQ 服務器。
<rabbit:topic-exchange name="${mq.queue}_exchange" durable="true" auto-delete="false">
<rabbit:bindings>
<rabbit:binding queue="test_queue" pattern="${mq.queue}_patt"/>
</rabbit:bindings>
</rabbit:topic-exchange>
交換機的四種模式：
交換器的屬性：
如果沒有隊列綁定在交換機上，則發送到該交換機上的消息會丟失。
一個交換機可以綁定多個隊列，一個隊列可以被多個交換機綁定。
topic 類型交換器通過模式匹配分析消息的 routing-key 屬性。它將 routing-key 和 binding-key 的字符串切分成單詞。這些單詞之間用點隔開。它同樣也會識別兩個通配符：#匹配0個或者多個單詞，*匹配一個單詞。例如，binding key：*.stock.#匹配 routing key：usd.stcok 和 eur.stock.db，但是不匹配 stock.nana。
因為交換器是命名實體，聲明一個已經存在的交換器，但是試圖賦予不同類型是會導致錯誤。客戶端需要刪除這個已經存在的交換器，然后重新聲明并且賦予新的類型。
6. 在 applicationContext.xml 中聲明一個隊列，name 屬性是需要配置到 RabbitMQ 服務器的。
7. 創建生產者端
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @Description: 消息隊列發送者
* @Author:
* @CreateTime:
*/
@Service
public class Producer {
@Autowired
private AmqpTemplate amqpTemplate;
public void sendQueue(String exchange_key, String queue_key, Object object) {
// convertAndSend 將Java對象轉換為消息發送至匹配key的交換機中Exchange
amqpTemplate.convertAndSend(exchange_key, queue_key, object);
}
}
8. 在 applicationContext.xml 中配置監聽及消費者端
<!-- 消費者 --> <bean name="rabbitmqService" class="com.enh.mq.RabbitmqService"></bean> <!-- 配置監聽 --> <rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto"> <!-- queues 監聽隊列，多個用逗號分隔 ref 監聽器 --> <rabbit:listener queues="test_queue" ref="rabbitmqService"/> </rabbit:listener-container>
消費者 Java 代碼：
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
public class RabbitmqService implements MessageListener {
public void onMessage(Message message) {
System.out.println("消息消費者 = " + message.toString());
}
}
至此，我們的所有配置文件就寫完了，最終如下：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/rabbit
http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">
<!-- RabbitMQ start -->
<!-- 連接配置 -->
<rabbit:connection-factory id="connectionFactory" host="${mq.host}" username="${mq.username}"
password="${mq.password}" port="${mq.port}" />
<rabbit:admin connection-factory="connectionFactory"/>
<!-- 消息隊列客戶端 -->
<rabbit:template id="amqpTemplate" exchange="${mq.queue}_exchange" connection-factory="connectionFactory" />
<!-- queue 隊列聲明 -->
<!--
durable 是否持久化
exclusive 僅創建者可以使用的私有隊列，斷開后自動刪除
auto-delete 當所有消費端連接斷開后，是否自動刪除隊列 -->
<rabbit:queue id="test_queue" name="${mq.queue}_testQueue" durable="true" auto-delete="false" exclusive="false" />
<!-- 交換機定義 -->
<!--
交換機：一個交換機可以綁定多個隊列，一個隊列也可以綁定到多個交換機上。
如果沒有隊列綁定到交換機上，則發送到該交換機上的信息則會丟失。
direct模式:消息與一個特定的路由器完全匹配，才會轉發
topic模式:按規則轉發消息，最靈活
-->
<rabbit:topic-exchange name="${mq.queue}_exchange" durable="true" auto-delete="false">
<rabbit:bindings>
<!-- 設置消息Queue匹配的pattern (direct模式為key) -->
<rabbit:binding queue="test_queue" pattern="${mq.queue}_patt"/>
</rabbit:bindings>
</rabbit:topic-exchange>
<bean name="rabbitmqService" class="com.enh.mq.RabbitmqService"></bean>
<!-- 配置監聽 消費者 -->
<rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto">
<!--
queues 監聽隊列，多個用逗號分隔
ref 監聽器 -->
<rabbit:listener queues="test_queue" ref="rabbitmqService"/>
</rabbit:listener-container>
</beans>
9. 如何使用 RabbitMQ 發送一個消息
@Autowired
private Producer producer;
@Value("#{appConfig['mq.queue']}")
private String queueId;
/**
* @Description: 消息隊列
* @Author:
* @CreateTime:
*/
@ResponseBody
@RequestMapping("/sendQueue")
public String testQueue() {
try {
Map<String, Object> map = new HashMap<String, Object>();
map.put("data", "hello rabbitmq");
producer.sendQueue(queueId + "_exchange", queueId + "_patt", map);
} catch (Exception e) {
e.printStackTrace();
}
return "發送完畢";
}
嗯。這個測試是 SpringMVC 框架。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
