SpringBoot內建RabbitMQ
一、建立SpringBoot項目
File → New Project →Spring Initializr → Next
二、配置檔案編寫
留意pom.xml檔案有無此包,沒有要加上去
配置application.properties檔案，配置rabbitmq的安裝位址、端口以及賬戶資訊
三、生成隊列
四、建立生産者
五、建立第一個消費者
六、編寫測試類
結果是生成了兩個隊列,都隻有一個隊列在工作,因為第一個生産者隻路由了”queue1”
七、編寫第二個消費者,測試一對多模式
八、測試類中添加方法
//一對多
@Test public void oneToMany() throws Exception {
for (int i=0;i<50;i++){ firstProducer.send(i); Thread.sleep(300); }
}
測試結果
九、注意事項
由于我的包都不是在啟動類下,是以需要掃描其他包,不然會注入類失敗!!
源碼:https://download.csdn.net/download/yan95520/11174024