日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

学习activemq,在spring中activemq的配置信息

發布時間:2023/12/2 编程问答 24 豆豆
生活随笔 收集整理的這篇文章主要介紹了 学习activemq,在spring中activemq的配置信息 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

提供者:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.springframework.org/schema/jms"
?xmlns:context="http://www.springframework.org/schema/context"
?xmlns:amq="http://activemq.apache.org/schema/core"
?xsi:schemaLocation="
??http://www.springframework.org/schema/beans
??http://www.springframework.org/schema/beans/spring-beans.xsd
??http://www.springframework.org/schema/jms
??http://www.springframework.org/schema/jms/spring-jms.xsd
??http://activemq.apache.org/schema/core
??http://activemq.apache.org/schema/core/activemq-core.xsd
??http://www.springframework.org/schema/context
??http://www.springframework.org/schema/context/spring-context.xsd">
?<!-- 需要創建一個連接工廠,連接ActiveMQ. ActiveMQConnectionFactory. 需要依賴ActiveMQ提供的amq標簽 -->
?<!-- amq:connectionFactory 是bean標簽的子標簽, 會在spring容器中創建一個bean對象. 可以為對象命名.
??類似: <bean id="" class="ActiveMQConnectionFactory"></bean> -->
?<amq:connectionFactory brokerURL="tcp://192.168.46.131:61616" password="admin"
?userName="admin"? id="amqconnectionFactory">
?</amq:connectionFactory>?
?<!-- 配置池化的ConnectionFactory。 為連接ActiveMQ的connectionFactory提供連接池 -->
?<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactoryBean">
?<property name="connectionFactory" ref="amqconnectionFactory"></property>
?<property name="maxConnections" value="5"></property>
?</bean>
?<!-- spring管理JMS相關代碼的時候,必須依賴jms標簽庫. spring-jms提供的標簽庫. -->
?<!-- 定義Spring-JMS中的連接工廠對象 CachingConnectionFactory - spring框架提供的連接工廠對象.
??不能真正的訪問MOM容器. 類似一個工廠的代理對象. 需要提供一個真實工廠,實現MOM容器的連接訪問. -->
?<!-- 配置有緩存的ConnectionFactory,session的緩存大小可定制。 -->
?<bean id="cachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
?<property name="targetConnectionFactory" ref="pooledConnectionFactory"></property>
?<property name="sessionCacheSize" value="3"></property>
?</bean> <!-- JmsTemplate配置 -->
?<bean id="template" class="org.springframework.jms.core.JmsTemplate">
??<!-- 給定連接工廠, 必須是spring創建的連接工廠. -->
??<property name="connectionFactory" ref="cachingConnectionFactory"></property>
??<!-- 可選 - 默認目的地命名 -->
??<property name="defaultDestinationName" value="test-spring"></property>
?</bean>
</beans> 消費者: <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
?xmlns:jms="http://www.springframework.org/schema/jms"
?xmlns:amq="http://activemq.apache.org/schema/core"
?xsi:schemaLocation="
??http://www.springframework.org/schema/beans
??http://www.springframework.org/schema/beans/spring-beans.xsd
??http://www.springframework.org/schema/jms
??http://www.springframework.org/schema/jms/spring-jms.xsd
??http://activemq.apache.org/schema/core
??http://activemq.apache.org/schema/core/activemq-core.xsd">
?<!-- 需要創建一個連接工廠,連接ActiveMQ. ActiveMQConnectionFactory. 需要依賴ActiveMQ提供的amq標簽 -->
?<!-- amq:connectionFactory 是bean標簽的子標簽, 會在spring容器中創建一個bean對象.
??可以為對象命名. 類似: <bean id="" class="ActiveMQConnectionFactory"></bean>
? -->
?<amq:connectionFactory brokerURL="tcp://192.168.46.131:61616"
??userName="admin" password="admin" id="amqConnectionFactory"/> <!-- spring管理JMS相關代碼的時候,必須依賴jms標簽庫. spring-jms提供的標簽庫. -->
?<!-- 定義Spring-JMS中的連接工廠對象
??CachingConnectionFactory - spring框架提供的連接工廠對象. 不能真正的訪問MOM容器.
???類似一個工廠的代理對象. 需要提供一個真實工廠,實現MOM容器的連接訪問.
? -->
?<bean id="connectionFactory"
??class="org.springframework.jms.connection.CachingConnectionFactory">
??<property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
??<property name="sessionCacheSize" value="3"></property>
?</bean>
?
?<!-- 注冊監聽器 -->
?<!-- 開始注冊監聽.
??需要的參數有:
???acknowledge - 消息確認機制
???container-type - 容器類型 default|simple
???simple:SimpleMessageListenerContainer最簡單的消息監聽器容器,只能處理固定數量的JMS會話,且不支持事務。
???default:DefaultMessageListenerContainer是一個用于異步消息監聽器容器 ,且支持事務????????
???destination-type - 目的地類型. 使用隊列作為目的地.
???connection-factory - 連接工廠, spring-jms使用的連接工廠,必須是spring自主創建的
???不能使用三方工具創建的工程. 如: ActiveMQConnectionFactory.
? -->
?<jms:listener-container acknowledge="auto" container-type="default"
??destination-type="queue" connection-factory="connectionFactory" >
??<!-- 在監聽器容器中注冊某監聽器對象.
???destination - 設置目的地命名
???ref - 指定監聽器對象
?? -->
??<jms:listener destination="test-spring" ref="myListener"/>
?</jms:listener-container>
?
</beans> 其實差異并沒啥區別,多注冊了一個監聽

轉載于:https://www.cnblogs.com/MTAngel/p/10981843.html

創作挑戰賽新人創作獎勵來咯,堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的学习activemq,在spring中activemq的配置信息的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。