关于java:RocketMQ的简单使用

5次阅读

共计 629 个字符,预计需要花费 2 分钟才能阅读完成。

一,本机环境

  • macOS Big Sur 11.1
  • Rocketmq 4.7.0
  • SpringBoot 2.4.1

二,操作步骤

1. 下载 RocketMQ

https://archive.apache.org/rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip

2. 自行解压

应用工具解压即可

3. 运行名称服务器

./mqnamesrv 

4. 运行经纪人

./mqbroker -n localhost:9876 

5. 下载可视化控制台

应用 apache 提供的可视化控制台 rocketmq-console-ng

https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console 

批改配置文件中名称服务器地址

rocketmq.config.namesrvAddr=127.0.0.1:9876 

如下图所示

浏览 localhost:8080,查看成果

三,问题列表

1. 依照官网的示例编写代码,生产者服务启动报如下谬误

Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest 

官网的示例教程采纳的版本是 4.3.0

解决办法:

采纳本人应用的 rocketmq 的版本

[](https://blog.xueyao.me/2020-y…

正文完
 0