Spring+ActiveMQ

news2025/1/17 13:52:47

1. 环境搭建

1.1 env-version

JDK

1.8

Spring

2.7.13

Maven

3.6

ActiveMQ

5.15.2

1.2 docker-compose.yml

version: '3.8'

services:
  activemq:
    image: rmohr/activemq:5.16.3
    container_name: activemq
    ports:
      - "61616:61616"
      - "8161:8161"
    environment:
      - ACTIVEMQ_ADMIN_LOGIN=admin
      - ACTIVEMQ_ADMIN_PASSWORD=admin
      - ACTIVEMQ_CONFIG_MINMEMORY=512
      - ACTIVEMQ_CONFIG_MAXMEMORY=2048
#    volumes:
#     - ./data/activemq:/var/activemq/data
#     - ./conf/activemq.xml:/var/activemq/conf/activemq.xml
    networks:
      - activemq-network    

networks:
  activemq-network:
    driver: bridge

在这个docker-compose.yml文件中：

  • activemq服务使用了rmohr/activemq Docker镜像，这是一个社区维护的ActiveMQ镜像。请确保选择一个与你的Spring Boot版本兼容的ActiveMQ版本。

  • container_name设置了容器的名称。

  • ports映射了ActiveMQ的JMS端口（61616）和管理控制台端口（8161）到宿主机的相同端口。

  • environment部分设置了管理员账号和密码，以及JVM的最小和最大内存配置。这些可以根据需要进行调整。

  • volumes部分映射了宿主机的目录到容器内部，用于持久化ActiveMQ的数据和配置文件。你需要创建相应的目录并放置你的activemq.xml配置文件。

  • networks定义了一个自定义网络，以便ActiveMQ服务可以连接到其他可能需要的Docker服务。

在使用这个docker-compose.yml文件之前，请确保你已经创建了data和conf目录，并且在conf目录中放置了自定义的activemq.xml配置文件。如果不需要持久化存储，可以移除volumes部分。

1.3 添加依赖

<!-- ActiveMQ 依赖 -->
<!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-spring -->
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-spring</artifactId>
    <version>5.15.4</version>
    <!-- 排除依赖 -->
    <exclusions>
    <exclusion>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
    </exclusion>
</exclusions>
</dependency>

<!-- Spring Boot 与 JMS 集成的 starter -->
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-activemq -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
    <version>2.7.12</version>
</dependency>

2. 工程结构

activemq/
├── src/
│   ├── main/
│   │   ├── java/
│   │   │   ├── com/
│   │   │   │   ├── xiaokai/
│   │   │   │   │   ├── ActiveMQApplication.java   // 应用程序的主类，通常包含main方法
│   │   │   │   │   ├── config/                   // 配置包
│   │   │   │   │   │   └── JmsConfig.java        // ActiveMQ的配置类
│   │   │   │   │   ├── event/                   // 事件包
│   │   │   │   │   │   ├── Eventinfo.java        // 事件信息类:构建消息、send topic
│   │   │   │   │   ├── listener/                // 监听器包
│   │   │   │   │   │   └── MessageListener.java  // 消息监听器类
│   │   │   │   │   ├── service/                 // 服务包
│   │   │   │   │   │   └── ActiveMQService.java   // ActiveMQ服务类
│   │   │   │   │   
│   │   │   ├── resources/                      // 资源文件
│   │   │   │   └── application.yml             // Spring配置文件
│   │   │   
│   │   ├── test/                                // 测试代码
│   │   │   ├── java/                           // 测试Java代码
│   │   │   │   ├── com/
│   │   │   │   │   ├── xiaokai/
│   │   │   │   │   └── ActiveMQTest.java        // ActiveMQ的测试类
└── pom.xml                                     // Maven构建配置文件（未在文件内容中列出）

ActiveMQApplication.java：项目的主类，通常包含启动Spring应用程序的main方法。

JmsConfig.java：配置ActiveMQ的Java配置类。

Eventinfo.java：可能用于表示事件信息的类。

MessageListener.java：消息监听器，用于监听并处理ActiveMQ消息。

