本篇主要講解如何在spring中配置jms,關于spring本身的配置本文就不多做介紹了。
在使用spring-jms之前,先配置相關依賴。
這裡隻是簡單介紹如何安裝啟動activemq,詳細請參考官方文檔。
安裝:
- 解壓:tar zxvf activemq-x.x.x-bin.tar.gz
- 增權重限:
<code>cd [activemq_install_dir]/bin</code>
<code>chmod 755 activemq</code>
啟動:
<code>./activemq start</code>
檢查是否啟動成功:
<code>netstat -nl|grep 61616</code>
寫一個jmsmessageproducer異步發送消息:
寫完listener之後還需要在配置檔案中配置這個listener:
寫一個jmsmessageproducertest測試一下發送:
看一下運作結果:

消息已經異步發送成功,雖然還沒有消費者消費,消息就像被成功處理一樣。
寫一個jmsmessageconsumertest 測試一下接收:
我們可以看到消費者接收到一條消息,這條消息正是上面發送者發送的第一條消息。如果我們再運作一遍則會收到第二條消息。如果所有消息都消費完了,broker中沒有消息了,此時jmsmessageconsumertest程序便會挂起一直等待,直到有新消息産生,大家可以試一下。
按照上面3.2節寫介紹一個<code>jmsmessagelistener</code>并将其配置到 <code>listener-container</code>中。此時<code>jmsmessagelistener</code>便會實時監聽<code>brokerurl="tcp://192.168.134.128:61616"</code>這個端口,一旦有消息産生,便會在<code>onmessage()</code>方法接收到消息。其實此時我們的producer和監聽器都在同一個應用中,如果我們再運作producer,可以看到如下結果:
通過運作結果可以看到,每當生産者生産消息,監聽器便會實時接收到消息。