（十七）SpringBoot之使用異步消息服務jms之ActiveMQ

一、引入maven依賴

    <dependencies>
        <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>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

 

二、配置application.properties

# activemq  
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin
#默認為true表示使用內存的activeMQ，不需要安裝activeMQ server
spring.activemq.in-memory=false

#如果此處設置為true，需要加如下的依賴包 <groupId>org.apache.activemq</groupId>  
#          <artifactId>activemq-pool</artifactId>  ，否則會自動配置失敗，報JmsMessagingTemplate注入失敗  
spring.activemq.pool.enabled=false

• 注意value后面不能加空格，即spring.activemq.pool.enabled=false[空格]

 

三、在啟動類中使用異步消息服務@EnableJms注解

@EnableJms
@SpringBootApplication
public class SpringbootActiveMqApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootActiveMqApplication.class, args);
    }
}

 

四、編寫消息生產者

package com.shyroke.jms;

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 {
    @Autowired // 也可以注入JmsTemplate，JmsMessagingTemplate對JmsTemplate進行了封裝
    private JmsMessagingTemplate jmsTemplate;

    // 發送消息，destination是發送到的隊列，message是待發送的消息
    public void sendMessage(Destination destination, final String message) {
        jmsTemplate.convertAndSend(destination, message);
    }
}

 

五、編寫兩個消費者

• 消費者一

package com.shyroke.jms;

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); 
        System.out.println("================="); 
    }  
}  

• 消費者二

package com.shyroke.jms;

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);  
    }  
}  

 

六、測試

package com.shyroke;

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;

import com.shyroke.jms.Producer;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootActiveMqApplicationTests {

    @Autowired
    private Producer producer;
    
    @Test
    public void contextLoads() {
    
        Destination destination=new ActiveMQQueue("mytest.queue");
        
         for(int i=0; i<5; i++){  
                producer.sendMessage(destination, "生產者發送了消息"+i);  
            }  
        
        
    }

}

• 結果