ActiveMQ整合Spring入門用法解析

更新時(shí)間：2020年10月27日 09:12:42 作者：愛(ài)編程DE文兄

這篇文章主要介紹了ActiveMQ整合Spring入門用法解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

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

　　ActiveMQ和Spring的整合，其實(shí)是把a(bǔ)ctivemq的一些對(duì)象交給spring來(lái)管理，比如連接工廠，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)的對(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)部類的方式，但是在spring這就不能了，還是書(shū)寫(xiě)一個(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)聽(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í)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: