RocketMQ安装

1、安装

下载地址:http://rocketmq.apache.org/docs/quick-start/
选择binary release下载(也可以下载source release,但是需要maven编译)。
我下载的版本是rocketmq-all-4.7.1-bin-release.zip
1、解压文件:

> unzip rocketmq-all-4.7.1-bin-release.zip #解压
> mv rocketmq-all-4.7.1-bin-release rocketmq #重命名文件夹
> cd rocketmq

2、修改runserver.sh文件

> vim bin/runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改成
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn64m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

3、修改runbroker.sh文件:

> vim bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
修改成
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn64m"

这里设置了server、broker运行时需要的内存。如果不修改,服务器可能没有足够的内存,导致server或broker无法启动。
4、启动name server

> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log # 查看nameserv日志
> jps # 查看java进程
12642 Jps
12622 NamesrvStartup

5、启动broker

> nohup sh bin/mqbroker -n localhost:9876 &
> tail -f ~/logs/rocketmqlogs/broker.log #查看broker日志
> jps
12709 BrokerStartup
12838 Jps
12622 NamesrvStartup

注意:启动namesrv和broker时会有这样一个提示:nohup: ignoring input and appending output to 'nohup.out',直接按回车键即可。

6、测试
发送消息

> export NAMESRV_ADDR=localhost:9876 # 设置环境变量
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer #使用安装包的Demo发送消息

接受消息

> export NAMESRV_ADDR=localhost:9876 # 设置环境变量(我这里是打开了一个新的会话,如果是同一个会话,这一步操作可以省略)
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer # 接受消息

7、关闭服务

> sh bin/mqshutdown broker
> sh bin/mqshutdown namesrv
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。