AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

53分布式电商项目 - Spring集成ActiveMQ

2023-10-30 124
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 53分布式电商项目 - Spring集成ActiveMQ

代码已上传到Gtihub

地址：https://github.com/ylw-github/Spring-ActiveMQ-Demo.git

下面讲解Spring整合ActiveMQ过程，根据ActiveMQ的消息通讯机制，分点对点的方式和发布/订阅的模式讲解。

点对点模式

1.消息生产者

（1）创建工程 springjms_producer，在 POM 文件中引入 SpringJms 、activeMQ 以及单元测

试相关依赖

（2）在 src/main/resources 下创建 spring 配置文件 applicationContext-jms-producer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    <context:component-scan
        base-package="com.pyg">
    </context:component-scan>
    <!-- 真正可以产生 Connection 的 ConnectionFactory，由对应的 JMS 服务厂商提供-->
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://192.168.25.128:61616"/>
    </bean>
    <!-- Spring 用于管理真正的 ConnectionFactory 的 ConnectionFactory -->
    <bean id="connectionFactory"
          class="org.springframework.jms.connection.SingleConnectionFactory">
        <!-- 目标 ConnectionFactory 对应真实的可以产生 JMS Connection 的 ConnectionFactory -->
        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
    </bean>
    <!-- Spring 提供的 JMS 工具类，它可以进行消息发送、接收等 -->
    <bean id="jmsTemplate"
          class="org.springframework.jms.core.JmsTemplate">
        <!-- 这个 connectionFactory 对应的是我们定义的 Spring 提供的那个 ConnectionFactory对象 -->
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>
    <!--这个是队列目的地，点对点的 文本信息-->
    <bean id="queueTextDestination" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="queue_text"/>
    </bean>
</beans>

（3）创建消息生产者类

package com.pyg;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
@Component
public class QueueProducer {
    @Autowired
    private JmsTemplate jmsTemplate;
    @Autowired
    private Destination queueTextDestination;
    /**
     * 发送文本消息
     *
     * @param text
     */
    public void sendTextMessage(final String text) {
        jmsTemplate.send(queueTextDestination, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage(text);
            }
        });
    }
}

（4）单元测试在 src/test/java 创建测试类

import com.pyg.QueueProducer;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext-jms-producer.xml")
public class TestP2P_Producer {
    @Autowired
    private QueueProducer queueProducer;
    @Test
    public void testSend() {
        queueProducer.sendTextMessage("SpringJms-点对点");
    }
}
2.消息消费者

（1）创建工程 springjms_consumer，在 POM 文件中引入依赖 （同上一个工程）

（2）创建配置文件 applicationContext-jms-consumer-queue.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    <!-- 真正可以产生 Connection 的 ConnectionFactory，由对应的 JMS 服务厂商提供-->
    <bean id="targetConnectionFactory"
          class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://192.168.25.128:61616"/>
    </bean>
    <!-- Spring 用于管理真正的 ConnectionFactory 的 ConnectionFactory -->
    <bean id="connectionFactory"
          class="org.springframework.jms.connection.SingleConnectionFactory">
        <!-- 目标 ConnectionFactory 对应真实的可以产生 JMS Connection 的 ConnectionFactory -->
        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
    </bean>
    <!--这个是队列目的地，点对点的 文本信息-->
    <bean id="queueTextDestination"
          class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="queue_text"/>
    </bean>
    <!-- 我的监听类 -->
    <bean id="myMessageListener" class="com.pyg.MyMessageListener"></bean>
    <!-- 消息监听容器 -->
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="destination" ref="queueTextDestination"/>
        <property name="messageListener" ref="myMessageListener"/>
    </bean>
</beans>

（3）编写监听类