ActiveMQService.java：服务类，可能包含与ActiveMQ交互的业务逻辑。

application.yml：Spring Boot的配置文件，用于配置应用程序的各种参数。

ActiveMQTest.java：用于测试ActiveMQ功能的测试类。

3. 示例代码

JmsConfig.java

package com.xiaokai.config;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;

import javax.jms.ConnectionFactory;

/**
 * Author:yang
 * Date:2024-10-19 15:57
 */
@Configuration
@EnableJms
public class JmsConfig {

    @Bean
    public ActiveMQConnectionFactory connectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL("tcp://116.198.242.56:61616");
        connectionFactory.setUserName("admin");
        connectionFactory.setPassword("admin");
        return connectionFactory;
    }

    @Bean
    public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setSessionTransacted(true);
        return factory;
    }

}

MessageListener.java

package com.xiaokai.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * Author:yang
 * Date:2024-10-19 15:55
 */
@Component
@Slf4j
public class MessageListener {

    // 监听队列test.queue
    @JmsListener(destination = "test.queue")
    public void onMessage(String message) {
        log.info("Received message: " + message);
    }

}

ActiveMQService .java

package com.xiaokai.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

/**
 * Author:yang
 * Date:2024-10-19 16:01
 */
@Service
@Slf4j
public class ActiveMQService {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    public void send(String message) {
        log.info("Sending message: {}", message);
        jmsMessagingTemplate.convertAndSend("test.queue", message);
    }
}

注：JmsMessagingTemplate作为Spring相关bean，封装了JmsTemplate 。总的来说JmsTemplate更底层，但是在使用过程中不需要过多关注底层实现。

@Autowired private JmsMessagingTemplate jmsMessagingTemplate; 
@Autowired private JmsTemplate jmsTemplate;

application.yml

spring:
  activemq:
    broker-url: tcp://116.198.242.56:61616
    user: admin
    password: admin

注：在JmsConfig.java配置文件中配置后，可以不需要配置文件，二者选其一。

测试：

package com.xiaokai;

import com.xiaokai.service.ActiveMQService;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * Author:yang
 * Date:2024-10-21 10:28
 */
@SpringBootTest
@RunWith(SpringRunner.class)
@Slf4j
public class ActiveMQTest {


    @Autowired
    private ActiveMQService activeMQService;


    @Test
    public void testSend(){
        activeMQService.send("test");
    }
}

结果：

 Sending message: test
 
 
 Started ActiveMQApplication in 1.368 seconds (JVM running for 1.799)
 Received message: test

注：在ActiveMQ提供的可视化控制台可以查看相关信息。

访问：http://116.198.242.56:8161/admin/index.jsp

4. 消息模型

4.1 P2P模型

bean

@Bean
public Destination queue() {
    return new ActiveMQQueue("test.queue");
}

消息监听器

@Component
@Slf4j
public class MessageListener {

    // 监听队列test.queue
    @JmsListener(destination = "test.queue")
    public void onMessage1(String message) {
        log.info("Received queue message1: " + message);
    }

    // 监听队列test.queue
    @JmsListener(destination = "test.queue")
    public void onMessage2(String message) {
        log.info("Received queue message2: " + message);
    }

}

消息服务

@Service
@Slf4j
public class ActiveMQService {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    private Destination queue;

    // 发送点对点消息
    public void sendP2P(String message) {
        log.info("Sending queue message: {}", message);
        jmsMessagingTemplate.convertAndSend(queue, message);
    }

}

application.yml

spring:
  activemq:
    broker-url: tcp://116.198.242.56:61616
    user: admin
    password: admin

#    true表示使用发布/订阅模式，false表示使用点对点模式
  jms:
    pub-sub-domain: false

结论：点对点消息模式是将消息推送到queue中，消费者通过轮训的方式消费消息

4.2 发布/订阅模型

Bean

@Bean
public Destination topic() {
    return new ActiveMQTopic("test.topic");
}

消息监听器

@Component
@Slf4j
public class PubMessageListener {

    // 监听主题test.topic
    @JmsListener(destination = "test.topic")
    public void onMessage3(String message) {
        log.info("Received topic message1: " + message);
    }

