首页
专栏
java
文章详情
0
RocketMQ的简单使用
小码农薛尧发布于 今天 04:47
一,本机环境
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…
javarocketmq
阅读 30发布于 今天 04:47
赞收藏
分享
本作品系原创,采用《署名-非商业性使用-禁止演绎 4.0 国际》许可协议

流体石头
学如逆水行舟,不进则退。
关注专栏

小码农薛尧
欢迎关注我的公众号『小码农薛尧』
30声望
1粉丝
关注作者
0 条评论
得票时间

提交评论

小码农薛尧
欢迎关注我的公众号『小码农薛尧』
30声望
1粉丝
关注作者
宣传栏
目录
▲
一,本机环境
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…
|