文档章节

spring boot框架学习12-spring boot整合active mq方法1

中凯_凯哥java
 中凯_凯哥java
发布于 2017/12/10 09:51
字数 948
阅读 54
收藏 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

© 著作权归作者所有

中凯_凯哥java

中凯_凯哥java

粉丝 51
博文 105
码字总数 72576
作品 0
昌平
私信 提问
spring boot框架学习12-spring boot整合active mq方法1

本章节主要内容:主要从以下几个方面讲解:mybatis和spring boot整合、redis(单机版)和spring boot整合、redis(集群)和spring boot整合、httpclient和spring boot整合、rabbitMQ/active MQ和...

799879287
2017/12/10
0
0
spring boot框架学习9-spring boot的web开发(5)-错误解决及跳转页面

本章节主要内容: 通过前面的学习,我们了解并快速完成了spring boot第一个应用。spring boot企业级框架,那么spring boot怎么读取静态资源?如js文件夹,css文件以及png/jpg图片呢?怎么自定...

中凯_凯哥java
2017/11/12
55
0
220.详细整理学习spring boot

1.springboot是什么? 有什么用? 1.1 是什么 一个整合常用第三方框架,简化xml配置,完全采用注解形式,内置tomcat容器,帮助开发者快速实现项目搭建,spring boot 的web组件默认集成的是spr...

Lucky_Me
04/23
111
1
关于SpringCloud、SpringBoot 希望这是说得最详细的

几年前,没几个jar冲突一下都不叫搭框架 —— java面试必修 什么是Spring Boot 用我的话来理解,Spring Boot就是整合了框架的框架,它让一切依赖都变得有序简单,你不用操心A.jar是什么版本,...

阿郎_
2018/09/21
0
0
spring boot框架学习1-认识spring boot和快速入门

本节主讲: 1:什么是spring boot?它哪些特点以至于我们去学习它? 2:使用spring boot 写出hell word的快速入门小示例 声明: 本文是《凯哥陪你学系列-框架学习之spring boot框架学习》中s...

中凯_凯哥java
2017/10/25
152
1

没有更多内容

加载失败,请刷新页面

加载更多

最简单的获取相机拍照的图片

  import android.content.Intent;import android.graphics.Bitmap;import android.os.Bundle;import android.os.Environment;import android.provider.MediaStore;import andr......

MrLins
今天
6
0
说好不哭!数据可视化深度干货,前端开发下一个涨薪点在这里~

随着互联网在各行各业的影响不断深入,数据规模越来越大,各企业也越来越重视数据的价值。作为一家专业的数据智能公司,个推从消息推送服务起家,经过多年的持续耕耘,积累沉淀了海量数据,在...

个推
今天
10
0
第三方支付-返回与回调注意事项

不管是支付宝,微信,还是其它第三方支付,第四方支付,支付机构服务商只要涉及到钱的交易都要进行如下校验,全部成功了才视为成功订单 1.http请求是否成功 2.校验商户号 3.校验订单号及状态...

Shingfi
今天
5
0
简述Java内存分配和回收策略以及Minor GC 和 Major GC(Full GC)

内存分配: 1. 栈区:栈可分为Java虚拟机和本地方法栈 2. 堆区:堆被所有线程共享,在虚拟机启动时创建,是唯一的目的是存放对象实例,是gc的主要区域。通常可分为两个区块年轻代和年老代。更...

DustinChan
今天
7
0
Excel插入批注:可在批注插入文字、形状、图片

1.批注一直显示:审阅选项卡-------->勾选显示批注选项: 2.插入批注快捷键:Shift+F2 组合键 3.在批注中插入图片:鼠标右键点击批注框的小圆点【重点不可以在批注文本框内点击】----->调出批...

东方墨天
今天
7
1

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部