Rocketmq-简单部署
2024-09-05 05:45:07
一、准备环境
1.系统:Centos7.3(无硬性要求)
2. jdk:1.8
3.maven:3.5(无硬性要求)
4.git
5.rocketmq 4.2
二、环境部署
1.jdk1.8以及maven可以在另一篇文章查看【http://www.cnblogs.com/dingkailinux/p/8794611.html】
2.git安装
# yum -y install git
# git --version
git version 2.16.2
3.部署rocketmq
参考官方指导【https://rocketmq.apache.org/docs/quick-start/】
(1)下载源码
wget 'http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip'
(2)解压编译
# unzip rocketmq-all-4.2.-source-release.zip
# mv rocketmq-all-4.2. /opt/
# cd /opt/rocketmq-all-4.2.0# mvn -Prelease-all -DskipTests clean install -U #使用mvn编译
(3)编译完成后,调整配置
# cd distribution/target/apache-rocketmq #编译后的程序其实就在’apache-rocketmq‘中,这个目录可以单独拿出来启动
# cd /opt/rocketmq-all-4.2.0/distribution/target/
# cp -a apache-rocketmq /opt/rocketmq
# cd /opt/rocketmq #########调整启动内存#######
# vim bin/runserver.sh #调整nameserver启动的内存(如果服务器内存比较大,可以不调整),如果内存较小,不调整此文件,可能导致无法启动
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" #需要调整标红部分
# vim bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
########调整日志文件位置########
# vim conf/logback_broker.xml
# vim conf/logback_filtersrv.xml
# vim conf/logback_namesrv.xml
# vim conf/logback_tools.xml
以上四个文件,将类似于[${user.home}/logs/rocketmqlogs/namesrv_default.log]修改为自定义的日志路径,如[/data/logs/rocketmqlogs/namesrv_default.log],如果不修改,日志就会写入到用户目录下的logs目录下
(4)启动服务
# nohup sh bin/mqnamesrv & #启动nameserver
# tail -f nohup.outThe Name Server boot success #输出此类信息,说明启动成功
# tail -f nohup.out
#nohup sh bin/mqbroker -n 本地IP:9876 & #启动broker
INFO main - The broker[localhost, 172.17.154.196:10911] boot success. serializeType=JSON and name server is 172.17.154.196:9876 #日志输出如下信息,证明启动成功
3.向客户端提供NameServer地址
export NAMESRV_ADDR=172.17.154.196:
也可以将内容写入/etc/profile中
cat <<EOF>>/etc/profile
export NAMESRV_ADDR=172.17.154.196:
EOF source /etc/profile
4.模拟消息传送
()模拟producer产生消息
#cd /opt/rocketmq/
#sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer ()模拟consumer消费消息
#cd /opt/rocketmq/
#sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
最新文章
- js实现找质因数
- sh脚本异常:/bin/sh^M:bad interpreter: No such file or directory
- 轻松搞定C语言中复杂的声明
- 有关Java的优秀博客集锦
- Python Import 详解
- Android中string.xml文件中设置部分字体颜色大小
- 数学语言和程序语言的对比:面向过程与面向集合&;命题
- android 在一个scrollView里面嵌套一个需要滑动的控件(listView、gridView)
- C#中 字符串的处理
- 关于“minSdk>;deviceSdk”解决办法
- 汉化testlink
- java 随机生成11位 组合
- Java Map对象的遍历
- 关于多条数据转为json格式单次传输的问题 2017.05.27
- poj2689 Prime Distance
- Nest + typeorm
- 关于HttpModule和HttpHandler以及HttpApplication
- UI框架搭建DAY1
- [what is machine learning?]
- Win7-64位安装TensorFlow-CPU
热门文章
- System.Web.HttpRequestValidationException: 从客户端(name=";<;a href=&#39;&#39;>;我是晓菜鸟<;/a>;";)中检测到有潜在危险的 Request.Form 值
- HDU 6143 - Killer Names | 2017 Multi-University Training Contest 8
- json读写
- CF 940F - Machine Learning ( 带 修 )
- Git Clone 的时候遇到 Filename too long 错误
- [USACO5.5] 矩形周长Picture
- 内存管理3- @property 参数详解
- Selenium执行cdp命令,driver.execute_cdp_cmd用法
- ThreadGroupAPI
- storm滑动窗口