RocketMQ学习

1.下载安装jdk1.8和rocketmq 

 下载linux 64位 jdk1.8+(自行百度资源) 

 下载 | RocketMQ (apache.org)

## 解压
tar -zxvf jdk-8u144-linux-x64.tar.gz
## 删除安装包
rm -rf jdk-8u144-linux-x64.tar.gz
##安装jdk环境变量自行百度

 解压rocketmq二进制包

## 解压
unzip rocketmq-all-4.9.4-bin-release.zip
## 删除安装包
rm -rf rocketmq-all-4.9.4-bin-release.zip

2.启动RocketMQ 要启动注册中心和Broker

    2.1 启动注册中心  NameServer

## 1.进入bin目录执行nohup sh mqnamesrv &## 2. 查看运行日志,具体日志目录根据自己实际去写
tail -f ~/logs/rocketmqlogs/namesrv.log或者cat nohup.out

     2.2 启动Broker

## 进入bin目录执行localhost 是安装mq的虚拟机ipnohup sh mqbroker -n localhost:9876 &

2.3 可能遇到问题:Rocketmq默认的虚拟内存较大,启动Broker会因为分配的虚拟内存不足导致启动失败,解决方法是手动修改JVM内存大小,在bin目录2个 .sh文件

vi runbroker.sh
vi runserver.sh
# 参考:
# 1. runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:PermSize=128m -XX:MaxPermSize=320m"# 2. runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m

 3. 配置环境变量  (目的不用每次进入rocketmq的bin目录执行命令)

总结:

# 启动namesrv
nohup sh mqnamesrv & 
# 启动broker
nohup sh mqbroker -n localhost:9876 &# 查看日志检查是否成功启动
cat nohup.out 或者jps#配置环境变量
vim /etc/profile
export NAMESRV_ADDR=192.168.126.132:9876  #(你的虚拟机ip,端口号一样)
source /etc/profile# 测试发送消息,
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
# 测试消费消息
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer# 关闭namesrv
sh mqshutdown namesrv
# 关闭broker
sh mqshutdown broker

 踩坑!!

DESC: service not available now. It may be caused by one of the following reasons:the broker's disk is full

 error='Cannot allocate memory' 

 重新修改runbroker.sh

 正常了

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

IT系统可观测性

什么是可观测性 可观测性(Observability)是指能够从系统的外部输出推断出系统内部状态的能力。在IT和云计算领域,它涉及使用软件工具和实践来收集、关联和分析分布式应用程序以及运行这些应用程序的硬件和网络产生的性能数据流。这样做可以更…

达梦如何备份以及导入

启动达梦服务 右键选择管理服务器 点击系统管理,点击配置,点击转换 归档配置点击归档 创建文件夹,选择文件夹目录点击确定 命令方式 逻辑备份与还原 逻辑导出(dexp)和逻辑导入(dimp)支持如下四种级别操作: 数据库级(FULL)&#…

【人工智能】英文学习材料03(每日一句)

🌻个人主页:相洋同学 🥇学习在于行动、总结和坚持,共勉! 目录 Chain Rule (链式法则) Dimensionality Reduction (降维) Long Short-Term Memory (LSTM) (长短期记忆网络) Gradient Explosion (梯度爆炸) Gradie…

线程池详解

线程池详解 一,为什么要用线程池 ① Java的线程模型是基于操作系统的原生线程模型实现的,所以说Java线程实际上是基于内核实现的,创建,析构,同步都需要从用户态切换至内核态,这样带来的性能损耗是很大的。…

数据库事务中“锁”的分类

数据库事务中的锁可以按照不同的维度进行分类。以下是一些常见的分类方式: 1、按锁的粒度分类: 行锁(Row-level lock):锁定单个或少量的数据行。这种锁粒度小,允许高度的并发,但管理开销大。页…

《1w实盘and大盘基金预测 day6》

昨日预测完美,点位基本符合,我预测3052,实际最低3055。 走势也符合高平开,冲高回落,再反震荡上涨 大家可以观察我准不准哟~后面有我的一些写笔记、分享的网站。 关注公众号,了解各种理财预测内…

【Windows 常用工具系列 15 -- VMWARE ubuntu 安装教程】

文章目录 安装教程镜像下载 工具安装 安装教程 安装教程参考链接:https://blog.csdn.net/Python_0011/article/details/131619864 https://linux.cn/article-15472-1.html 激活码 VMware 激活码连接:https://www.haozhuangji.com/xtjc/180037874.html…

STM32实验DMA数据搬运小助手

本次实验做的是将一个数组的内容利用DMA数据搬运小助手搬运到另外一个数组中去。 最后的实验结果: 可以看到第四行的数据就都不是0了,成功搬运了过来。 DMA实现搬运的步骤其实不是很复杂,复杂的是结构体参数: 整个步骤为&#xf…

三级等保技术建议书

1信息系统详细设计方案 1.1安全建设需求分析 1.1.1网络结构安全 1.1.2边界安全风险与需求分析 1.1.3运维风险需求分析 1.1.4关键服务器管理风险分析 1.1.5关键服务器用户操作管理风险分析 1.1.6数据库敏感数据运维风险分析 1.1.7“人机”运维操作行为风险综合分析 1.2…

JEDI:变形下分子和周期系统应变分析的通用代码

JEDI:变形下分子和周期系统应变分析的通用代码 拉伸或压缩会引起材料显着的能量、几何和光谱变化。为了在机械或压致变色材料、自修复聚合物和其他机械响应装置的设计中充分利用这些效应,必须详细了解材料中机械应变的分布。在过去的十年中,能…

PSCA系统控制集成之复位层次结构

PPU 提供以下对复位控制的支持。 • 复位信号Reset signals:PPU 提供冷复位和热复位输出信号。PPU 还为实现部分保留的电源域管理提供了额外的热复位输出信号。 • 电源模式控制Power mode control:PPU 硬件适当地管理每个支持的电源模式转换的复位信号…

代码随想录算法训练营第day29|491.递增子序列、 46.全排列、 47.全排列 II

目录 491.递增子序列 46.全排列 47.全排列 II 491.递增子序列 力扣题目链接 给定一个整型数组, 你的任务是找到所有该数组的递增子序列,递增子序列的长度至少是2。 示例: 输入: [4, 6, 7, 7]输出: [[4, 6], [4, 7], [4, 6, 7], [4, 6, 7, 7], [6, 7], [6, 7,…