[RocketMQ 5.3.1] Win11 + Docker Desktop 本地部署全流程 + 踩坑记录

时间比较仓促，部署Linux的过程我就简写啦。

0. 我的系统版本（供参考）

Windows 11 专业版 24H2, Build 26100.2161

Experience: Windows Feature Experience Pack 1000.26100.32.0

JDK: OpenJDK Amazon Corretto 21.0.4.7.1

1. 在WSL2上安装Ubuntu 24.04

我完全参照了这个安装，流程上没啥问题：Install Ubuntu on WSL2 - Ubuntu WSL documentation

遇到的坑：

（1）安装之后需要以管理员身份打开。进入到命令行才算是安装完成。

（2）打开Ubuntu 24.04后无法进入命令行，显示WslRegisterDistribution failed with error: 0x80370114 后面跟着一堆问号或者啥

解决方法：控制面板→启用或关闭Windows功能→勾选 Hyper-V和Virtual Machine Platform，最好不要勾选Telnet→确定后重启电脑。

2. 安装Docker Desktop：Windows | Docker Docs

不需要付费，也不用登录，直接打开就行。遇到的坑：

（1）无法打开Docker Desktop，显示 An unexpected error was encountered while executing a WSL command…

解决方法：确认已安装的Linux子系统来自Ubuntu Distribution，并设置为默认。详见：https://stackoverflow.com/questions/76160943/docker-desktop-an-unexpected-error-was-encountered-while-executing-a-wsl-comma

3. 从Docker安装RocketMQ 5.3.1

在标题栏上搜索“rocketmq”，然后直接 pull 即可。

4. 创建一个共享网络，并启动一个命名服务。

以管理员身份打开Powershell，然后执行

docker network create rocketmqdocker run -d --name rmqnamesrv -p 9876:9876 --network rocketmq apache/rocketmq:5.3.1 sh mqnamesrv

现在我们占用了 9876 这个端口。还可以顺便用这个命令检查一下是否正常启动了：

docker logs -f rmqnamesrv

当然，从Docker Desktop也能看：

5. 启用Broker和Proxy

官方步骤在这个：Run RocketMQ in Docker | RocketMQ

但是我的步骤和官网不太一样，可以先试试我的步骤

（1）随便找个地方新建个记事本，然后重命名为broker.conf，空文件就行，啥也不用写。我建在了 D:\broker.conf

（2）在Powershell中执行

docker run -d `--name rmqbroker `--network rocketmq `-p 10912:10912 -p 10911:10911 -p 10909:10909 `-p 8080:8080 -p 8081:8081 `-e "NAMESRV_ADDR=rmqnamesrv:9876" `-v /D/broker.conf:/home/rocketmq/rocketmq-5.3.1/conf/broker.conf `apache/rocketmq:5.3.1 sh mqbroker --enable-proxy `-c /home/rocketmq/rocketmq-5.3.1/conf/broker.conf

注意：-v后面推荐使用Unix风格的绝对路径，比如我的写成 /D/broker.conf，冒号后面的部分不用改。

10909、10911、10912三个端口都应该做映射（如命令所示）。现在我们能在容器列表看到：

6. 点进 rmqbroker，确认一下 broker.conf文件真实存在

依次展开：/home/rocketmq/rocketmq-5.3.1/conf/，看有没有 broker.conf 文件

7. 回到 Exec，执行以下命令，然后重启容器

cd /home/rocketmq/rocketmq-5.3.1/conf/echo "brokerIP1=127.0.0.1" > broker.conf

重启容器：点击右上角那个圈圈箭头

8. 如果你想，可以手动建立一个Topic，也可以不建

这次我们在 Powershell 里进入容器，然后执行新建命令，就叫 TopicTest 吧，默认集群即可

docker exec -it rmqbroker shsh mqadmin updateTopic -n rmqnamesrv:9876 -t TopicTest

9. Java 代码验证一下

（0）POM

<!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-client -->
<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>5.3.1</version>
</dependency><!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-common -->
<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-common</artifactId><version>5.3.1</version>
</dependency>

（1）生产者

package com.example.demo.rmq;import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;@SuppressWarnings("preview")
public class Producer {public static void main(String[] args) throws MQClientException, MQBrokerException, RemotingException, InterruptedException {DefaultMQProducer producer = new DefaultMQProducer("ProducerGroup");producer.setNamesrvAddr("localhost:9876");producer.start();Message msg = new Message("TopicTest", "TagA", "Hello RocketMQ".getBytes());producer.send(msg, 10000);System.out.println(STR."Message sent: \{new String(msg.getBody())}");producer.shutdown();}
}

