sprng-jms消息服務小項目
所需的包:
spring的基礎包
spring-jms-xx包
spring-message–xx包
commons-collection-xx包
commons-pool2-xx包
aop切面的包: spring-aop,spring-aspect,aopalliance,aspectjrt.jar,aspectjweaver.jar
配置:
1.配置connectionfactory
2.配置jmstemplate;
3.配置destination
4.配置listener
5.配置container
話不多說，直接上代碼
前提是你已經開啟了activemq服務
看一下項目架構
臨聽器有兩種實作方案: 一種是采用原生的jms的messagelistener
另一種是采用spring的方案:sessionawaremessagelistener
前一種隻能消費消息,不能發送回送消息
後一種可以再接到消息後，給生産者回送消息,它自己即是生産者也是消費者
所有所需的連接配接工、目的地等都是通過spring注入的,具體看後面的配置檔案
發送消息的接口
生産者一
生産者二
消費者一
消費者二
最後看一些spring的配置檔案
看一下第一種的測試類
運作結果
第二種方案測試類