欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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

程序员文章站 2022-05-29 17:04:52
...

本章节主要内容:

主要从以下几个方面讲解:

mybatis和spring boot整合、redis(单机版)和spring boot整合、redis(集群)和spring boot整合、httpclient和spring boot整合、rabbitMQ/active MQ和spring boot整合。

欢迎访问凯哥个人博客网站:www.kaigejava.com

欢迎关注凯哥公众号:凯哥Java(kaigejava)

接下来我们学习第二小节:spring boot整合redis开启缓存


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

本节主要内容:

1:spring boot整合active mq方案一

方案一是简单的,生产者和消费者都在同一个应用项目中。

一:active mq相关

1:active mq下载:


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

2:启动


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

在bin文件夹下有64和32位找到自己系统响应的文件夹打开。凯哥使用的是64位的

spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
 

双击activemq.bat批处理就启动了。

启动如下图:


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

二:spring boot中应用active mq

2.1:在pom.xml文件中添加mq相关的依赖。


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

 

 

org.springframework.boot

spring-boot-starter-activemq

 

 

org.apache.activemq

activemq-pool

 

 

2.2:MQ配置类


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

注:必须使用@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:生产者配置:

spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
 

这里记录日志时候使用的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:消费者:消费者进行消费处理。


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

2.5:在service层使用:


spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

spring boot框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

使用步骤:

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框架学习12-spring boot整合active mq方法1
            
    
    博客分类: spring boot凯哥springboot凯哥Java 凯哥Java凯哥spring boot凯哥学Java
网络异常取消重新上传

至此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