【源码】基于Spring Boot和Apache RocketMQ的动态ZKMQ系统

项目简介

本项目是基于Spring Boot框架与Apache RocketMQ消息中间件构建的动态ZK - MQ系统。其核心用途是对ZooKeeper节点进行动态管理与操作，同时借助RocketMQ实现消息的发布和订阅。此系统具备动态注册服务、节点操作、消息监听等功能，适用于需要动态配置和管理的分布式系统场景。

项目的主要特性和功能

1. 动态ZooKeeper节点管理：可动态创建、更新和删除ZooKeeper节点，还能监听节点变化，实时响应相关事件。
2. RocketMQ消息发布与订阅：能够动态创建和管理RocketMQ的消费者与生产者，支持消息的发布、订阅和监听，可处理并发和顺序消息。
3. 分布式原子操作：提供分布式原子整数操作，适用于需要全局唯一ID的场景。
4. JSON数据转换：具备JSON与Java对象之间的转换工具，支持多种数据格式转换。
5. 动态配置管理：可从配置文件中动态加载和更新配置参数，如ZooKeeper连接信息、RocketMQ配置等。

安装使用步骤

1. 环境准备

• 安装Java 8或更高版本。
• 安装Maven，用于项目构建和管理依赖。
• 安装ZooKeeper和RocketMQ，并启动相应服务。

2. 进入项目目录

bash cd dynamic-zk-mq

3. 配置文件

在src/main/resources目录下，编辑application.properties文件，配置ZooKeeper和RocketMQ的相关参数： ```properties zookeeper.connectString=localhost:2181 zookeeper.sessionTimeoutMs=5000 zookeeper.connectionTimeoutMs=5000 zookeeper.baseSleepTimeMs=1000 zookeeper.maxRetries=3

rocketmq.namesrvAddr=localhost:9876 rocketmq.producerGroupName=producerGroup rocketmq.consumerGroupName=consumerGroup ```

4. 构建项目

使用Maven构建项目： bash mvn clean install

5. 运行项目

启动Spring Boot应用： bash mvn spring-boot:run

6. 使用示例

• 创建ZooKeeper节点：调用API接口/add创建新的ZooKeeper节点。
• 发送RocketMQ消息：调用API接口/sendMsg发送RocketMQ消息。
• 监听ZooKeeper节点变化：启动应用后，系统自动监听ZooKeeper节点变化并实时响应。

下载地址

点击下载 【提取码: 4003】【解压密码: www.makuang.net】