ActiveMQ整合Spring入門(mén)用法解析
一.ActiveMQ整合Spring基礎(chǔ)
ActiveMQ和Spring的整合,其實(shí)是把a(bǔ)ctivemq的一些對(duì)象交給spring來(lái)管理,比如連接工廠,queue,top等等
二.依賴(lài)
除了activemq本身提供的jar包外,還需要兩個(gè)spring整合activemq的jar:
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> </dependency> <!-- activemq --> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> </dependency>
三.在spring配置文件中,配置activemq相關(guān)的對(duì)象
》生產(chǎn)者需要配置的對(duì)象:activemq原生連接工廠,spring包裝過(guò)的工廠,JmsTemplate(生產(chǎn)者),queue,topic
<!-- 配置activemq的連接工廠 --><bean name='activemqConnectionFactory' class='org.apache.activemq.ActiveMQConnectionFactory'> <constructor-arg index='0' value='tcp://192.168.xx.xxx:61616'></constructor-arg></bean><!-- 配置spring包裝的連接工廠 --><bean name='connectionFactory' class='org.springframework.jms.connection.SingleConnectionFactory'> <!-- 設(shè)置activemq的連接工廠 --> <property name='targetConnectionFactory' ref='activemqConnectionFactory'></property></bean><!-- 配置生產(chǎn)者對(duì)象:jmstemplate --><bean name='jmsTemplate' class='org.springframework.jms.core.JmsTemplate'> <!-- 設(shè)置工廠 --> <!-- <constructor-arg name='connectionFactory' ref='connectionFactory'></constructor-arg> --> <property name='connectionFactory' ref='connectionFactory'></property></bean><!-- 配置queue對(duì)象 --><bean name='queueDestination' class='org.apache.activemq.command.ActiveMQQueue'> <constructor-arg name='name' value='spring-active-queue'></constructor-arg></bean><!-- 配置topic對(duì)象 --><bean name='topicDestination' class='org.apache.activemq.command.ActiveMQTopic'> <constructor-arg name='name' value='spring-active-topic'></constructor-arg></bean>
測(cè)試代碼:
//測(cè)試生產(chǎn)者發(fā)生queue @Test public void testJMSTemplateByQueue() throws Exception {//創(chuàng)建spring容器 ApplicationContext ioc = new ClassPathXmlApplicationContext('classpath:spring/applicationContext-activemq.xml');//獲取jmstemplate JmsTemplate jmsTemplate = ioc.getBean(JmsTemplate.class);//獲取目的對(duì)象 Destination queue = (Destination) ioc.getBean('queueDestination');//發(fā)送消息,并設(shè)置目的對(duì)象和消息 jmsTemplate.send(queue,new MessageCreator() { public Message createMessage(Session session) throws JMSException {TextMessage message = session.createTextMessage();message.setText('hello spring activemq');return message; } });
小結(jié):生產(chǎn)者是需要在特定的時(shí)間發(fā)送指定的消息內(nèi)容,因此是需要書(shū)寫(xiě)代碼的
》消費(fèi)者需要配置的對(duì)象:activemq原生連接工廠,spring包裝過(guò)的工廠,監(jiān)聽(tīng)容器(消費(fèi)者),監(jiān)聽(tīng)器,queue,topic
》之前監(jiān)聽(tīng)器我們是直接實(shí)現(xiàn)匿名內(nèi)部類(lèi)的方式,但是在spring這就不能了,還是書(shū)寫(xiě)一個(gè)實(shí)現(xiàn)類(lèi)并繼承messageListener接口
<!-- 配置activemq的連接工廠 --><bean name='activemqConnectionFactory' class='org.apache.activemq.ActiveMQConnectionFactory'> <constructor-arg index='0' value='tcp://192.168.xx.xxx:61616'></constructor-arg></bean><!-- 配置spring包裝的連接工廠 --><bean name='connectionFactory' class='org.springframework.jms.connection.SingleConnectionFactory'> <!-- 設(shè)置activemq的連接工廠 --> <property name='targetConnectionFactory' ref='activemqConnectionFactory'></property></bean><!-- 配置監(jiān)聽(tīng)器 --><bean name='myMessageListener' class='cn.e3mall.search.listener.MyMessageListener'></bean><!-- 配置監(jiān)聽(tīng)容器:消費(fèi)者 --><bean name='messageListenerContainer' class='org.springframework.jms.listener.DefaultMessageListenerContainer'> <!-- 設(shè)置連接工廠 --> <property name='connectionFactory' ref='connectionFactory'></property> <!-- 設(shè)置目的對(duì)象 --> <property name='destination' ref='queueDestination'></property> <!-- 設(shè)置監(jiān)聽(tīng)器 --> <property name='messageListener' ref='myMessageListener'></property></bean><!-- 配置queue對(duì)象 --><bean name='queueDestination' class='org.apache.activemq.command.ActiveMQQueue'> <constructor-arg name='name' value='spring-active-queue'></constructor-arg></bean><!-- 配置topic對(duì)象 --><bean name='topicDestination' class='org.apache.activemq.command.ActiveMQTopic'> <constructor-arg name='name' value='spring-active-topic'></constructor-arg></bean>
測(cè)試代碼:
@Test public void testListener() throws IOException { ApplicationContext ioc = new ClassPathXmlApplicationContext('classpath:spring/applicationContext-activemq.xml'); System.in.read(); }
小結(jié):我們的測(cè)試代碼很簡(jiǎn)單,只要把容器啟動(dòng)了,監(jiān)聽(tīng)器就會(huì)一致監(jiān)聽(tīng)著。不需要寫(xiě)任何代碼,監(jiān)聽(tīng)器只要一直關(guān)注目的對(duì)象Destination是否有消息發(fā)送過(guò)來(lái)
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. phpstudy apache開(kāi)啟ssi使用詳解2. .Net加密神器Eazfuscator.NET?2023.2?最新版使用教程3. JSP之表單提交get和post的區(qū)別詳解及實(shí)例4. Xml簡(jiǎn)介_(kāi)動(dòng)力節(jié)點(diǎn)Java學(xué)院整理5. 詳解瀏覽器的緩存機(jī)制6. jsp文件下載功能實(shí)現(xiàn)代碼7. 如何在jsp界面中插入圖片8. ASP動(dòng)態(tài)網(wǎng)頁(yè)制作技術(shù)經(jīng)驗(yàn)分享9. jsp實(shí)現(xiàn)登錄驗(yàn)證的過(guò)濾器10. .Net Core和RabbitMQ限制循環(huán)消費(fèi)的方法
