RocketMQ

Apache RocketMQ

---

相关地址

Git地址：https://github.com/apache/incubator-rocketmq

快速入门：https://rocketmq.incubator.apache.org/docs/quick-start/

编译好的文件：https://rocketmq.incubator.apache.org/dowloading/releases/

---

下载源码并进行编译

>  git clone https://github.com/apache/incubator-rocketmq.git

>  cd incubator-rocketmq

>  mvn clean package install -Prelease-all assembly:assembly -U

>  cd target/apache-rocketmq-all/

Start Name Server

> nohup sh bin/mqnamesrv &

> tailf nohup.out

Start Broker

> nohup sh bin/mqbroker -n localhost:9876 &

> tailf nohup.out

注意 如果这里启动失败，看一下内存是否足够，可以看一下“runbroker.sh”这个文件，对应的修改参数，如下

JAVA_OPT="-server -Xms4g -Xmx4g -Xmn2g -XX:PermSize=128m -XX:MaxPermSize=320m"

测试发送与接收

> export NAMESRV_ADDR=localhost:9876

> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

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

关闭服务

> sh bin/mqshutdown broker

> sh bin/mqshutdown namesrv