    // 监听主题test.topic
    @JmsListener(destination = "test.topic")
    public void onMessage4(String message) {
        log.info("Received topic message2: " + message);
    }

}

消息服务

@Service
@Slf4j
public class ActiveMQService {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    private Destination topic;

    // 发送发布订阅消息
    public void sendPubSub(String message) {
        log.info("Sending topic message: {}", message);
        jmsMessagingTemplate.convertAndSend(topic, message);
    }

}

application.yml

spring:
  activemq:
    broker-url: tcp://116.198.242.56:61616
    user: admin
    password: admin

#    true表示使用发布/订阅模式，false表示使用点对点模式
  jms:
    pub-sub-domain: true

注：需要将发布/订阅开关打开

结论：发送消息后，订阅主题的消费者都能收到同一条消息去消费。

5. 消息类型

5.1 普通消息

        普通消息如上述案例，生产者生产消息后，由消费者消费消息，中间不需要做额外的事情。

5.2 延迟消息

延迟消息指在生产者生产带有延迟时间的消息后，broker接收到消息后，并不立即投送到队列或者主题，而是到达延迟时间后，再将消息投送到队列、主题。

配置ActiveMQ支持延迟消息： 修改ActiveMQ的配置文件activemq.xml，确保<broker>标签包含schedulerSupport="true"属性。这允许ActiveMQ的计划任务功能，从而支持延迟消息。

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" schedulerSupport="true">

修改配置后，需要重启ActiveMQ服务器以使更改生效。

发送延迟消息

// 发送延迟消息
public void sendDelay(String message) {
    HashMap<String, Object> properties = new HashMap<>();
    properties.put(ScheduledMessage.AMQ_SCHEDULED_DELAY, 10000);
    log.info("Sending delay queue message: {}", message);
    jmsMessagingTemplate.convertAndSend(queue, message, properties);
}

消息监听器

...

5.3 事务消息

        没啥用，用ActiveMQ实现事务消息还不如不用，辣鸡（狗头保命）

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2225066.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

图解：什么是多租户？

图解：什么是多租户？

大家好&#xff0c;我是汤师爷~ 什么是多租户&#xff1f; 多租户是SaaS&#xff08;软件即服务&#xff09;领域里特有的一个概念。在SaaS服务中&#xff0c;“租户”指的就是使用这个SaaS系统的客户。 那么租户和用户有什么区别呢&#xff1f;举个例子。假设你正在使用一款…
阅读更多...
SQL实战训练之，力扣：1532最近的三笔订单

SQL实战训练之，力扣：1532最近的三笔订单

目录 一、力扣原题链接 二、题目描述 三、建表语句 四、题目分析 五、SQL解答 六、最终答案 七、验证 八、知识点 一、力扣原题链接 1532. 最近的三笔订单 二、题目描述 客户表&#xff1a;Customers ------------------------ | Column Name | Type | --------…
阅读更多...
【C++单调栈 贡献法】907. 子数组的最小值之和|1975

【C++单调栈 贡献法】907. 子数组的最小值之和|1975

本文涉及的基础知识点 C单调栈 LeetCode907. 子数组的最小值之和 给定一个整数数组 arr&#xff0c;找到 min(b) 的总和&#xff0c;其中 b 的范围为 arr 的每个&#xff08;连续&#xff09;子数组。 由于答案可能很大&#xff0c;因此 返回答案模 109 7 。 示例 1&#x…
阅读更多...
ArcGIS计算多个面要素范围内栅格数据各数值的面积

ArcGIS计算多个面要素范围内栅格数据各数值的面积

本文介绍在ArcMap软件中&#xff0c;基于面积制表工具&#xff08;也就是Tabulate Area工具&#xff09;&#xff0c;基于1个面要素数据集与1个栅格数据&#xff0c;计算每一个面要素中各栅格数据分布面积的方法。 首先&#xff0c;来看一下本文的需求。现有一个矢量面的要素集…
阅读更多...
动态规划 —— 斐波那契数列模型-解码方法

