spring boot框架學習12-spring boot整合active mq方法1

本章節主要內容：

主要從如下幾個方面講解：

mybatis和spring boot整合、redis(單機版)和spring boot整合、redis(集羣)和spring boot整合、httpclient和spring boot整合、rabbitMQ/active MQ和spring boot整合。

歡迎關注凱哥公衆號：凱哥Java(kaigejava)

凱哥我的博客：www.kaigejava.com

 

本節主要內容：

 

1:spring boot整合active mq方案一

方案一是簡單的，生產者和消費者都在同一個應用項目中。

一：active mq相關

1：active mq下載：

 

 

2：啓動

 

 

在bin文件夾下有64和32位找到本身系統響應的文件夾打開。凱哥使用的是64位的

 

 

雙擊activemq.bat批處理就啓動了。

啓動以下圖：

 

 

二：spring boot中應用active mq

2.1：在pom.xml文件中添加mq相關的依賴。

 

 

<!-- actionMQ相關的 start -->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-activemq</artifactId>

</dependency>

<!-- 若是此處設置爲true，須要加以下的依賴包，不然會自動配置失敗，報JmsMessagingTemplate注入失敗 -->

<dependency>

<groupId>org.apache.activemq</groupId>

<artifactId>activemq-pool</artifactId>

<!-- <version>5.7.0</version> -->

</dependency>

<!-- actionMQ相關的 end -->

2.2：MQ配置類

 

 

注：必須使用@Configuration 或者是spring 其餘註解。這樣該類才能夠被spring管理。

setBrokerURL是添加url的

 

完整代碼以下：

package com.kaigejava.springconfig.mq;

import org.apache.activemq.ActiveMQConnectionFactory;

import org.apache.activemq.pool.PooledConnectionFactory;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.jms.connection.SingleConnectionFactory;

import org.springframework.jms.core.JmsTemplate;

@Configuration

public class ActiveMQConfig {

 

@Bean

public ActiveMQConnectionFactory targetConnectionFactory(){

ActiveMQConnectionFactory targetConnectionFactory = new ActiveMQConnectionFactory();

targetConnectionFactory.setBrokerURL("tcp://localhost:61616");

return targetConnectionFactory;

}

 

 

 

@Bean

public SingleConnectionFactory connectionFactory( PooledConnectionFactory targetConnectionFactory){

SingleConnectionFactory connectionFactory = new SingleConnectionFactory();

connectionFactory.setTargetConnectionFactory(targetConnectionFactory);

return connectionFactory;

}

@Bean

public PooledConnectionFactory pooledConnectionFactory(ActiveMQConnectionFactory targetConnectionFactory){

PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();

pooledConnectionFactory.setConnectionFactory(targetConnectionFactory);

pooledConnectionFactory.setMaxConnections(10);

return pooledConnectionFactory;

}

 

@Bean

public JmsTemplate jmsTemplate(SingleConnectionFactory connectionFactory){

JmsTemplate jmsTemplate = new JmsTemplate();

jmsTemplate.setConnectionFactory(connectionFactory);

return jmsTemplate;

}

}

 

 

2.3:生產者配置：

 

 

這裏記錄日誌時候使用的MQ生產者。

 

/**

*

* @ClassName: Producer

* @Description: 後臺經過MQ記錄日誌的生成者

* @author 凱哥Java

*

*

*/

@Service("adminLogProducer")  

public class AdminLogProducer {  

   @Autowired // 也能夠注入JmsTemplate，JmsMessagingTemplate對JmsTemplate進行了封裝  

   private JmsMessagingTemplate jmsTemplate;  

   // 發送消息，destination是發送到的隊列，message是待發送的消息  

   public void sendMessage(Destination destination, final String message){  

       jmsTemplate.convertAndSend(destination, message);  

   }  

}  

2.4：消費者：消費者進行消費處理。

 

 

2.5：在service層使用：

 

 

 

使用步驟：

2.5.1:注入mq生產者

2.5.2:準備準備發射的數據

2.5.3：建立一個目標並指定消費者

Destination destination = new ActiveMQQueue("adminLogConsumerQuenue.loggingClassName");

2.5.4：調用生產者的方法進行發送

adminLogProducer.sendMessage(destination,sendmsg);

2.6：生產者發送類：

 

 

至此spring boot整合active MQ方案一完成。

 

本系列教程其餘文章：

spring boot框架學習學前掌握之重要註解(1)-sprng的java配置方式

 

spring boot框架學習學前掌握之重要註解(2)-經過java的配置方式進行配置spring.

 

boot框架學習學前掌握之重要註解(3)-經過註解方式讀取外部資源配置文件

 

spring boot框架學習學前掌握之重要註解(4)-經過註解方式讀取外部資源配置文件2

 

boot框架學習1-認識spring boot和快速入門

 

spring boot框架學習2-spring boot核心(1)

 

spring boot框架學習3-spring boot核心(2)

 

spring boot框架學習4-spring boot核心(3)

 

spring boot框架學習5-spring boot的web開發(1)

 

spring boot框架學習6-spring boot的web開發(2)

 

spring boot框架學習7-spring boot的web開發(3)-自定義消息轉換器

 

spring boot框架學習8-【乾貨】spring boot的web開發(4)-自定義攔截器處理權限

 

spring boot框架學習9-spring boot的web開發(5)-錯誤解決及跳轉頁面

 

spring boot框架學習10-spring boot持久化數據

 

spring boot框架學習11-spring boot整合redis

本文地址：http://kaigejava.com/article/detail/95