RocketMQ搭建与配置

蔚落 2022-11-27 07:09 244阅读 0赞

RocketMQ

Apache RockerMQ是一个分布式消息传递引擎，轻量级的数据处理平台。
它具有以下的特性:

  • 低延迟： 高压下在1毫米内响应延迟超过99.6%。
  • 财务导向：具有跟踪和审核功能的高可用性。
  • 产业可持续发展：万亿级消息容量。
  • 大数据友好：具有通用集成功能的批处理传输实现大批量吞吐。
  • 兼容性好：提供开放式分布式消息传递和流传输标准。
  • 万亿级容量：给定足够的磁盘空间，可以在不损失性能的情况下累计邮件。

RocketMQ安装与配置

第一步：下载安装包并解压
无法识别unzip: yum install -y unzip zip

  1. cd /usr/local
  2. ##解压
  3. unzip rocketmq-all-4.7.1-bin-release.zip
  5. chmod -777  rocketmq-all-4.7.1-bin-release/*

第二步：修改配置
配置：broker.conf

  1. vim rocketmq-all-4.7.1-bin-release/conf/broker.conf
  2. namesrvAddr=127.0.0.1:9876
  3. brokerIP1=127.0.0.1
  4. autoCreateSubscriptionGroup=true
  5. brokerClusterName = DefaultCluster
  6. brokerName = broker-a
  7. brokerId = 0
  8. deleteWhen = 04
  9. fileReservedTime = 48
  10. brokerRole = ASYNC_MASTER
  11. flushDiskType = ASYNC_FLUSH
  • 如果需要设置外网访问：127.0.0.1 替换成对应外网IP

第三步：根据服务情况修改启动参数
配置 runserver.sh，修改内存大小

  1. vim rocketmq-all-4.7.1-bin-release/bin/runserver.sh
  3. JAVA_OPT="${ JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g
  4. -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

配置：runbroker.sh，修改broker

  1. vim rocketmq-all-4.7.1-bin-release/bin/runbroker.sh
  2. JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx256m -Xmn256m"
  4. JAVA_OPT="${JAVA_OPT} -Drocketmq.broker.diskSpaceWarningLevelRatio=0.99"

rocketMQ有磁盘大小限制，个人服务器搭建建议添加：
JAVA_OPT=”${JAVA_OPT} -Drocketmq.broker.diskSpaceWarningLevelRatio=0.99”
只有磁盘空间使用率达到99%时才拒绝接收producer消息

第四步：启动和停止服务
启动服务

  1. nohup sh bin/mqnamesrv 
  3. nohup sh bin/mqbroker -n 127.0.0.1:9876 -c conf/broker.conf autoCreateTopicEnable=true&
  • 如果需要设置外网访问：127.0.0.1 替换成对应外网IP

使用jsp指令验证进程是否开启
在这里插入图片描述

停止服务

  1. sh bin/mqshutdown broker
  3. sh bin/mqshutdown namesrv

第五步：验证功能
验证生产者

  1. export NAMESRV_ADDR=127.0.0.1:9876
  2. sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

在这里插入图片描述

验证消费者

  1. sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

在这里插入图片描述

在这里插入图片描述

发表评论

表情：
评论列表 （有 0 条评论，244人围观）

还没有评论，来说两句吧...

相关阅读

    相关 RocketMQ搭建与配置

    [RocketMQ][] Apache RockerMQ是一个分布式消息传递引擎，轻量级的数据处理平台。 它具有以下的特性: 低延迟： 高压下在1毫米内响应延

    蔚落蔚落/ 0 赞/ 245 阅读

    相关 Hexo 搭建：搭建与配置

        其实很久之前就有搭建自己博客的想法，但是一直都没有时间去实践，最近刚好有时间，就尝试搭建了一下，不多说废话，直接进入主题，首先就是环境问题了 准备环境     

    系统管理员系统管理员/ 0 赞/ 607 阅读