动态规划 —— 斐波那契数列模型-解码方法

1. 解码方法 题目链接&#xff1a; 91. 解码方法 - 力扣&#xff08;LeetCode&#xff09;https://leetcode.cn/problems/decode-ways/description/ 2. 题目解析 1. 对字母A - Z进行编码1-26 2. 11106可以解码为1-1-10-6或者11-10-6, 但是11-1-06不能解码 3. 0n不能解码 4. …
阅读更多...
springboot项目测试环境构建出的依赖包比本地构建出的依赖包多

springboot项目测试环境构建出的依赖包比本地构建出的依赖包多

本地能够正常启动服务&#xff0c;但是测试环境启动报错。 上述druid是服务pom文件中之前引入的依赖包&#xff0c;后续由于某种原因而不需要该依赖包了&#xff0c;故已在pom文件中移除掉了该依赖包。 移除该依赖包之后&#xff0c;本地服务可正常构建和启动。 而测试环境却…
阅读更多...
C语言 | Leetcode C语言题解之第504题七进制数

C语言 | Leetcode C语言题解之第504题七进制数

题目&#xff1a; 题解&#xff1a; char * convertToBase7(int num){if (num 0) {return "0";}bool negative num < 0;num abs(num);char * digits (char *)malloc(sizeof(char) * 32);int pos 0;while (num > 0) {digits[pos] num % 7 0;num / 7;}if…
阅读更多...
cm211-1刷机教程镜像包

cm211-1刷机教程镜像包

cm211-1刷机教程 包含镜像包酷看桌面 s905l3-l3b通用 镜像包&#xff1a;https://www.123684.com/s/WGAwjv-5tlv3 1.刷机教程 镜像为线刷镜像包&#xff0c;需要短接刷机 短接刷机&#xff0c;导入镜像包 开始即可。到100%就证明可以了。
阅读更多...
四期书生大模型实战营（【入门岛】- 第4关 | 玩转HF/魔搭/魔乐社区）

四期书生大模型实战营（【入门岛】- 第4关 | 玩转HF/魔搭/魔乐社区）

文章目录 1. 任务介绍闯关任务 2. 平台介绍2.1. HF 平台2.1.1. HF的Transformers库介绍 2.2. GitHub CodeSpaces 和 Hugging Face Spaces 介绍。2.2.1. GitHub CodeSpaces2.2.2. Hugging Face Spaces2.2.3. 总结 3. 模型下载3.1. GitHub CodeSpaces使用3.1.下载internlm2_5-7b-…
阅读更多...
MySQL任意版本安装卸载和数据库原理图绘制

MySQL任意版本安装卸载和数据库原理图绘制

MYSQL任意版本安装和卸载 安装&#xff1a; 1、解压文件 --- 不能出现中文路径 2、在解压目录&#xff08;安装目录&#xff09;下&#xff1a; 1>.创建data文件夹 2>.创建配置文件my.txt 然后修改成ini格式 3、修改配置文件 basedirD:\\mysql\\mysql-5.7.28-winx64…
阅读更多...
006：看图软件ACDSeePhotoStudio2019安装教程

006：看图软件ACDSeePhotoStudio2019安装教程

摘要&#xff1a;本文主要介绍看图软件ACDSee Photo Studio2019的安装流程。 一、软件概述 ACDSee Photo Studio是ACDSee公司开发的一款面向摄影师和图像编辑者的专业软件。它提供了全面的图像处理、管理和发布功能&#xff0c;帮助用户高效地浏览、编辑、分类和分享数字照片。…
阅读更多...
新160个crackme - 084-slayer_crackme1

新160个crackme - 084-slayer_crackme1

运行分析 点击check&#xff0c;提示注册失败 PE分析 ASM程序&#xff0c;32位&#xff0c;无壳 静态分析&动态调试 ida搜索到关键字符串发现注册文件reg.key 通过动态调试&#xff0c;获得计算机名称为’CONCEALBEAR’通过计算得到int_2 接下来有一个剪贴板判断&#xff0…
阅读更多...
从“摸黑”到“透视”：AORO A23热成像防爆手机如何改变工业检测？

