springboot使用activemq

╰半夏微凉° 2022-05-14 07:28 262阅读 0赞

1.导包

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-activemq</artifactId>
            </dependency>

2.配置账号密码等

3.配置类

3.1 配置目的地，我们用topic做实验

@Bean
        public ActiveMQTopic depthTop() {
            return new ActiveMQTopic("depthtop");
        }

3.2配置mq连接工厂

public ActiveMQConnectionFactory activeMQConnectionFactory() {
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(username, password, brockUrl);
            factory.setMaxThreadPoolSize(30);
            return factory;
        }

3.3配置spring管理的cache连接工厂

@Bean
        public ConnectionFactory connectionFactory() {
            CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(activeMQConnectionFactory());
            cachingConnectionFactory.setSessionCacheSize(20);
            return cachingConnectionFactory;
        }

3.4 配置 JmsMessagingTemplate

@Bean
        public JmsMessagingTemplate jmsMessagingTemplate() {
            JmsMessagingTemplate template = new JmsMessagingTemplate(connectionFactory());
            JmsTemplate jmsTemplate = template.getJmsTemplate();
            jmsTemplate.setDeliveryMode(DeliveryMode.NON_PERSISTENT);//非持久模式
            jmsTemplate.setPubSubDomain(true);//订阅模式
            jmsTemplate.setExplicitQosEnabled(true);//启用上面的设置
            return template;
        }

3.5使用  JmsMessagingTemplate

直接在类中 @Resource 引入JmsMessagingTemplate 即可

二，接收消息

JmsListener 注解，注解一个bean，即可接受信息

发表评论取消回复

表情：

评论列表（有 0 条评论，262人围观）

还没有评论，来说两句吧...

相关阅读

相关 ActiveMQ 7.SpringBoot整合ActiveMQ

ActiveMQ @Author:hanguixian @Email:hn\_hanguixian@163.com 七 SpringBoot整合ActiveMQ

男娘i/ 2023年07月06日 13:06/ 0 赞/ 79 阅读

相关 ActiveMQ的安装与使用及Springboot集成ActiveMQ

ActiveMQ的安装与使用及Springboot集成ActiveMQ 1、JMS简介 2、ActiveMQ的安装 3、sprin

短命女/ 2022年12月23日 07:18/ 0 赞/ 261 阅读

相关 ActiveMQ专题8 —— SpringBoot整合ActiveMQ

环境准备启动的ActiveMQ服务 JDK1.8+ IDEA或Eclipse Maven环境 SpringBoot和ActiveMQ整合的

比眉伴天荒/ 2022年11月05日 12:58/ 0 赞/ 267 阅读

相关 SpringBoot-ActiveMq

ActiveMq下载: http://activemq.apache.org 下载解压安装,打开安装目录下的bin/win64/activemq: ![Center

布满荆棘的人生/ 2022年06月09日 12:09/ 0 赞/ 210 阅读

相关 springboot使用activemq

1.导包 <dependency> <groupId>org.springframework.boot</groupId>

╰半夏微凉°/ 2022年05月14日 07:28/ 0 赞/ 263 阅读

相关 SpringBoot JMS(ActiveMQ) 消息队列使用

一、 JMS和MQ的关系：　　JMS是一个用于提供消息服务的技术规范，它制定了在整个消息服务提供过程中的所有数据结构和交互流程。而MQ则是消息队列

缺乏、安全感/ 2022年04月15日 05:37/ 0 赞/ 325 阅读

相关 Springboot -ActiveMQ中Qunue模式使用

下载官方网站 [http://activemq.apache.org/][http_activemq.apache.org] Windows版本 [https:/

柔光的暖阳◎/ 2022年04月08日 10:26/ 0 赞/ 180 阅读

相关 ActiveMQ--SpringBoot整合ActiveMQ主题

Topic生产者新建Maven工程 pom.xml <?xml version="1.0" encoding="UTF-8"?> <project

约定不等于承诺〃/ 2021年08月13日 18:21/ 0 赞/ 617 阅读

相关 ActiveMQ--SpringBoot整合ActiveMQ队列

整合生产者创建Maven工程 pom.xml <?xml version="1.0" encoding="UTF-8"?> <project x

叁歲伎倆/ 2021年08月13日 17:40/ 0 赞/ 573 阅读

相关 ActiveMQ学习2：SpringBoot整合ActiveMQ

1.简介：这篇博客主要记录SpringBoot整合ActiveMQ的过程，并且实现queue、Topic模式的消息传递。项目主要类如下，Email是一个消息实体，De...

红太狼/ 2020年11月15日 13:49/ 0 赞/ 808 阅读