安装准备
新上线系统要求安装recketmq或者以上版本。
2. RocketMQ部署配置规范
针对linux、unix操作系统,除一些操作系统配置、用户创建等操作外,所有RocketMQ软件安装以及配置、启动操作建议使用RocketMQ用户进行。
systemctl stop firewalld |
配置hosts 文件,每台服务器添加hosts文件信息。
按照口令要求进行口令创建。
cd /root/.ssh scp id_dsa.pub root@node2:~ scp id_dsa.pub root@node3:~ 拷贝的时候你会发现,是需要密码的。 cat ~/id_dsa.pub >>~/.ssh/authorized_keys |
7. 在官网下载rocketmq包并上传
官网地址:http://rocketmq.apache.org/
下载完成后按照要求上传到/opt/application/
安装部署规范
本规范暂时以rocketmq4.9版本为例。
cd /opt/application/ unzip rocketmq-all-4.9.0-bin-release.zip |
2. 安装java-jdk
修改配置:vi /etc/profile
生效:source /etc/profile
要注意如何是单机部署 rocketmq 要添加nameserver地址
添加完此配置后 启动nameserver:
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
单机服务:
Step1:
修改nameserver jvm参数
(内存默认 是4g要根据自己的实际 情况修改 一个 512M)
修改runserver.sh 修改内存为512M
Step2:
修改runbroker.sh jvm参数
(内存默认 是8g要根据自己的实际 情况修改 一个 512M)
修改runbroker.sh 修改内存为1g(界面内存)
启动nameserver 在bin录入下
nohup sh bin/mqnamesrv &
jps检验 启动进程
启动 broker
nohup ./mqbroker -c ../conf/broker.conf &
Step4:
开始搭建2主2从异步刷盘的集群,这个集群的搭建reckmq有对应的模板文件在conf/2m-2s-async 下的配置文件:
启动 :NameServer
Node1:
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup sh bin/mqnamesrv &
node2: NameServer 和 broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup sh bin/mqnamesrv &
启动:broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup ./mqbroker -c ../conf/2m-2s-async/broker-a.properties &
nohup ./mqbroker -c ../conf/2m-2s-async/broker-b-s.properties &
.-
node3: NameServer 和 broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup sh bin/mqnamesrv &
启动:broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup ./mqbroker -c ../conf/2m-2s-async/broker-b.properties &
nohup ./mqbroker -c ../conf/2m-2s-async/broker-a-s.properties &
消费消息和接受消息:
发送消息和接收消息
export NAMESRV_ADDR=192.168.1.5:9876
export NAMESRV_ADDR=192.168.1.4:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
rocketmq 源码中并没有提供控制台,但是在rocketmq社区扩展项目中提供一个控制台:
地址:
https:github.com.apache/recketmq-externals
/原始地址
https://github.com/apache/rocketmq-externals
//加速地址
https://codechina.csdn.net/mirrors/apache/rocketmq-externals/
下载rocketmq-console 项目:
1) 安装maven
yum install maven
2) 安装maven
yum install git
3) 下载rocketmq-externals代码
git clone https://codechina.csdn.net/mirrors/apache/rocketmq-externals/
4) 编译
(编译前可以先修改配置文件 vim src/main/resources/application.properties )cd rocketmq-externals/rocketmq-console/
mvn clean package -Dmaven.test.skip=true
在rocketmq-externals/rocketmq-console/target/目录下即为目标文件 :rocketmq-console-ng-2.0.0.jar
5) 运行
nohup java -jar rocketmq-console-ng-2.0.0.jar --rocketmq.config.namesrvAddr=localhost:9876 --server.port=8080 &
启动:
http://192.168.1.3:8080/#/
更多精彩干货分享
点击下方名片关注
IT那活儿
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/129815.html
摘要:本地的安装与调试标签启动进入的源码项目。消息发送的高性能与低延迟。强大的消息堆积能力与消息处理能力。严格的顺序消息存储。保证消息至少被消费一次,但不承诺消息不会被消费者多次消费。其消息的幂等由消费者自己实现。 本地RocketMQ的安装与调试 标签:【RocketMQ】 1. 启动 进入RocketMQ-ALL的源码项目。 执行maven打包: mvn -Prelease-all ...
摘要:前提通过前面两篇文章可以简单的了解和安装,今天就将和整合起来使用。然后我运行之前的整合项目,查看监控信息如下总结整篇文章讲述了与整合和监控平台的搭建。 showImg(https://segmentfault.com/img/remote/1460000013232432?w=1920&h=1277); 前提 通过前面两篇文章可以简单的了解 RocketMQ 和 安装 RocketMQ...
摘要:具体可以参考消息队列之具体可以参考实战之快速入门十分钟入门阿里中间件团队博客是一个分布式的可分区的可复制的基于发布订阅的消息系统主要用于大数据领域当然在分布式系统中也有应用。目前市面上流行的消息队列就是阿里借鉴的原理用开发而得。 我自己总结的Java学习的系统知识点以及面试问题,目前已经开源,会一直完善下去,欢迎建议和指导欢迎Star: https://github.com/Snail...
摘要:依次执行下面命令本地安装从官方安装包下载。管理界面提供多种管理方式命令行和界面等提供一个开源的扩展项目里面包含一个子项目配置下打个包就可以用了。 前言 github 开源项目--paascloud-master:https://github.com/paascloud/... paascloud-master 官方环境搭建:http://blog.paascloud.net/20...
摘要:我在前面的文章中也提到了应该怎么做自我介绍与项目介绍,详情可以查看这篇文章备战春招秋招系列初出茅庐的程序员该如何准备面试。因此基于事件消息对象驱动的业务架构可以是一系列流程。 showImg(https://user-gold-cdn.xitu.io/2018/11/14/16711ac29c2ae52c?w=928&h=531&f=png&s=798562); 一 消息队列MQ的...
阅读 1249·2023-01-11 13:20
阅读 1557·2023-01-11 13:20
阅读 1011·2023-01-11 13:20
阅读 1680·2023-01-11 13:20
阅读 3971·2023-01-11 13:20
阅读 2518·2023-01-11 13:20
阅读 1310·2023-01-11 13:20
阅读 3485·2023-01-11 13:20