Mac M1芯片 搭建RocketMQ

news2024/9/22 3:28:57

Mac M1芯片 搭建RocketMQ

RocketMQ需要启动三个组件

1、nameserver 路由中心,为整个MQ集群提供服务协调与治理

2、broker 提供消息的转发和存储功能

3、console 控制台面板工具

1、下载RocketMQ

https://rocketmq.apache.org/dowloading/releases/

选择 Binary: rocketmq-all-4.9.3-bin-release.zip

2.环境配置(可不配置,方便启动)

打开终端进入到根目录
编辑.bash_profile文件

vim .bash_profile

把下面代码复制进去,记得把 rocketmq目录地址 修改为你下载的rocketmq目录
如: export ROCKETMQ_HOME=/Users/xxx/software/rocketmq-4.9.3

export ROCKETMQ_HOME=rocketmq目录地址
export PATH=$PATH:$ROCKETMQ_HOME/bin

配置完成之后需重新加载配置文件

source .bash_profile

3、启动路由

(配置第二步可忽略:cd到bin目录)

//启动
nohup sh mqnamesrv &   
// 查看namaserver日志
tail -f ~/logs/rocketmqlogs/namesrv.log   
 
#显示以下内容代表启动成功
INFO main - The Name Server boot success

4. 启动broker

(配置第二步可忽略:cd到bin目录)

//启动
nohup sh mqbroker -n localhost:9876 &
 
// 查看broker日志
tail -f ~/logs/rocketmqlogs/broker.log
 
// 启动成功
The broker[TF012778.local, 10.50.62.53:10911] boot success

5.关闭rocketmq(需关闭MQ时使用)

//停止 broker
sh mqshutdown broker
 
//停止 nameserver
sh mqshutdown namesrv

6、下载console控制台面板

RocketMQ控制台安装

6.1 下载地址源码

https://github.com/apache/rocketmq-externals/tags
下载 rocketmq-externals-rocketmq-console-1.0.0 这个压缩包就行
解压压缩包备用

6.2 修改配置信息

进入rocketmq-externals\rocketmq-console\src\main\resources文件夹,打开application.properties进行配置,如下图

img

6.3 打成jar包

进入路径 C:\Users\wqf\Desktop\rocketmq-externals-rocketmq-console-1.0.0\rocketmq-console
打开命令控制台(按住shift键,鼠标右键)//或者可以用idea打开项目进行打包。
执行命令(跳过测试文件)

 mvn clean package -Dmaven.test.skip=true 

6.4启动jar包

 java -jar jar包路径

web访问地址:http://127.0.0.1:8088/#/
在这里插入图片描述

1.查看帮助:在 mqadmin 下可以查看有哪些命令
   1): 查看具体命令的使用 : sh mqadmin    
   2): sh mqadmin help 命令名称  
2. 关闭nameserver和所有的broker: 
   sh mqshutdown namesrv
   sh mqshutdown broker
3. 查看所有消费组group:
   sh mqadmin consumerProgress -n 192.168.1.23:9876
   注:-n,即配置的namesrvAddr参数
4. 查看指定消费组下的所有topic数据堆积情况:
   sh mqadmin consumerProgress -n 192.168.1.23:9876 -g warning-group
5. 查看所有topic :
   sh mqadmin topicList -n 192.168.1.23:9876
6. 查看topic信息列表详情统计
   sh mqadmin topicstatus -n 192.168.1.23:9876 -t topicWarning
7.  新增topic
   sh mqadmin updateTopic –n 192.168.1.23:9876 –c DefaultCluster –t topicWarning
   注:-c,即配置的brokerClusterName参数;-t,topic
8. 删除topic
   sh mqadmin deleteTopic –n 192.168.1.23:9876 –c DefaultCluster –t topicWarning
9、查询集群消息
   sh mqadmin  clusterList -n 192.168.1.23:9876

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/141600.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

对外投资追踪汇率数据金融开放指数

一、2005-2020年中国全球投资追踪数据 “中国全球投资跟踪”(China Global Investment Tracker)数据库,由美国企业研究所于1月28日发布。该数据库是唯一一套涵盖中国全球投资和建设的综合数据集,同时使用分别记录和汇总记录两种方…

这几个算法可视化网站,太牛了!

本文已经收录到Github仓库,该仓库包含计算机基础、Java基础、多线程、JVM、数据库、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分布式、微服务、设计模式、架构等核心知识点,欢迎star~ Github地址:https://github.com/Tyson0314/Java-…

深入 Android 底层服务(service)

前言 我们都知道,字节最近发布了PICO4VR眼镜,我买了一个,体验还行。因为我也是做VR眼镜的Android应用层开发的,所以想把自己项目中遇到的一些Android技术分享给读者。近些年随着VR眼镜的兴起,Android的的服…

项目经理跨部门沟通,如何避免踢皮球?

软件项目干系人越多,沟通成本也就越高,非常容易出现相互提皮球的现象。那么如何高效沟通? 1、划分干系人 不同干系人不同策略 软件项目涉及干系人众多,项目不经理不可能对每一个人进行详细沟通,那么我们需要将干系人的…

如何把优化Docker镜像大小

什么是Docker Docker是一个开源的虚拟化平台,可以让开发人员将应用程序和依赖项打包在轻量级容器中,然后可以轻松地在任何环境中运行。这样,开发人员可以将容器作为独立的可移植单元在不同的环境中部署和运行应用程序,而不用担心环…

系统学习ElasticSearch

