国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術(shù)文章
文章詳情頁

ActiveMQ整合Spring入門用法解析

瀏覽:8日期:2023-08-05 15:34:13

一.ActiveMQ整合Spring基礎(chǔ)

ActiveMQ和Spring的整合,其實(shí)是把a(bǔ)ctivemq的一些對象交給spring來管理,比如連接工廠,queue,top等等

二.依賴

除了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)的對象

》生產(chǎn)者需要配置的對象:activemq原生連接工廠,spring包裝過的工廠,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)者對象: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對象 --><bean name='queueDestination' class='org.apache.activemq.command.ActiveMQQueue'> <constructor-arg name='name' value='spring-active-queue'></constructor-arg></bean><!-- 配置topic對象 --><bean name='topicDestination' class='org.apache.activemq.command.ActiveMQTopic'> <constructor-arg name='name' value='spring-active-topic'></constructor-arg></bean>

測試代碼:

//測試生產(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);//獲取目的對象 Destination queue = (Destination) ioc.getBean('queueDestination');//發(fā)送消息,并設(shè)置目的對象和消息 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)容,因此是需要書寫代碼的

》消費(fèi)者需要配置的對象:activemq原生連接工廠,spring包裝過的工廠,監(jiān)聽容器(消費(fèi)者),監(jiān)聽器,queue,topic

》之前監(jiān)聽器我們是直接實(shí)現(xiàn)匿名內(nèi)部類的方式,但是在spring這就不能了,還是書寫一個(gè)實(shí)現(xiàn)類并繼承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)聽器 --><bean name='myMessageListener' class='cn.e3mall.search.listener.MyMessageListener'></bean><!-- 配置監(jiān)聽容器:消費(fèi)者 --><bean name='messageListenerContainer' class='org.springframework.jms.listener.DefaultMessageListenerContainer'> <!-- 設(shè)置連接工廠 --> <property name='connectionFactory' ref='connectionFactory'></property> <!-- 設(shè)置目的對象 --> <property name='destination' ref='queueDestination'></property> <!-- 設(shè)置監(jiān)聽器 --> <property name='messageListener' ref='myMessageListener'></property></bean><!-- 配置queue對象 --><bean name='queueDestination' class='org.apache.activemq.command.ActiveMQQueue'> <constructor-arg name='name' value='spring-active-queue'></constructor-arg></bean><!-- 配置topic對象 --><bean name='topicDestination' class='org.apache.activemq.command.ActiveMQTopic'> <constructor-arg name='name' value='spring-active-topic'></constructor-arg></bean>

測試代碼:

@Test public void testListener() throws IOException { ApplicationContext ioc = new ClassPathXmlApplicationContext('classpath:spring/applicationContext-activemq.xml'); System.in.read(); }

小結(jié):我們的測試代碼很簡單,只要把容器啟動(dòng)了,監(jiān)聽器就會(huì)一致監(jiān)聽著。不需要寫任何代碼,監(jiān)聽器只要一直關(guān)注目的對象Destination是否有消息發(fā)送過來

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Spring
相關(guān)文章:
主站蜘蛛池模板: 鲁老汉精品视频在线观看 | 国产午夜免费视频片夜色 | 欧美视频在线观在线看 | 欧美成人免费sss | 美女张开双腿让男人桶视频免费 | 成人亚洲欧美 | 她也啪97在线视频 | 亚洲日本va午夜中文字幕 | 久热精品免费视频 | 日韩三级在线 | 成人欧美精品一区二区不卡 | 亚洲图片偷拍自拍 | 国产成人午夜极速观看 | 久草在线资源 | 久草在在线视频免费 | 亚洲日本精品 | 免费伦费一区二区三区四区 | 99精品在线播放 | 免费看a级| 国产精品理论 | 亚洲欧美网址 | 成人a免费α片在线视频网站 | 免费看一级欧美毛片 | 亚洲第一区在线 | 久在线观看视频 | 在线免费视频 | 欧美日韩精品一区二区三区不卡 | 国产欧美日韩一区二区三区在线 | 一本大道香蕉久在线不卡视频 | 欧美日韩亚洲在线观看 | 最新国产三级 | 久久综合精品国产一区二区三区 | 午夜免费69性视频爽爽爽 | 国产日韩欧美在线 | 久草观看 | 国产成人在线免费 | 国产亚洲综合成人91精品 | 欧美日本在线一区二区三区 | 美女视频很黄很a免费国产 美女视频黄.免费网址 | 成人看片黄a免费 | 天天综合色一区二区三区 |