rabbitMQ與spring整合在專案中使用

2021-07-25 15:51:49 字數 1388 閱讀 5748

rabbitmq與spring整合

1、引入spring-rabbit依賴

org.springframework.amqpgroupid>

spring-rabbitartifactid>

1.5.1.releaseversion>

dependency>

2、對應spring的版本4.2.8.release

3、配置sping-mq.xml配置檔案

id="connectionfactory"

host="$"

port="$"

username="$"

password="$" />

connection-factory="connectionfactory" />

id="test-template"

connection-factory="connectionfactory"

exchange="test.exchange" />

name="test.a.queue" />

name="test.b.queue" />

name="test.exchange">

queue="test.a.queue" />

rabbit:bindings>

rabbit:fanout-exchange>

connection-factory="connectionfactory"

concurrency="10"

prefetch="5">

queue-names="test.a.queue"

method="listen"

ref="testlistener" />

rabbit:listener-container>

id="testlistener"

class="org.t.testlistener"/>

此時可以使用test-template向exchange中推送訊息,exchange接收到訊息後向其繫結的佇列進行訊息投遞。

exchange有兩種型別:

a. fanout型別的exchange,該型別的exchange會對其繫結的佇列進行廣播(即當前exchange繫結的所有佇列都會被投遞)

b. direct型別的exchange,改型別的exchange會根據key投遞到不同的佇列(key可以使用萬用字元,具體參考文件)

使用rabbitmq時候遇到的問題

1 監聽b佇列,向a佇列推送訊息,結果***也可以監聽到訊息

原因:要通過rabbitmq提供的網頁管理工具檢查該exchange繫結到哪些queue上去了,要保證該exchange只向a佇列投遞,而不是既繫結了a佇列又繫結了b佇列。

RabbitMQ的介紹與spring整合

本文主要講述的是個人參考官網及其他前輩部落格,對rabbitmq的一些理解與spring整個rabbitmq.rabbitmq是乙個由erlang開發的amqp advanced message queue 的開源實現,官網位址 amqp就是乙個協議,是乙個高階抽象層訊息通訊協議。雖然在同步訊息通訊...

rabbitmq安裝與配置

rabbitmq的安裝和簡單配置 rabbitmq的說明和特性見官網 然後xz d rabbitmq server generic unix 3.6.2.tar.xz 之後用tar xvf 解壓 rabbitmq server generic unix 3.6.2.tar 注意 使用tar zxvf...

RabbitMQ配置與安裝

示例使用的是rabbitmq 3.7.9,因為rabbitmq需要建立在erlang otp平台上,首先要安裝erlang。erlang 二 開始安裝 1 先安裝erlang,如果使用opt win64的方式,開啟後直接全部點 下一步 直到安裝成功。選擇解壓或者其它非安裝的方式,記得新增一下系統環境...