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的方式,開啟後直接全部點 下一步 直到安裝成功。選擇解壓或者其它非安裝的方式,記得新增一下系統環境...