Spring和SpringBoot整合ActiveMQ

一:ActiveMQ的Broker

ActiveMQ除了可以作為獨立程序單獨部署在伺服器上之外，也可以很小巧的内嵌在程式中啟動，下面我們來簡單的介紹内置Broker啟動的一種方式。

啟動上面的main方法之後,就可以使用生産者和消費者對我們部署的這個小型的ActiveMQ進行通路了,三者的位址要一樣,十分的小巧友善

二:Spring整合ActiveMQ

由于進行簡單的整合測試,沒有使用MVC的分層架構,僅僅使用了一個service,要想通路Spring容器中的bean對象時,需要目前對象也需要是一個bean對象,是以我用@Service将生産者和消費者都聲明成bean,友善我調用其他的bean。

在Topic模式中,如果沒有消費者進行訂閱,那麼生産者生産出來的消息就是非消息,我們可以通過配置監聽來實作不期待消費者,實作消費

生産者和消費者的代碼不做改動,隻啟動生産者即可,當生産者生産出消息之後,會被監聽器立刻監聽到

三:SpringBoot整合ActiveMQ(隊列)

使用@JmsListener注解進行監聽消息