2. 程式人生 > >Spring整合ActiveMQ教程

Spring整合ActiveMQ教程

阿新 • • 發佈：2019-01-12

寫在前面：這篇文章會涉及二者的整合思路，為了能夠更好地讀懂本文，建議最好你能夠在不整合其他環境的情況下使用ActiveMQ編寫簡單的控制檯Demo，並且能夠了解JMS(Java Message Service)。當然，你也可以直接略過整合思路看整合的過程。

簡介

ActiveMQ是Apache出品的一個訊息佇列(Message Queue)軟體，它可以與諸如C#、C++、PHP、Java等語言進行整合。本文重點敘述的是與Java Web中Spring框架的整合，ActiveMQ很好地實現了JMS介面，為編寫高併發的應用程式提供了高效的解決方案。

整合思路

在整合之前，我想先說一下思路，古人云：知其然知其所以然嘛~

Spring最厲害的地方就是它的Bean了，還有它特有的IOC(控制反轉)和AOP(面向切面程式設計)技術。有了這些，我們就可以不用new關鍵字構造物件，同時，可以方便地使用注入往類中的屬性進行初始化。如果你編寫過ActiveMQ之類的JMS應用程式，無論對於訊息的生產者還是消費者，最重要的介面有以下兩個：
1.ConnectionFactory
2.Destination

ConnectionFactory是一切的基礎，有了它才有了Connection，然後才有Session，只有通過Session物件，我們才能建立訊息佇列、構建生產者/消費者，繼而傳送/接收訊息。
Destination

是一切的歸宿，它就像匯流排一樣，生產者發出訊息要發到它上面，消費者取訊息也要從這上面取。

試想，如果這一切都能借助Spring強大的Bean管理的話，我們在編寫程式的時候會更加的方便簡潔。幸運的是，ActiveMQ官方提供了完美的Spring框架支援，一切只需要在xml檔案中配置即可~

Spring官方提供了一個叫JmsTemplate的類，這個類就專門用來處理JMS的，在該類的Bean配置標籤中有兩個屬性connectionFactory-ref和defaultDestination-ref正好對應JMS中的ConnectionFactory和Destination，如果你有興趣檢視原始碼的話，就可以發現JmsTemplate

幫我們做了大量建立的工作，我們只需要用它來進行收發資訊就ok了，而ActiveMQ官方也提供了對應的實現包。

OK，上面是一個基本的思路，還有一些細節會在整合的過程中說明。

整合過程

首先，先說一下我的配置環境：

  • Spring：4.1.3.RELEASE
  • Activemq：5.15.3
  • IDE：IntelliJ IDEA 15.0.5
  • Maven：3.3.9
  • 此次整合是針對訊息佇列中的P2P（點對點）模式

專案結構：

Step1:配置Maven的pom.xml

這裡我只貼出關鍵的依賴選項：
1、JMS依賴

 <dependency>
      <groupId>javax.jms</groupId>
      <artifactId>jms</artifactId>
      <version>1.1</version>
 </dependency>

2、 ActiveMQ核心依賴

<dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-core</artifactId>
      <version>5.5.0</version>
</dependency>
<dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-pool</artifactId>
      <version>5.7.0</version>
</dependency>

3、 Spring依賴(${spring.version}的值為4.1.3.RELEASE)

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-core</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-web</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-oxm</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-tx</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jdbc</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-aop</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context-support</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-test</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jms</artifactId>
      <version>${spring.version}</version>
    </dependency>

4、日誌依賴

    <dependency>
      <groupId>log4j</groupId>
      <artifactId>log4j</artifactId>
      <version>1.2.17</version>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-api</artifactId>
      <version>1.6.1</version>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-log4j12</artifactId>
      <version>1.6.1</version>
    </dependency>

其中，slf4j一定要有，不然的話執行會報錯，如下圖，提示找不到包。

Step2:配置Spring的spring-activemq.xml

1、首先是各種約束

<beans
        xmlns="http://www.springframework.org/schema/beans"
        xmlns:amq="http://activemq.apache.org/schema/core"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:p="http://www.springframework.org/schema/p"
        xmlns:context="http://www.springframework.org/schema/context"
        xmlns:jms="http://www.springframework.org/schema/jms"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
         http://www.springframework.org/schema/beans/spring-beans-2.0.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
         http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd"
></beans>

2、如果你在專案中使用了註解，請開啟註解的自動掃描(這裡略)

3、連線到ActiveMQ，建立一個ConnectionFactory

<bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"
          p:brokerURL="tcp://localhost:61616"></bean>

4、對上步建立的ConnectionFactory進行快取包裝，這樣做的目的是提升效能，對sessions, connections 和 producers進行快取複用，減少開銷。

<bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"
          p:targetConnectionFactory-ref="amqConnectionFactory"
          p:sessionCacheSize="10"></bean>

5、建立訊息目的地，constructor-arg是目的地名稱

<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
        <!--訊息佇列名稱-->
        <constructor-arg value="FOO.TEST"/>
    </bean>

6、構建JmsTemplate

<bean id="producerTemplate" class="org.springframework.jms.core.JmsTemplate"
          p:connectionFactory-ref="cachedConnectionFactory"
          p:defaultDestination-ref="destination"></bean>

7、對於訊息的消費者，Spring官方提供了一個叫 DMLS(DefaultMessageListenerContainer)的容器，它能有效剋制MDB(Message Driven Beans)的缺點。
要使用這個容器，我們需要建立自己的監聽器(下面會提及)，並且註冊進容器中，這樣一旦目的地有訊息，就會自動觸發監聽事件。

<jms:listener-container
        container-type="default"
        connection-factory="amqConnectionFactory"
        acknowledge="auto">
        <jms:listener destination="FOO.TEST" ref="simpleMsgListener" method="onMessage"></jms:listener>
    </jms:listener-container>

其中，connection-factory與前面用org.apache.activemq.ActiveMQConnectionFactory包建立的bean的id對應，listener標籤中destination填前面建立的目的地名稱，ref填listener的bean id。

Step3:建立監聽器

我這裡建立了一個叫SimpleMsgListener的監聽器

package com.test.listener;

import org.springframework.stereotype.Component;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**
 * Created by Martin Huang on 2018/4/20.
 */
//bean id
@Component(value = "simpleMsgListener")
public class SimpleMsgListener implements MessageListener {

