Spring Boot整合ActiveQ實現消息收發和訂閱

javax.jms.ConnectionFactory接口提供了一個標準的用於建立一個javax.jms.Connection的方法，javax.jms.Connection用於和JMS代理（broker）交互。儘管爲了使用JMS，Spring須要一個ConnectionFactory，但一般不須要直接使用它，而是依賴於上層消息抽象，Spring Boot會自動配置發送和接收消息須要的設施（infrastructure）。

若是發現ActiveMQ在classpath下可用，Spring Boot會配置一個ConnectionFactory。若是須要代理，將會開啓一個內嵌的，已經自動配置好的代理（只要配置中沒有指定代理URL）。

引入spring-boot-starter-activemq，在pom.xml配置文件中增長配置以下（基於以前章節「Spring Boot 構建框架」中的pom.xml文件）：

<dependency>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-activemq</artifactId>  
</dependency>

ActiveMQ配置是經過spring.activemq.*中的外部配置來控制的。在application.properties配置文件增長以下內容：

spring.activemq.broker-url=tcp://192.168.1.100:9876
spring.activemq.user=admin
spring.activemq.password=secret

默認狀況下若是目標不存在，ActiveMQ將建立一個，因此目標是經過它們提供的名稱解析出來的。

應用整合AxtiveQ支持案例

消息生產者，具體代碼以下：

import javax.jms.Destination;  
  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.jms.core.JmsMessagingTemplate;  
import org.springframework.stereotype.Service;  
  
@Service("producer")  
public class Producer {  
       // 該方式能夠注入JmsTemplate，JmsMessagingTemplate對JmsTemplate進行了封裝 
    @Autowired
    private JmsMessagingTemplate jmsTemplate; 
     
    // 發送消息，destination是發送到的隊列，message是待發送的消息  
    public void sendMessage(Destination destination, final String message){  
        jmsTemplate.convertAndSend(destination, message);  
    }  
}

兩個消息消費者，具體代碼以下：

/***************** Consumer1 ******************/

import org.springframework.jms.annotation.JmsListener;  
import org.springframework.stereotype.Component;  
  
@Component  
public class Consumer {  
        // 使用JmsListener配置消費者監聽的隊列，其中text是接收到的消息  
    @JmsListener(destination = "mytest.queue")  
    public void receiveQueue(String text) {  
        System.out.println("Consumer收到的報文爲:"+text);  
    }  
} 

/***************** Consumer2 ******************/

import org.springframework.jms.annotation.JmsListener;  
import org.springframework.stereotype.Component;  
  
@Component  
public class Consumer2 {  
        // 使用JmsListener配置消費者監聽的隊列，其中text是接收到的消息  
    @JmsListener(destination = "mytest.queue")  
    public void receiveQueue(String text) {  
        System.out.println("Consumer2收到的報文爲:"+text);  
    }  
}

注意的是消息消費者的類上必須加上@Component或@Service註解，這樣的話，消息消費者類就會被委派給Listener類，原理相似於使用SessionAwareMessageListener以及MessageListenerAdapter來實現消息驅動POJO。

簡單測試消息狀況，具體代碼以下：

import javax.jms.Destination;  
  
import org.apache.activemq.command.ActiveMQQueue;  
import org.junit.Test;  
import org.junit.runner.RunWith;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.boot.test.context.SpringBootTest;  
import org.springframework.test.context.junit4.SpringRunner;  
  
@RunWith(SpringRunner.class)  
@SpringBootTest  
public class SpringbootJmsApplicationTests {  
      
    @Autowired  
    private Producer producer;  
      
    @Test  
    public void contextLoads() throws InterruptedException {  
        Destination destination = new ActiveMQQueue("mytest.queue");  
          
        for(int i=0; i<100; i++){  
            producer.sendMessage(destination, "my site is blog.yoodb.com");  
        }  
    }  
  
}

運行結果以下：

Consumer2收到的報文爲:my site is blog.yoodb.com
Consumer收到的報文爲:my site is blog.yoodb.com
Consumer2收到的報文爲:my site is blog.yoodb.com
Consumer收到的報文爲:my site is blog.yoodb.com
Consumer2收到的報文爲:my site is blog.yoodb.com
Consumer收到的報文爲:my site is blog.yoodb.com
Consumer2收到的報文爲:my site is blog.yoodb.com
Consumer收到的報文爲:my site is blog.yoodb.com
Consumer2收到的報文爲:my site is blog.yoodb.com
Consumer收到的報文爲:my site is blog.yoodb.com
Consumer2收到的報文爲:my site is blog.yoodb.com
Consumer收到的報文爲:my site is blog.yoodb.com
Consumer2收到的報文爲:my site is blog.yoodb.com