从“摸黑”到“透视”：AORO A23热成像防爆手机如何改变工业检测？

在工业检测领域&#xff0c;传统的检测手段常因效率低下、精度不足和潜在的安全风险而受到诟病。随着科技的不断进步&#xff0c;一种新兴的检测技术——红外热成像技术&#xff0c;正逐渐在该领域崭露头角。近期&#xff0c;小编对一款集成红外热成像技术的AORO A23防爆手机进…
阅读更多...
【Linux系统】Ubuntu的简单操作

【Linux系统】Ubuntu的简单操作

什么是 Ubuntu&#xff1f; Ubuntu&#xff08;乌帮图&#xff09;是一个非洲词汇&#xff0c;它的意思是“人性对待他人”或“群在故我在”。Ubuntu发行版将Ubuntu精神带到软件世界之中。 目前已有大量各种各样基于GNU/Linux的操作系统&#xff0c;例如:Debian,SuSE,Gentoo,R…
阅读更多...
【热门主题】000010 深入 Vue.js 组件开发

【热门主题】000010 深入 Vue.js 组件开发

前言&#xff1a;哈喽&#xff0c;大家好&#xff0c;今天给大家分享一篇文章&#xff01;并提供具体代码帮助大家深入理解&#xff0c;彻底掌握&#xff01;创作不易&#xff0c;如果能帮助到大家或者给大家一些灵感和启发&#xff0c;欢迎收藏关注哦 &#x1f495; 目录 【热…
阅读更多...
【HarmonyOS Next】原生沉浸式界面

【HarmonyOS Next】原生沉浸式界面

背景 在实际项目中&#xff0c;为了软件使用整体色调看起来统一&#xff0c;一般顶部和底部的颜色需要铺满整个手机屏幕。因此&#xff0c;这篇帖子是介绍设置的方法&#xff0c;也是应用沉浸式效果。如下图&#xff1a;底部的绿色延伸到上面的状态栏和下面的导航栏 UI 在鸿蒙…
阅读更多...
Android 判断手机放置的方向

Android 判断手机放置的方向

#1024程序员节&#xff5c;征文# 文章目录 前言一、pandas是什么&#xff1f;二、使用步骤 1.引入库2.读入数据总结 需求 老板&#xff1a;我有个手持终端&#xff0c;不能让他倒了&#xff0c;当他倒或者倾斜的时候要发出报警&#xff1b; 程序猿&#xff1a;我这..... 老板…
阅读更多...
断点续传技术是什么？大型文件传输的新模式！

断点续传技术是什么？大型文件传输的新模式！

随着科技的不断进步&#xff0c;文件传输已成为我们日常生活和工作中不可或缺的一部分。然而&#xff0c;传输大型文件时常常会遇到网络不稳定、传输中断等问题&#xff0c;导致传输失败或者重新传输。为解决这一问题&#xff0c;断点续传技术应运而生。 一、断点续传技术是什么…
阅读更多...
Ovis: 多模态大语言模型的结构化嵌入对齐

Ovis: 多模态大语言模型的结构化嵌入对齐

论文题目&#xff1a;Ovis: Structural Embedding Alignment for Multimodal Large Language Model 论文地址&#xff1a;https://arxiv.org/pdf/2405.20797 github地址&#xff1a;https://github.com/AIDC-AI/Ovis/?tabreadme-ov-file 今天&#xff0c;我将分享一项重要的研…
阅读更多...
猫头虎 分享：MySQL 中 TEXT 与 LONGTEXT 数据类型详解与使用场景分析

猫头虎 分享：MySQL 中 TEXT 与 LONGTEXT 数据类型详解与使用场景分析

今天猫头虎带大家深入探讨一番&#xff0c;关于 MySQL 中 TEXT 和 LONGTEXT 数据类型的区别与具体使用场景问题。最近有粉丝私信我说&#xff1a;“猫哥&#xff0c;TEXT 和 LONGTEXT 到底应该怎么选择啊&#xff1f;” 我相信很多开发者在面对 MySQL 中的这两个数据类型时&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023