（2）消费者

package com.example.demo.rmq;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel;@SuppressWarnings("preview")
public class Consumer {public static void main(String[] args) throws MQClientException {DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");consumer.setNamesrvAddr("localhost:9876");consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);consumer.subscribe("TopicTest", "*");consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {for (MessageExt msg : msgs) {System.out.println(STR."Received message: \{new String(msg.getBody())}");}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;});consumer.setMessageModel(MessageModel.BROADCASTING);consumer.start();}
}

（3）删除 Topic

package com.example.demo.rmq;import org.apache.rocketmq.client.ClientConfig;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.impl.MQClientManager;
import org.apache.rocketmq.remoting.exception.RemotingException;import java.util.concurrent.ExecutionException;@SuppressWarnings("preview")
public class DeleteTopics {public static void main(String[] args) throws ExecutionException, InterruptedException, RemotingException, MQClientException {final String topicToDelete = "TopicTest";final String nameServerAddr = "localhost:9876";final String brokerAddr = "localhost:10911";ClientConfig config = new ClientConfig();config.setNamesrvAddr(nameServerAddr);var admin = MQClientManager.getInstance().getOrCreateMQClientInstance(config).getMQClientAPIImpl();admin.start();System.out.println(STR."Before deletion, topics available: \{admin.getTopicListFromNameServer(3000).getTopicList()}");// Step 1: Delete topic from NameServeradmin.deleteTopicInNameServer(nameServerAddr, topicToDelete, 3000);// Step 2: Delete topic from Brokeradmin.deleteTopicInBroker(brokerAddr, topicToDelete, 3000);System.out.println(STR."After deletion, topics available: \{admin.getTopicListFromNameServer(3000).getTopicList()}");}
}

运行结果：

Before deletion, topics available: [RMQ_SYS_TRANS_HALF_TOPIC, BenchmarkTest, OFFSET_MOVED_EVENT, TBW102, %RETRY%ConsumerGroup, rmq_sys_REVIVE_LOG_DefaultCluster, SELF_TEST_TOPIC, DefaultCluster, SCHEDULE_TOPIC_XXXX, DefaultCluster_REPLY_TOPIC, rmq_sys_wheel_timer, 6d472f2c2a3d, rmq_sys_SYNC_BROKER_MEMBER_6d472f2c2a3d, RMQ_SYS_TRANS_OP_HALF_TOPIC, TopicTest]


After deletion, topics available: [RMQ_SYS_TRANS_HALF_TOPIC, BenchmarkTest, OFFSET_MOVED_EVENT, TBW102, %RETRY%ConsumerGroup, rmq_sys_REVIVE_LOG_DefaultCluster, SELF_TEST_TOPIC, DefaultCluster, SCHEDULE_TOPIC_XXXX, DefaultCluster_REPLY_TOPIC, rmq_sys_wheel_timer, 6d472f2c2a3d, rmq_sys_SYNC_BROKER_MEMBER_6d472f2c2a3d, RMQ_SYS_TRANS_OP_HALF_TOPIC]

可以发现末尾的 TopicTest 已经删掉了。

That's it.

---

后记：在最新版本的 RocketMQ 中，已经没有 DefaultMQAdminExt 等常用的 Admin 类了，都需要通过 ClientConfig 构建 MQClient，不知道为何官方文档迟迟没有更新。另外，已经不需要 DeleteTopicRequestHeader 等麻烦的类了。

其他内容欢迎大家补充。

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

基于SpringBoot的植物园管理小程序【附源码】

基于SpringBoot的植物园管理小程序【附源码】

基于SpringBoot的植物园管理小程序 效果如下&#xff1a; 系统登录页面 管理员主页面 商品订单管理页面 植物园信息管理页面 小程序主页面 小程序登录页面 植物信息查询推荐页面 研究背景 随着互联网技术的快速发展和移动设备的普及&#xff0c;线上管理已经成为各行各业提高…
阅读更多...
qt QDragEnterEvent详解

qt QDragEnterEvent详解

1、概述 QDragEnterEvent是Qt框架中用于处理拖放进入事件的一个类。当用户将一个拖拽对象&#xff08;如文件、文本或其他数据&#xff09;拖动到支持拖放操作的窗口部件&#xff08;widget&#xff09;上时&#xff0c;系统会触发QDragEnterEvent事件。这个类允许开发者在拖拽…
阅读更多...
《C#语法一篇通》，有20万字，需8MB字节，宜48小时阅读，没准会继续完善

《C#语法一篇通》，有20万字，需8MB字节，宜48小时阅读，没准会继续完善

本文摘录了C#语法的主要内容&#xff0c;接近20万字。 所有鸡汤的味道都等于马尿&#xff01; 如果你相信任何所谓的鸡汤文章&#xff0c;智商堪忧。 计算机语言没有”好不好“之说&#xff0c;骗子才会告诉你哪个语言好&#xff0c;学好任何一本基础语言&#xff08;C&#…
阅读更多...
帆软报表新增一行数据后保存，删除选中数据

帆软报表新增一行数据后保存，删除选中数据

表格数据显示 1、建立数据库连接 2、建立查询语句&#xff0c;把需要显示的字段对应在界面上 3&#xff0c;关于自增序号如何设置&#xff0c;双击序号单元格&#xff0c;插入公式 4、如果有外键的&#xff0c;要进行下拉显示时&#xff0c;设置形态&#xff0c;显示中文保存…
阅读更多...
MySQL-如果你在添加外键时忘加约束名，如何找到系统默认的约束名

MySQL-如果你在添加外键时忘加约束名，如何找到系统默认的约束名

问题 在你添加约束的时候&#xff0c;一般都会为其取名以方便后期的修改&#xff0c;但是如果你忘记了呢&#xff0c;如何找到系统默认的约束名 解决方法 -- 查找约束名 SELECTCONSTRAINT_NAME FROMINFORMATION_SCHEMA.KEY_COLUMN_USAGE WHERETABLE_NAME emp ANDREFERENCED_T…
阅读更多...
【MongoDB】MongoDB的聚合(Aggregate、Map Reduce)与管道(Pipline) 及索引详解（附详细案例）

【MongoDB】MongoDB的聚合(Aggregate、Map Reduce)与管道(Pipline) 及索引详解（附详细案例）

文章目录 MongoDB的聚合操作&#xff08;Aggregate&#xff09;MongoDB的管道&#xff08;Pipline操作&#xff09;MongoDB的聚合&#xff08;Map Reduce&#xff09;MongoDB的索引 更多相关内容可查看 MongoDB的聚合操作&#xff08;Aggregate&#xff09; 简单理解&#xff…
阅读更多...
【dvwa靶场：XSS系列】XSS (DOM) 低-中-高级别，通关啦

【dvwa靶场：XSS系列】XSS (DOM) 低-中-高级别，通关啦

一、低级low 拼接的url样式&#xff1a;​​​​​​​ http://127.0.0.1/dvwa/vulnerabilities/xss_d/?default 拼接的新内容 <script>alert("假客套")</script> 二、中级middle 拼接的url样式&#xff1a;​​​​​​​ http://127.0.0.1/dvwa/vuln…
阅读更多...
Android13 系统/用户证书安装相关分析总结(二) 如何增加一个安装系统证书的接口

Android13 系统/用户证书安装相关分析总结(二) 如何增加一个安装系统证书的接口

一、前言 接着上回说&#xff0c;最初是为了写一个SDK的接口&#xff0c;需求大致是增加证书安装卸载的接口&#xff08;系统、用户&#xff09;。于是了解了一下证书相关的处理逻辑&#xff0c;在了解了功能和流程之后&#xff0c;发现settings中支持安装的证书&#xff0c;只…
阅读更多...
React 组件生命周期与 Hooks 简明指南

React 组件生命周期与 Hooks 简明指南

文章目录 一、类组件的生命周期方法1. 挂载阶段2. 更新阶段3. 卸载阶段 二、函数组件中的 Hooks1. useState2. useEffect3. useContext4. useReducer 结论 好的&#xff0c;我们来详细讲解一下 React 类组件的生命周期方法和函数组件中的钩子&#xff08;hooks&#xff09;。 …
阅读更多...
软考（中级-软件设计师）数据库篇（1101）

软考（中级-软件设计师）数据库篇（1101）

第6章 数据库系统基础知识 一、基本概念 1、数据库 数据库&#xff08;Database &#xff0c;DB&#xff09;是指长期存储在计算机内的、有组织的、可共享的数据集合。数据库中的数据按一定的数据模型组织、描述和存储&#xff0c;具有较小的冗余度、较高的数据独立性和扩展…
阅读更多...
FITS论文解析

FITS论文解析

在本文中&#xff0c;作者探讨了如何将复杂的频域特征提取与简单的线性模型&#xff08;如DLinear&#xff09;结合&#xff0c;以优化时间序列预测任务的效率和解释性。本文的核心思想是利用频域处理和DLinear的简化结构来达到高效的预测能力&#xff0c;同时保留对复杂特征的…
阅读更多...
Ubuntu 搭建Yapi服务

Ubuntu 搭建Yapi服务

新手上路&#xff0c;小心开车 1. 安装mongo数据库 第一步&#xff1a;docker pull mongo 拉取mongo镜像&#xff1b; 第二步&#xff1a;启动mongo镜像 docker network create yapi_networkdocker run -d \-p 27017:27017 \--name mongodb \-e MONGO_INITDB_ROOT_USERNAMEya…
阅读更多...
【进度猫-注册/登录安全分析报告】

【进度猫-注册/登录安全分析报告】

前言 由于网站注册入口容易被黑客攻击&#xff0c;存在如下安全问题&#xff1a; 暴力破解密码&#xff0c;造成用户信息泄露短信盗刷的安全问题&#xff0c;影响业务及导致用户投诉带来经济损失&#xff0c;尤其是后付费客户&#xff0c;风险巨大&#xff0c;造成亏损无底洞…
阅读更多...
JAVA 插入 JSON 对象到 PostgreSQL

JAVA 插入 JSON 对象到 PostgreSQL

博主主页:【南鸢1.0】 本文专栏&#xff1a;JAVA 目录 ​编辑 简介 所用&#xff1a; 1、 确保 PostgreSQL 数据库支持 JSON&#xff1a; 2、添加 PostgreSQL JDBC 驱动 3、安装和运行 PostgreSQL 4、建立数据库的连接 简介 在现代软件开发中&#xff0c;由于 JSON 数据…
阅读更多...
前端通过nginx部署一个本地服务的方法

前端通过nginx部署一个本地服务的方法

前端通过nginx部署一个本地服务的方法&#xff1a; 1.下载ngnix nginx 下载完成后解压缩后运行nginx.exe文件 2.打包你的前端项目文件 yarn build 把生成的dist文件复制出来&#xff0c;替换到nginx的html文件下 3.配置conf目录的nginx.conf文件 主要配置server监听 ser…
阅读更多...
深度学习基础知识-损失函数

深度学习基础知识-损失函数

目录 1. 均方误差&#xff08;Mean Squared Error, MSE&#xff09; 2. 平均绝对误差&#xff08;Mean Absolute Error, MAE&#xff09; 3. Huber 损失 4. 交叉熵损失&#xff08;Cross-Entropy Loss&#xff09; 5. KL 散度&#xff08;Kullback-Leibler Divergence&…
阅读更多...
如何在BSV区块链上实现可验证AI

如何在BSV区块链上实现可验证AI

​​发表时间&#xff1a;2024年10月2日 nChain的顶尖专家们已经找到并成功测试了一种方法&#xff1a;通过区块链技术来验证AI&#xff08;人工智能&#xff09;系统的输出结果。这种方法可以确保AI模型既按照规范运行&#xff0c;避免严重错误&#xff0c;遵守诸如公平、透明…
阅读更多...
网络原理（应用层）-＞HTTPS解

网络原理（应用层）-＞HTTPS解

前言&#xff1a; 大家好我是小帅&#xff0c;今天我们来了解HTTPS, 个人主页&#xff1a;再无B&#xff5e;U&#xff5e;G 文章目录 1.HTTPS1.1HTTPS 是什么&#xff1f;1.2 "加密" 是什么1.3 HTTPS 的⼯作过程1.3. 1对称加密1.3.2⾮对称加密 1.4中间人攻击1.5 证书…
阅读更多...
TOEIC 词汇专题：娱乐休闲篇

TOEIC 词汇专题：娱乐休闲篇

TOEIC 词汇专题&#xff1a;娱乐休闲篇 在娱乐和休闲活动中&#xff0c;我们会接触到许多特定的词汇。这些词汇涉及到活动入场、观众互动、评论等各个方面&#xff0c;帮助你在相关场景中更加自如。 1. 入场和观众 一些常用词汇帮助你轻松应对观众与入场管理相关的场景&#…
阅读更多...
Spring框架---AOP技术

Spring框架---AOP技术

AOP概念的引入 第一步创建普通Maven项目 导入依赖 <dependencies><!--spring的核心--><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.0.2.RELEASE</version&g…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023