目录

一、安装rocketmq nameserver 和broker

1. 先启动 rocketmq nameserver

2. 再启动 rocketmq broker

二、安装客户端页面

三、编译客户端源码


一、安装rocketmq nameserver 和broker

nameserver和broker 下载地址: Release Notes - Apache RocketMQ - Version 4.3.0 - Apache RocketMQ

下载完后放入到F盘根目录,然后设置系统环境变量ROCKETMQ_HOME: F:\rocketmq-server\rocketmq-all-4.3.0-bin-release\bin

注: 安装server时注意路径名不要有空格,否则会出现启动报错的问题。

1. 先启动rocketmq nameserver

start mqnamesrv.cmd

2. 再启动 rocketmq broker

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

 autoCreateTopicEnable=true 参数设置,表示broker可以自动创建topic。

如果出现启动报错: 加载不到主类的问题, 可以参考如下:

(1) jdk 位置放到一个没有空格的路径下。

(2) rocketmq的位置放到路径之间没有空格的路径下。

(3)打开runbroker.cmd,然后将‘%CLASSPATH%’加上英文双引号。保存并重新执行start语句

二、安装客户端页面

gitee地址: RocketMQ-Externals: 由 Apache RocketMQ 社区贡献并维护的 Apache RocketMQ 扩展项目

将rocketmq-console 打包, 执行如下命令:

cd F:\rocketmq-server\RocketMQ-Externals\rocketmq-console
F:
mvn clean package -Dmaven.test.skip=true

切到target目录下的jar包,执行命令

java -jar rocketmq-console-ng-2.0.0.jar

加载首页报错: ERROR op=global_exception_handler_print_error

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to null failed

修改console的application.properties文件, 修改nameserver 的地址配置:

重新打包,然后启动jar:

访问客户端页面: localhost:8080

三、编译客户端源码

从官网下载rocketmq 所有的源代码: RocketMQ: RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。

下载完毕后,使用idea打开,全部工程目录:

 在idea的Terminal终端执行如下命令,解决依赖问题:

mvn -Prelease-all -DskipTests clean install 

也可以切换代码的版本,通过命令git tag 查看所有的tag版本:

git tag

然后使用check out 命令切换到指定的版本:

git checkout rocketmq-all-4.8.0

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