关于java:RocketMQ的简单使用

一,本机环境

  • 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…

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理