SpringBoot怎樣整合ActiveMQ？ | 帶你讀《SpringBoot實戰教程》之三十五

上一篇：SpringBoot如何內建MongoDB？ | 帶你讀《SpringBoot實戰教程》之三十四 下一篇：SpringBoot怎樣整合RabbitMQ？ | 帶你讀《SpringBoot實戰教程》之三十六

本文來自于千鋒教育在阿裡雲開發者社群學習中心上線課程《SpringBoot實戰教程》，主講人楊紅豔，

點選檢視視訊内容

。

SpringBoot整合ActiveMQ

ActiveMQ是符合JMS規範的消息管理者。

如何使用呢？

在工程中添加依賴：

<!-- 整合ActiveMQ的依賴 -->
       <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-activemq</artifactId>  
       </dependency>            

全局配置檔案進行配置

spring.activemq.broker-url=tcp://192.168.25.129:61616
spring.activemq.in-memory=true
spring.activemq.user=admin
spring.activemq.password=admin
#如果此處設定為true，需要加如下面的依賴包，否則會自動配置失敗，JmsMessagingTemplate
spring.activemq.pool.enabled=false           

依賴如下：

<dependency>  
                <groupId>org.apache.activemq</groupId>  
                <artifactId>activemq-pool</artifactId> 
     </dependency>            

如何實作消息的發送和消息的接收?

建立包：com.qianfeng.activemq：

@Component
public class Producer {

   @Autowired
    private JmsMessagingTemplate jmsTemplate;


    //發送消息
    public void sendMessage(Destination des, String message) {
        jmsTemplate.convertAndSend(des, message);
     }
}


@Component
public class Consumer {

    @JmsListener(destination="myqueues")
    public void receiveMsg(String text) {
        System.out.println(text+"......");
    }
}           

建立包com.qianfeng.controller：

@Controller
public class TestController {

    @Autowired
    private Producer producer;


    @RequestMapping("/activemq")
    @ResponseBody
    public String tests() {
        //點對點消息
        Destination des = new ActiveMQQueue("myqueues");
        for(int i = 1; i <= 3; i++) {
            producer.sendMessage(des, "hello");
        }
        return "ok";
    }
}           

在啟動類中添加所有需要掃描的包：

@SpringBootApplication(scanBasePackages="com.qianfeng")           

執行結果：

配套視訊