镜像下载、域名解析、时间同步请点击 阿里云开源镜像站

部署rocketmq和可视化客户端

一、 服务器资源

服务名称:Linux服务器

IP:[请查看资源分配文档]

操作系统:CentOS 7.8 x64

二、rocketmq安装

2.1下载

下载地址:rocketmq.apache.org/dowloading/…

file

这里,咋们下载4.8.0版本

2.2、将压缩包放到 tools目录下并解压

rocketmq-all-4.8.0-bin-release.zip上传到/opt/tools目录下并解压并重命名

  1. # cd /opt/tools
  2. # unzip -d /opt/apps/ rocketmq-all-4.8.0-bin-release.zip
  3. # cd /opt/apps/
  4. # mv rocketmq-all-4.8.0-bin-release rocketmq-4.8.0

2.3、配置环境变量

  1. # vi /etc/profile

在文件末尾添加以下内容:

  1. #rocketmq env
  2. export ROCKETMQ_HOME=/opt/apps/rocketmq-4.8.0
  3. export PATH=$PATH:$ROCKETMQ_HOME/bin

使修改生效:

  1. # source /etc/profile

2.4、创建存储路径和日志目录

  1. # mkdir -p /opt/apps/rocketmq-4.8.0/store/{store,commitlog,consumequeue,index}
  2. # mkdir /opt/apps/rocketmq-4.8.0/logs

2.5、broker配置

备份原配置文件

  1. # cd /opt/apps/rocketmq-4.8.0/conf
  2. # mv broker.conf broker.conf.bak
  3. # vi broker.conf

添加以下内容:

  1. #ip为服务器内网地址,port可自由设置一般为9876
  2. namesrvAddr=xxx.xxx.x.xx:9876
  3. messageIndexSafe=true
  4. #是否允许Broker 自动创建。Topic,建议线下开启,线上关闭
  5. autoCreateTopicEnable=true
  6. waitTimeMillsInSendQueue=5000
  7. #发送消息线程池数量
  8. sendMessageThreadPoolNums=64
  9. useReentrantLockWhenPutMessage=true
  10. defaultReadQueueNums = 16
  11. defaultWriteQueueNums = 16
  12. #ip设置外网ip,不需要连接外网的话,可以在参数前面加#注释掉
  13. #brokerIP1=ip(外网ip)
  14. #默认值为DefaultCluster,可以修改为broker所属的哪个集群
  15. brokerClusterName=DefaultCluster
  16. #原始值为本机主机名,Broker名称
  17. brokerName=broker-a
  18. #BrokerId,必须是大等于 0 的整数,0 表示Master,>0 表示 Slave,一个 Master 可以挂多个 Slave,Master 与 Slave通过 BrokerName 来配对,原始值为0
  19. brokerId=0
  20. deleteWhen=04
  21. fileReservedTime=48
  22. brokerRole=ASYNC_MASTER
  23. flushDiskType=ASYNC_FLUSH
  24. #port可自由设置,一般设置10911
  25. listenPort=10911
  26. storePathRootDir=/opt/apps/rocketmq-4.8.0/store
  27. storePathCommitLog=/opt/apps/rocketmq-4.8.0/store/commitlog
  28. storePathConsumeQueue=/opt/apps/rocketmq-4.8.0/store/consumequeue
  29. storePathIndex=/opt/apps/rocketmq-4.8.0/store/index

修改启动脚本参数,根据自己linux的配置进行调整:

  1. # vi /opt/apps/rocketmq-4.8.0/bin/runbroker.sh

调整以下内容:

  1. JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

注意:Xms和Xmx至少是1G 否则启动不起来 Xmn一般是前者的一半,这边设置的内存不能大于机器实际的内存,根据实际情况调整

  1. # vi /opt/apps/rocketmq-4.8.0/bin/runserver.sh
  1. JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

注意:Xms和Xmx至少是1G 否则启动不起来 Xmn一般是前者的一半,这边设置的内存不能大于机器实际的内存,根据实际情况调整

2.6、启动NameSrv

  1. # nohup sh mqnamesrv > /opt/apps/rocketmq-4.8.0/logs/mqnamesrv.log 2>&1 &

验证是否启动成功

  1. # tail -f /opt/apps/rocketmq-4.8.0/logs/mqnamesrv.log

file

  1. # jps

file

2.7、启动broker

  1. # nohup sh mqbroker -c /opt/apps/rocketmq-4.8.0/conf/broker.conf >/opt/apps/rocketmq-4.8.0/logs/broker.log 2>&1 &

验证是否启动成功

  1. # tail -f /opt/apps/rocketmq-4.8.0/logs/broker.log

file

  1. # jps

file

2.8、停止broker

  1. # sh mqshutdown broker

备注:停止这个任务时不能用kill,如果用kill的话,重新启动的话,broker是启动不了的。

2.9、停止namesrv

  1. # sh mqshutdown namesrv

备注:停止这个任务时不能用kill,如果用kill的话,重新启动的话,broker是启动不了的。

三、配置防火墙

3.1、配置防火墙

启动9876、10911端口

  1. # firewall-cmd --permanent --add-port=9876/tcp
  2. # firewall-cmd --permanent --add-port=10911/tcp

重启防火墙

  1. # systemctl restart firewalld

四、可视化客户端

这里,rocketmq提供了可视化客户端,就是rocketmq-console-ng

4.1下载

下载地址

file

4.2源码打包

  1. mvn clean package -Dmaven.test.skip=true

如果你下载依赖慢,可以配置一下maven仓库地址,修改mavensettings.xml文件

  1. <mirrors>
  2. <mirror>
  3. <id>alimaven</id>
  4. <name>aliyun maven</name>
  5. <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
  6. <mirrorOf>central</mirrorOf>
  7. </mirror>
  8. </mirrors>

4.3jar包启动

打包成功后,可以看到target下,生成rocketmq-console-ng-1.0.0.jar

启动即可:

  1. java -jar target/rocketmq-console-ng-1.0.0.jar --server.port=7777 --rocketmq.config.namesrvAddr=xxxx:9876
  • server.port是指定启动端口
  • rocketmq.config.namesrvAddr是指定rocketmq的nameserver地址

file

可以看到启动成功!!!

  • 直接访问localhost:7777,即可看到rocketmq可视化客户端

file

好了,rocketmq部署成功,可视化客户端部署成功!!!

file

本文转自:https://juejin.cn/post/7091642840651923486

更多相关文章

  1. Android(安卓)Activity (1)
  2. Android(安卓)APP 启动时间统计
  3. Android启动和关闭Activity
  4. 2011.07.12——— android Foreground service
  5. Android实现开机自启动及开机自启动失败原因
  6. android 调用camera相关操作
  7. Android启动界面实现
  8. 在U盘下安装ubuntu20.04,从U盘启动Linux系统
  9. Android计时器

随机推荐

  1. 管理大量文件的提示?
  2. PHP正则表达式
  3. PHP代码在不需要时在Javascript中自动运
  4. Web2.0 (social media) 企业应用的架构
  5. HTML5关于get请求添加headers的问题
  6. 在页面重新加载时添加活动链接和jquery幻
  7. 采集资源的方法(文字,图片) [图片]
  8. 如何将添加到ajax html编辑器的文本保存
  9. 在Chtmlview中,浏览多frame的框架的网页,有
  10. 如何在应用程序中嵌入图像并在HTML控件中