作者：追夢1819
原文：https://www.cnblogs.com/yanfei1819/p/11190048.html
版權宣告：本文為博主原創文章，轉載請附上博文連結！

引言

  前一章節中，我們詳細闡述了 ActiveMQ 的安裝和使用。其實在網站發展壯大的過程中，訊息中介軟體是無法忽視的技術框架，其重要性在前一章也作了詳細的說明。如此重要的技術，SpringBoot 生態圈自然也是不會"放過"的了，必然要整合到它的體系中去。

  本章將闡述 SpringBoot 整合 ActiveMQ。

使用

首先建立專案，引入 maven 依賴：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!-- 該啟動器是後面做測試用，非必須的 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
 

第二步，配置相關資訊：

spring.activemq.broker-url=tcp://xxx:61616
spring.activemq.in-memory=true
spring.activemq.pool.enabled=false

第三步，建立訊息生產者：

package com.yanfei1819.activemq.producer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
import javax.jms.Destination;

/**
 * Created by 追夢1819 on 2019-06-26.
 */
@Component
public class Producer {
    @Autowired
    private JmsMessagingTemplate template;
    public void sendMessage(Destination destination, String message){
        template.convertAndSend(destination,message);
    }
}
 

第四步，建立訊息消費者：

package com.yanfei1819.activemq.consumer;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;

/**
 * Created by 追夢1819 on 2019-06-26.
 */
@Service
public class Consumer {
    @JmsListener(destination = "active.queue")
    public void receive(String text) {
        System.out.println("consumer接收到的報文為:" + text);
    }
}
 

最後，建立測試介面：

package com.yanfei1819.activemq.web.controller;

import com.yanfei1819.activemq.producer.Producer;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.jms.Destination;

/**
 * Created by 追夢1819 on 2019-06-26.
 */
@Controller
public class ActivemqController {

    @Autowired
    private Producer producer;

    @ResponseBody
    @RequestMapping("/test")
    public void test(){
        Destination destination=new ActiveMQQueue("active.queue");
        for (int i = 0; i <50 ; i++) {
            producer.sendMessage(destination,"我是追夢1819，我的微信公眾號是 technology-and-life ");
        }
    }
}

對以上程式碼作一個簡單的說明：

1. 為了簡化模型來說明 SpringBoot 中 Activemq 的使用，以上的訊息生產者和訊息消費者都只做了最簡單的模擬，沒有任何邏輯；
2. 以上的測試使用介面進行測試（作者比較喜歡這種方式），不侷限這種方式，讀者可以用單元測試。

啟動專案，先看看 ActiveMQ 介面：

可以看到生產出來的訊息，已經被注入到 ActiveMQ 中去了。

然後再訪問以上測試介面：http://localhost:8080/test，再看 ActiveMQ 介面：

生產者生產的訊息，被消費者消費。

控制檯的資訊是：

  以上演示了 ActiveMQ 在 SpringBoot 專案中的使用。其餘的一些詳細的測試，讀者可以按照前一章 ActiveMQ 的說明，自行測試。此處由於篇幅所限，就不做冗餘闡述。

總結

  看完以上的示例，讀者應該能繼續感受到 SpringBoot 框架的"開箱即用"的特性和極簡模式。關注幾個註解或者幾個元件，就能用的很順暢。

  但是，還是重複那句，框架的封裝度越高，用起來越簡單，但是對底層的原理的理解越難。如果碰到了問題，也更難追蹤。所以作者建議讀者，特別是新人或者剛接觸 SpringBoot 的讀者，一定要在使用的基礎上，去理解每一個被整合的框架的使用和原理（當然，如果基礎好，能夠讀底層原始碼更好了）。萬不可為了使用而使用。就像一個同事說的，如果哪一天 Spring 生態圈被別的框架取代了，那你就失業了。

  憂患意識一定要保持著。

相關推薦