RocketMQ

RocketMQ

RocketMQ4.5.2安装

下载安装包

下载地址:http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.5.2/rocketmq-all-4.5.2-bin-release.zip

系统要求

  • 64位操作系统,生产环境建议Linux环境

  • 64位JDK 1.8+

  • 内存越大越好

注意:如果有防火墙,则需要开通9876,10911,10909端口,否则会报错

RocketMQ Message hasn't been sent. Caused by Send [1] times, still failed, cost [3572]ms, Topic: naka_msg_topic, BrokersSent: [broker-a]

Linux安装

1. 解压压缩包到/usr/local/src目录下:

unzip rocketmq-all-4.5.2-bin-release.zip -d /usr/local/src

2. 进入RocketMQ下的bin目录:

cd rocketmq-all-4.5.2-bin-release/bin/

3. 除非服务器配置够高,否则建议执行这一步,修改runserver.sh和runbroker.sh

            runbroker.sh修改如下,第一个JAVA_OPT改成:

    JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"


            runserver.sh修改如下,第一个JAVA_OPT改成:

    JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"

4. 回到根目录,启动NameServer:

    cd ../
    nohup sh bin/mqnamesrv &
    • 验证启动是否成功

    tail -f ~/logs/rocketmq/namesrv.log
    • 如果启动成功,则会看到如下日志

    2019-08-26 21:45:37 INFO main - The Name Server boot success. serializeType=JSON

5. 启动Broker:

nohup sh bin/mqbroker -n localhost:9876 &

    指定broker配置文件启动:

    nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &

    可选命令:

    autoCreateTopicEnable=true

    验证启动是否成功:

    tail -f ~/logs/rocketmq/broker.log

    如果启动成功,会看到类似如下的日志:

    INFO main - The broker[192.168.137.131:10911] boot success. serializeType=JSON and name server is localhost:9876







除特别注明外,本站所有文章均为东哥技术分享原创,转载请注明出处来自http://quliming.com/post/93.html

评论回复