1.1 、ElasticSearch(简称ES) Elasticsearch是用Java开发并且是当前最流行的开源的企业级搜索引擎。 能够达到实时搜索,稳定,可靠,快速,安装使用方便。 客户端支持Java、.NET(C#)、…

SAP FICO财务月结-外币评估

月末操作-外币评估 —文章整理自高林旭老师的《由浅入深学习SAP财务》一书,SAP相关从业人员值得一读。 企业的外币业务在记账的时候一般都是使用期初的汇率或者即时汇率,但是在月末,需要按照月末汇率对外币的余额或者未清项进行重估&#xf…

c语言入门-3-打印复杂类型

打印复杂类型前言上代码字符整形浮点型打印超长小数向内存中申请空间局部变量,全局变量使用输入函数 scanf作用域生命周期深度解析1 c语言中数据类型2 这些字段类型的大小又是多少呢3 计算机的大小单位4 scanf 报错下一篇前言 语言本身的学习,有两点比较…

【前端】Vue项目:旅游App-(7)city:搜索框search和标签页Tabs

文章目录目标过程与代码搜索框初步自己实现取消功能样式修改标签页效果总代码修改的文件common.csscity.vuemain.js目标 过程与代码 搜索框 初步 在Vant文档中找到搜索框:Search搜索 按照文档要求引入(如果以插件的形式安装vant就不用这样引入&#x…

c语言 动态内存分配 柔性数组

常见的动态内存错误 对null指针的解引用操作 int main()//错误1 因为没有判断 {int* p (int*)malloc(10000);int i 0;for (i 0; i < 10; i){*(p i) i;}return 0; }对动态开辟空间的越界访问 int main() {int* p malloc(10 * sizeof(int));if (p NULL){return 1;}…

5G NR标准: 第16章 初始接入

第16章 初始接入 在 NR 中&#xff0c;初始接入功能包括&#xff1a; • 设备在进入系统覆盖区域时最初找到小区的功能和过程。 • 处于空闲/非活动状态的设备访问网络的功能和程序&#xff0c;通常是请求建立连接&#xff0c;通常称为随机访问。 在相当大的程度上&#xff0…

ORA-27102:out of memory Linux-x86_64 Error: 12: Cannot allocate memory

一 问题描述 无法启动数据库&#xff0c;报错&#xff1a; 二 排查思路 1.确保sga_target,sga_max_size比可用物理内存小 2.检查kernel.shmmax&#xff0c;kernel.shmall是否设置得太小 一般出现ORA-27102&#xff1a;out of memory&#xff0c;是/etc/sysctl.conf种内核参…

Apache Tomcat 存在 JsonErrorReportValve 注入漏洞(CVE-2022-45143)

漏洞描述 Apache Zeppelin是一款基于 Web 可实现交互式数据分析的notebook产品。 在Apache Zeppelin 0.10.1及以前的版本中“Move folder to Trash”功能存在路径遍历漏洞&#xff0c;由于未对InterpreterSettingManager类remove方法中id参数进行正确校验&#xff0c;攻击者可…

看完这篇文章,我再也不用担心线上出现 CPU 性能问题了(上)

目录CPU 使用率平均负载进程上下文切换总结生产环境上出现 CPU 性能问题是非常典型的一类问题&#xff0c;往往这个时候就比较考验相关人员排查问题的能力我相信不少小伙伴在工作当中多多少少都会碰到 CPU 出现性能瓶颈 不知道小伙伴们有没有跟我一样的感受——当 CPU 出现性能…

小红书排行榜 | 粉丝增量500w+,探寻爆款种草内容密码

随着兔年来临&#xff0c;回首上个月小红书母婴动态&#xff0c;行业热度依旧高涨&#xff0c;越来越多的达人和新品牌都涌入了小红书&#xff0c;母婴品牌要如何巧用小红书数据分析工具抢占用户心智&#xff1f;增量500w&#xff0b;的母婴博主有何亮点之处&#xff1f;和我一…

【甘特图软件部件】上海道宁与​DlhSoft助力您的Windows与移动应用程序开发

DlhSoft支持 使用可自定义的甘特图 时间轴、项目调度、资源负载图表、 看板、PERT图表和网络图 为您的WPF、ASP .NET、JavaScript 或macOS和iOS应用程序 设计更智能的应用程序 DlhSoft提供了 真正强大的甘特图软件部件 Apple平台开发人员可以 轻松地将其集成到 他们自…

equals和 == 的区别

1 问题equals和 都可以对于值类型&#xff0c;然后比较代数值是否相等。那么equals和 的具体区别是什么&#xff1f;2 方法 是运算符&#xff0c;可以使用在基本数据类型变量和引用数据类型变量中&#xff0c;如果比较的是基本数据类型&#xff1a;比较的是两个变量保存额数据…

嵌入式实时操作系统的设计与开发(二)

加载应用程序与创建程序运行环境 将应用程序从Flash加载到RAM的实现代码是一定在启动代码中的。 计算机系统的运行其实是CPU到相应的内存地址去取回指令&#xff0c;然后译码并执行指令&#xff0c;再依次从下一个地址取指、执行&#xff0c;而程序就是指令与数据的集合。 程序…

JAVAWeb开发(基于分片的网络状态查询方法、装置及存储介质)

本文基于分片的网络状态查询方法、装置及存储介质已是申请的专利。本人为第一发明人&#xff0c;这里给出来是提供一种写专利的范本&#xff0c;仅供参考。专利申请号&#xff1a;CN202110346967.5正文部分&#xff1a;技术领域本申请涉及但不限于计算机网络数据传输一致性领域…

opencv--颜色物体追踪 图片的形态学处理函数

目录 一、主要函数介绍 1. cv2.erode() 2. cv2.dilate() 3. cv2.findContours() 4. cv2.circle() 5. cv2.line() 二、代码 这里首先确定是否安装imutils库&#xff0c;这个库能让调整大小或者翻转屏幕等基本任务更加容易实现。这一次主要应用的是对于图片的形态学处理函…