RocketMQ快速开始

一时失言乱红尘 2022-05-15 06:05 219阅读 0赞

### 环境准备 ###

>  *  64bit OS, Linux/Unix/Mac is recommended
>  *  64bit JDK 1.8+
>  *  Maven 3.5.4
>  *  Git

### 1.Download ###

wget -c https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.3.0/rocketmq-all-4.3.0-source-release.zip

### 2.Build from Release ###

unzip rocketmq-all-4.3.0-source-release.zip
    cd rocketmq-all-4.3.0/
    mvn -Prelease-all -DskipTests clean install -U
    cd distribution/target/apache-rocketmq

### 3.Start Name Server ###

nohup sh bin/mqnamesrv &
    tail -f ~/logs/rocketmqlogs/namesrv.log
    The Name Server boot success...

### 4.Start Broker ###

nohup sh bin/mqbroker -n localhost:9876 &
    tail -f ~/logs/rocketmqlogs/broker.log 
    The broker[%s, 172.30.30.233:10911] boot success...

> 注意：如果这里启动失败，查看内存是否足够，打开runbroker.sh文件，对应修改参数为  
> JAVA\_OPT=”-server -Xms4g -Xmx4g -Xmn2g -XX:PermSize=128m -XX:MaxPermSize=320m”  
> 此时运行java程序时VM提示如下警告：  
> Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=512m; support was removed in 8.0  
> 原因：-XX:PermSize和-XX:MaxPermSize在jdk1.8中被弃用，使用-XX:MetaspaceSize和-XX:MaxMetaspaceSize替代  
> JAVA\_OPT=”-server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m”

按照官方文档\[ nohup sh bin/mqbroker -n localhost:9876 & \]启动broker会报错：

com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest1
    See http://docs.aliyun.com/cn#/pub/ons/faq/exceptions&topic_not_exist for further details.
        at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:542)
        at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1030)
        at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:989)
        at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:90)
        at com.yang.rocketmq.Producer.main(Producer.java:45)

>  *  将broker启动方式改为：nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &

### 5.Send & Receive Messages ###

> Before sending/receiving messages, we need to tell clients the location of name servers. RocketMQ provides multiple ways to achieve this. For simplicity, we use environment variable **NAMESRV\_ADDR**

export NAMESRV_ADDR=localhost:9876
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    SendResult [sendStatus=SEND_OK, msgId= ...
    
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
    ConsumeMessageThread_%d Receive New Messages: [MessageExt...

### 6.Shutdown Servers ###

sh bin/mqshutdown broker
    The mqbroker(36695) is running...
    Send shutdown request to mqbroker(36695) OK
    
    sh bin/mqshutdown namesrv
    The mqnamesrv(36664) is running...
    Send shutdown request to mqnamesrv(36664) OK