RocketMQ搭建与配置

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

# [RocketMQ][] #

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

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

## RocketMQ安装与配置 ##

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

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

**第二步：修改配置**  
[配置：broker.conf][broker.conf]

vim rocketmq-all-4.7.1-bin-release/conf/broker.conf
    namesrvAddr=127.0.0.1:9876
    brokerIP1=127.0.0.1
    autoCreateSubscriptionGroup=true
    brokerClusterName = DefaultCluster
    brokerName = broker-a
    brokerId = 0
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = ASYNC_MASTER
    flushDiskType = ASYNC_FLUSH

*  如果需要设置外网访问：127.0.0.1 替换成对应外网IP

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

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

配置：runbroker.sh，修改broker

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

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

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

nohup sh bin/mqnamesrv 
    
    nohup sh bin/mqbroker -n 127.0.0.1:9876 -c conf/broker.conf autoCreateTopicEnable=true&

*  如果需要设置外网访问：127.0.0.1 替换成对应外网IP

使用jsp指令验证进程是否开启  
![在这里插入图片描述][20200817171932113.png_pic_center]

停止服务

sh bin/mqshutdown broker
    
    sh bin/mqshutdown namesrv

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

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

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]

验证消费者

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

![在这里插入图片描述][20200814134643850.png_pic_center]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 1]

[RocketMQ]: http://rocketmq.apache.org/
[Link 1]: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip
[broker.conf]: https://www.cnblogs.com/qdhxhz/p/11116197.html
[20200817171932113.png_pic_center]: /images/20221124/a701374094fa4c79b5c8bc4eb5dd86e3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/7ff29f81e01e46be84dd3e748709b4c6.png
[20200814134643850.png_pic_center]: /images/20221124/44ea3976666946c2811b2443042fa15e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/acd996f1bdc14e26b43edb817b032df7.png