小工具      在线工具  汉语词典  css  js  c++  java

MAC下搭建RocketMQ

Java 额外说明

收录于:43天前

RocketMQ配置流程

1.下载RocketMQ二进制文件

https://rocketmq.apache.org/dowloading/releases/   选择  Binary: RocketMQ-all-4.2.0-bin-release.zip 

2.环境配置

将 mq 环境变量添加到 .bash_profile

导出 ROCKETMQ_HOME=/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release

将 mq 环境变量添加到配置文件

ROCKETMQ_HOME=/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release

3.开始路由(cd到rocketmq-all-4.2.0-bin-release目录)

》》nohup sh bin/mqnamesrv & 启动

》》tail -f ~/logs/rocketmqlogs/namesrv.log // 查看namaserver日志

》》 INFO main - 名称服务器启动成功 // 启动成功

4.启动broker(cd到rocketmq-all-4.2.0-bin-release目录)

》》 nohup sh bin/mqbroker -n localhost:9876 & //启动

》》tail -f ~/logs/rocketmqlogs/broker.log // 查看broker日志

》》 Broker[TF012778.local, 10.50.62.53:10911] boot success // 启动成功

5.消息测试(cd /Users/sunww/Documents/JAVA/RocketMQ/rocketmq-all-4.4.0)

(1) 发送消息

导出 NAMESRV_ADDR=127.0.0.1:9876

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

TF012778:rocketmq-all-4.2.0-bin-release sunww$ 导出 NA=localhost:9876

TF012778:rocketmq-all-4.2.0-bin-release sunww$ 导出 NAMESRV_ADDR=127.0.0.1:9876

(2) 接收消息

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

TF012778: Rocketmq-all-4.2.0-bin-release sunww$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

6. 关闭服务器

sh bin/mqshutdownbroker //停止broker

sh bin/mqshutdown namesrv //停止名称服务器

您是否遇到路由和代理启动无响应的问题?

解决方案:(1)打开/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release目录下的nohup.out文件内容。报错如下: sh: /usr/rocketmq/bin /runserver.sh: No such file or directory

可以知道是环境变量的位置配置错误。这应该指向 /Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release/bin 并重新修改环境变量(如上面步骤 2 所示)

(2)还可以查看mqnamesrv.sh文件(bin下)。可以看到这里使用了ROCKETMQ_HOME环境变量。您需要设置环境变量。

(3)消费者主题注册失败。

解决方案:我发现我的JAVA Web项目中使用的rocketMQ版本是4.3.0,而我使用的rocketMQ服务器版本是4.2.0。然后将项目中的版本统一为4.2.0即可。

<dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>4.2.0</version>
        </dependency>

参考:https://blog.csdn.net/zhwyj1019/article/details/80264698

https://rocketmq.apache.org/docs/quick-start/ 官方文档

. . .

相关推荐

额外说明

SQL 标准发布第 15 部分:ISO/IEC 9075-15:2019 多维数组 (SQL/MDA)

文章目录 SQL/MDA SQL/PGQ SQL 流数据处理 SQL/MDA 2019 年 6 月,SQL 标准发布了第 15 部分:ISO/IEC 9075-15:2019 多维数组(SQL/MDA)。 多维数组(Multi-Dimensional A

额外说明

Unity实战项目 ☀️| 教你如何在Unity中通过 代码获取 URL链接网页 的 标题 等各种信息✨

-博客主页:https://blog.csdn.net/zhangay1998 -欢迎点赞 - 收藏 ⭐留言 - 如有错误敬请指正! -本文由 呆呆敲代码的小Y 原创,首发于 CSDN- -未来很长,值得我们全力奔赴更美好的生活✨ 目录 -如何在Unit

额外说明

高等数学之反函数的求导法则

原函数与反函数的导数成倒数关系  实例  几何关系证明     二者关于y=x对称k1*k2=1;  洋葱法则 下面是两个比较经典的题目    

额外说明

Linux命令200例:compress用来对文件进行压缩和解压缩

-作者简介,黑夜开发者,CSDN领军人物,全栈领域优质创作者✌。CSDN专家博主,阿里云社区专家博主,2023年6月csdn上海赛道top4。 -数年电商行业从业经验,历任核心研发工程师,项目技术负责人。 -本文已收录于专栏:Linux命令大全。 -本专

额外说明

Lambda表达式的生动理解以及Java Lambda表达式常见使用场景

本篇承接上一篇 Java Lambda 表达式快速学习 , 对Lambda 表达式的语法格式进行演化说明, 并对Java 中Lambda表达式的常见使用场景进行说明。 Lambda 表达式怎么来的? 在Java 中, 给一个字符串变量赋值就很简单, 类似

额外说明

第一章:tornado入门环境搭建

一、准备及安装工具 1、pycharm 2017以下简称pycharm 2、虚拟机或者自己有服务器 3、安装ubuntu 16.04系统以下简称ubuntu 4、Xshell 5远程连接工具以下简称Xshell 二、ubuntu中环境的基本配置 1、创建

额外说明

YoloV8改进策略:重新思考高效的基于注意力的移动块模型EMO重新定义了轻量化的YoloV8

文章目录 摘要 论文翻译 EMO:重新思考高效的基于注意力的移动块模型 1、介绍 2、方法论:归纳法和演绎法 2.1、通用效率模型标准 2.2、元移动块 2.3、微设计:倒置残余移动块 2.4、面向密集预测的EMO宏观设计 3、实验 3.1、图像分类 3

额外说明

【MySQL】mysql:重复数据查询 sql

目录 一、准备测试表 (1)创建表 (2)查询表 (3)删除表 二、准备测试数据 (1)插入数据 (2)查询数据 三、重复数据查询 (1)查询 numid 相同,而 testname 不同,不包括同 numid 同 testname 的数据 (2)查询

额外说明

【Redis】文件译文:Redis on Windows Release Notes.docx(Windows 上的 Redis 版本发行说明文档.docx)

注意:下载后的原文件已损坏,以下是用金山文档修复预览的文档内容:   【Redis 版本说明】 MSOpenTech Redis 3.2 【原文】 Release Notes Welcome to the binary release of Redis

额外说明

wordpress添加媒体_如何在WordPress中添加社交媒体共享计数小部件

WordPress 添加媒体 Earlier on this blog, we created a WordPress 社交媒体备忘单, but that only showed you how to add social media buttons.

ads via 小工具