    //收到資訊時的動作
    @Override
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println("收到的資訊：" + textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

Step4:建立資訊生成器

package com.test.creator;

import org.springframework.jms.core.MessageCreator;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

/**
 * Created by Martin Huang on 2018/4/20.
 */
public class MyMessageCreator implements MessageCreator {

    private int id;

    public MyMessageCreator(int id)
    {
        this.id = id;
    }

    @Override
    public Message createMessage(Session session) throws JMSException {
        TextMessage message = session.createTextMessage("Spring-ActiveMQ傳送的第【"+id+"】條訊息");
        System.out.println("Spring-ActiveMQ傳送的第【"+id+"】條訊息");
        return message;
    }
}

Step5:建立生產者

package com.test.producer;

import com.test.creator.MyMessageCreator;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

/**
 * Created by Martin Huang on 2018/4/20.
 */
@Component(value = "producer")
public class SimpleProducer {
    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage() throws Exception
    {
        //每次傳送10條資訊
        for(int i = 0 ; i < 10 ; i++)
        {
            //這裡填入建立好的資訊生成器
            jmsTemplate.send(new MyMessageCreator(i));
        }
    }
}

Step6:測試

首先開啟ActiveMQ服務，然後編寫我們的測試類

    @Test
    public void testAmqProducer()
    {
        ApplicationContext context = new ClassPathXmlApplicationContext("spring-activemq.xml");
        SimpleProducer simpleProducer = (SimpleProducer) context.getBean("producer");
        try {
            simpleProducer.sendMessage();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

如果順利的話，你可能會看到以下結果：

ActiveMQ控制檯：

可以發現這裡傳送了10條訊息，但是隻處理了8條。這個測試便體現了DMLC(DefaultMessageListenerContainer)的特點：它是非同步容器，它不一定要等有訊息處理之後，再發送新的訊息。

提示

listener-container可以同時支援多個監聽器，如果你設定了多個監聽器，那麼這些監聽器會輪流去佇列中獲取資訊處理。比如我定義了兩個監聽器SimpleMsgListener和SimpleMsgListener1，那麼執行的效果是這樣的：

示例程式碼

Spring-ActiveMQ

參考資料

相關推薦

Spring整合ActiveMQ教程

寫在前面：這篇文章會涉及二者的整合思路，為了能夠更好地讀懂本文，建議最好你能夠在不整合其他環境的情況下使用ActiveMQ編寫簡單的控制檯Demo，並且能夠了解JMS(Java Message Service)。當然，你也可以直接略過整合思路看整合的過程。 簡介 A

Spring整合activeMQ消息隊列

else finally ant try 工具類 cal 創建 ransac cer 1.配置JMS <!-- Spring提供的JMS工具類，它可以進行消息發送、接收等 --> <bean id="jmsTemplate" class=

SPRING 整合 activemq 的 topic 模式

概要 activemq 支援兩種模式: 1.佇列模式 2. 釋出訂閱者模式，topic有一個主題可以有多個訂閱者。這種情況可以將一個訊息，分發到多個消費者。 實現程式碼 1.生產者 import java.util.Map; import javax.annotation.Resour

spring整合activemq傳遞物件注意事項

初衷：兩個專案分別部署在兩臺伺服器上，專案之間以activemq傳遞object訊息 拓樸結構： 伺服器A：tomcat，專案A--生產者 伺服器B：tomcat、activemq、專案B--消費者 專案A主要程式碼 src/main/resources/ActiveMQ

淺談jms之（通過spring整合activeMQ實現jms）例項

上篇說到使用activemq 實現jms訊息服務 的例項，但是那個是沒有spring進行整合和管理的；其實spring完整提供對jms的支援，所以我們可以通過spring來管理整合activemq 實現jms訊息傳遞服務。 1.建立maven工程（我的專案都是通過maven

spring整合activemq衝突問題

由於版本比較高的activemq-all的jar包中包含了spring的一些包，這會引起包的衝突 <dependency> <groupId>org.apache.activemq</groupId> <artifact

ActiveMQ學習（四）Spring整合ActiveMQ

因為2018年的第一場雪，比以往時候來的更晚一些，所以，本篇文章隔了近5個月才更新，抱歉來的有點晚了各位，不是人造革，皮是真的皮，啊彌陀佛，罪過罪過……本篇，將繼續跟隨以往的腳步，使用Spring MVC+ActiveMQ+Maven+Tomcat，做一個

Spring整合activeMq（一）:點對點模式

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:util="http://www.spring

spring整合activemq傳送MQ訊息[queue模式]例項

queue型別訊息 pom依賴 <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId>

spring整合activemq傳送MQ訊息[Topic模式]例項

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSc

spring 整合 activeMQ非同步傳送郵件

一、訊息佇列的作用 1、非同步處理 2、流量削峰 3、應用解耦 4、日誌處理 二、此處展示的是非同步處理場景 1、構建maven專案，此處不做多餘的說明了，匯入MQ相關的jar包,注意版本的問題，這裡費了好多時間解決衝突 <!-- MQ start--&

Spring整合ActiveMQ（topic 詳細配置步驟）

maven工程新增依賴<dependencies> <!-- Spring --> <dependency> <groupId>org.springframework</groupId>

Spring整合ActiveMQ

mqc .com core tex path utf-8 pen connect mman 第一步：添加依賴 <dependency> <groupId>org.apache.activemq</groupId>

Spring整合ActiveMQ-序列化的 Java物件

JMS定義了五種不同的訊息正文格式，以及呼叫的訊息型別，允許你傳送並接收以一些不同形式的資料，提供現有訊息格式的一些級別的相容性。 · StreamMessage -- Java原始值的資料流 · MapMessage--一套名稱-值對 · TextMessage--一個字

Spring整合activemq，實現單消費者消費

1.ActiveMQ 是Apache出品，最流行的，能力強勁的開源訊息匯流排，實現了JMS（Java MessageService，實際上是指JMS API）可用來實現基於訊息的RPC(過程遠端呼叫

ActiveMQ學習總結（二）——spring整合ActiveMQ

本文有兩篇參考文獻，因此有兩個例項，專案結構如下圖所示：3.例項1資訊傳送者：HelloSender.javapackage edu.sjtu.erplab.springactivemq;import javax.jms.JMSException;import javax.jms.Session;import

6、ActiveMQ入門教程（六）Spring與ActiveMQ整合

在這一篇部落格分享一下消費者，使用監聽的實現方式。 1. pom.xml 2. 生產者 package org.ygy.mq.lesson04;   import javax.jms.JMSException;   import javax.jms.Mes

深入淺出JMS(四)--Spring和ActiveMQ整合的完整實例

訂閱 實例 schema -i 同步和異步 生產 技術分享 .com factor 第一篇博文深入淺出JMS(一)–JMS基本概念，我們介紹了JMS的兩種消息模型：點對點和發布訂閱模型，以及消息被消費的兩個方式：同步和異步，JMS編程模型的對象，最後說了JMS的優點。 第二

Spring mvc4 + ActiveMQ 整合

ted toolbar :active 文件 nat ava logs const urn 轉載：http://www.cnblogs.com/leiOOlei/p/5075402.html 一、配置部分 二、代碼部分 三、頁面部分 四、Controller控制器 五、效果

Spring和ActiveMQ整合的完整實例

beans util caching consumer str blank prop ner 消息發送 Spring和ActiveMQ整合的完整實例 前言 這篇博文,我們基於Spring+JMS+ActiveMQ+Tomcat，做一個Spring4.1.0和Acti