package com.pyg;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class MyMessageListener implements MessageListener {
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println("接收到消息：" + textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

（4）创建测试类

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.io.IOException;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext-jms-consumer-queue.xml")
public class TestP2P_Consumer {
    @Test
    public void testQueue() {
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

发布/订阅模式

1.消息生产者

（1）在工程 springjms_producer 的 applicationContext-jms-producer.xml 增加配置。

<!--这个是订阅模式 文本信息-->
    <bean id="topicTextDestination" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="topic_text"/>
    </bean>

（2）创建生产者类

package com.pyg;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
@Component
public class TopicProducer {
    @Autowired
    private JmsTemplate jmsTemplate;
    @Autowired
    private Destination topicTextDestination;
    /**
     * 发送文本消息
     *
     * @param text
     */
    public void sendTextMessage(final String text) {
        jmsTemplate.send(topicTextDestination, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage(text);
            }
        });
    }
}

（3）编写测试类

import com.pyg.TopicProducer;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext-jms-producer.xml")
public class TestTopic_Producer {
    @Autowired
    private TopicProducer topicProducer;
    @Test
    public void sendTextQueue() {
        topicProducer.sendTextMessage("topic send message 。。。。。。");
    }
}
2.消息消费者

（1）在 activemq-spring-consumer 工 程 中 创 建 配 置 文 件applicationContext-jms-consumer-topic.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    <!-- 真正可以产生 Connection 的 ConnectionFactory，由对应的 JMS 服务厂商提供-->
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://192.168.25.128:61616"/>
    </bean>
    <!-- Spring 用于管理真正的 ConnectionFactory 的 ConnectionFactory -->
    <bean id="connectionFactory"
          class="org.springframework.jms.connection.SingleConnectionFactory">
        <!-- 目标 ConnectionFactory 对应真实的可以产生 JMS Connection 的 ConnectionFactory -->
        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
    </bean>
    <!--这个是队列目的地，点对点的 文本信息-->
    <bean id="topicTextDestination" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="topic_text"/>
    </bean>
    <!-- 我的监听类 -->
    <bean id="myMessageListener" class="com.pyg.MyMessageListener"></bean>
    <!-- 消息监听容器 -->
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="destination" ref="topicTextDestination"/>
        <property name="messageListener" ref="myMessageListener"/>
    </bean>
</beans>

（2）编写测试类

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.io.IOException;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext-jms-consumer-topic.xml")
public class TestTopic_Consumer {
    @Test
    public void testQueue() {
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}


文章标签：
Java
消息中间件
Spring
测试技术
关键词：
Spring分布式
分布式spring
Spring集成
Spring项目
Spring集成ActiveMQ
阿甘兄
目录
相关文章
糊涂糊涂123
|
12月前
|
消息中间件 存储 Java
第15课： Spring Boot中集成ActiveMQ
第15课： Spring Boot中集成ActiveMQ
糊涂糊涂123
704 0
游客ia4quza4dsxys
|
人工智能 Java 数据库
飞算 JavaAI：革新电商订单系统 Spring Boot 微服务开发
在电商订单系统开发中，传统方式耗时约30天，需应对复杂代码、调试与测试。飞算JavaAI作为一款AI代码生成工具，专注于简化Spring Boot微服务开发。它能根据业务需求自动生成RESTful API、数据库交互及事务管理代码，将开发时间缩短至1小时，效率提升80%。通过减少样板代码编写，提供规范且准确的代码，飞算JavaAI显著降低了开发成本，为软件开发带来革新动力。
游客ia4quza4dsxys
495 0
WanderInk-20107
|
前端开发 安全 Java
Spring Boot 便利店销售系统项目分包设计解析
本文深入解析了基于Spring Boot的便利店销售系统分包设计，通过清晰的分层架构（表现层、业务逻辑层、数据访问层等）和模块化设计，提升了代码的可维护性、复用性和扩展性。具体分包结构包括`controller`、`service`、`repository`、`entity`、`dto`、`config`和`util`等模块，职责分明，便于团队协作与功能迭代。该设计为复杂企业级应用开发提供了实践参考。
WanderInk-20107
561 0
盹猫
|
12月前
|
Java 关系型数据库 数据库连接
Spring Boot项目集成MyBatis Plus操作PostgreSQL全解析
集成 Spring Boot、PostgreSQL 和 MyBatis Plus 的步骤与 MyBatis 类似，只不过在 MyBatis Plus 中提供了更多的便利功能，如自动生成 SQL、分页查询、Wrapper 查询等。
盹猫
1062 2
啦啦啦191
|
前端开发 Java API
酒店管理系统基于 JavaFX Spring Boot 和 React 经典项目重构实操
本文介绍了基于现代技术栈的酒店管理系统开发方案，整合了JavaFX、Spring Boot和React三大技术框架。系统采用前后端分离架构，JavaFX构建桌面客户端，React开发Web管理界面，Spring Boot提供RESTful API后端服务。核心功能模块包括客房管理和客户预订流程，文中提供了JavaFX实现的客房管理界面代码示例和React开发的预订组件代码，展示了如何实现客房信息展示、添加修改操作以及在线预订功能。
啦啦啦191
731 0
TiAmoZhang
|
12月前
|
Java 测试技术 Spring
简单学Spring Boot | 博客项目的测试
本内容介绍了基于Spring Boot的博客项目测试实践，重点在于通过测试驱动开发（TDD）优化服务层代码，提升代码质量和功能可靠性。案例详细展示了如何为PostService类编写测试用例、运行测试并根据反馈优化功能代码，包括两次优化过程。通过TDD流程，确保每项功能经过严格验证，增强代码可维护性与系统稳定性。
TiAmoZhang
415 0
TiAmoZhang
|
12月前
|
存储 Java 数据库连接
简单学Spring Boot | 博客项目的三层架构重构
本案例通过采用三层架构（数据访问层、业务逻辑层、表现层）重构项目，解决了集中式开发导致的代码臃肿问题。各层职责清晰，结合依赖注入实现解耦，提升了系统的可维护性、可测试性和可扩展性，为后续接入真实数据库奠定基础。
TiAmoZhang
851 0
糊涂糊涂123
|
12月前
|
Java 应用服务中间件 Maven
第01课：Spring Boot开发环境搭建和项目启动
第01课：Spring Boot开发环境搭建和项目启动
糊涂糊涂123
3357 0
WanderInk-20107
|
SQL 前端开发 Java
深入理解 Spring Boot 项目中的分页与排序功能
本文深入讲解了在Spring Boot项目中实现分页与排序功能的完整流程。通过实际案例，从Service层接口设计到Mapper层SQL动态生成，再到Controller层参数传递及前端页面交互，逐一剖析每个环节的核心逻辑与实现细节。重点包括分页计算、排序参数校验、动态SQL处理以及前后端联动，确保数据展示高效且安全。适合希望掌握分页排序实现原理的开发者参考学习。
WanderInk-20107
881 4

热门文章

最新文章

  • 1
    2017双11技术揭秘—分布式缓存服务Tair的热点数据散列机制
  • 2
    ZooKeeper完全分布式安装与配置
  • 3
    浅析阿里数据技术架构（下）大规模分布式知识图谱
  • 4
    基于分布式平台的机器学习模型训练以及上线部署方案总结
  • 5
    分布式ID彻底把它搞懂
  • 6
    Git 系列之一：版本控制的概念、分布式、Git 简介及其工作流程-转载
  • 7
    ZooKeeper分布式协调服务详解：面试经验与必备知识点解析
  • 8
    进入云原生、分布式的时代 什么才是数据库的正确打开方式
  • 9
    Centos7搭建minio分布式集群
  • 10
    .Net普通三层-&gt;工厂模式-&gt;线程内唯一+单元工作模式-&gt;WebService分布式三层
  • 1
    基于 Spring AI Alibaba + Nacos 的分布式 Multi-Agent 构建指南
    5385
  • 2
    Spring AI Alibaba Admin 开源！以数据为中心的 Agent 开发平台
    8179
  • 3
    Spring Boot自动装配
    712
  • 4
    【Spring Boot实战】EasyPoi神技：一篇搞定“一对多+图片”导入！
    2122
  • 5
    《深入理解Spring》性能监控与优化——构建高性能应用的艺术
    542
  • 6
    《深入理解Spring》单元测试——高质量代码的守护神
    1379
  • 7
    《深入理解Spring》定时任务——自动化调度的时间管理者
    1045
  • 8
    《深入理解Spring》事务管理——数据一致性的守护者
    586
  • 9
    《深入理解Spring》过滤器（Filter）——Web请求的第一道防线
    1667
  • 10
    《深入理解Spring》拦截器（Interceptor）——请求处理的艺术
    871

    • 相关课程

    更多
  • 全面讲解Spring Cloud Alibaba技术栈（知识精讲+项目实战）第二阶段
  • 精通Spring Cloud Alibaba
  • 微服务框架 Spring Cloud 快速入门
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 阿里邮箱—安全高效集成
  • 集成智能接入网关APP：优化企业级移动办公网络
  • 云效助力企业集成安全到DevOps中

    • 相关实验场景

    更多
  • AnalyticDB Zero-ETL：简单易用零成本的一站式数据分析
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！