国外响应式网站,大名网站建设费用,虚拟现实企业解决方案,怎么开发一个小程序一、什么是RocketMQ RocketMQ是阿里巴巴开源的一个消息中间件#xff0c;在阿里内部历经了双十一等很多高并发场景的考验#xff0c;能够处理亿万级别的消息。2016年开源后捐赠给Apache#xff0c;现在是Apache的一个顶级项目。 早期阿里使用ActiveMQ#xff0c…一、什么是RocketMQ RocketMQ是阿里巴巴开源的一个消息中间件在阿里内部历经了双十一等很多高并发场景的考验能够处理亿万级别的消息。2016年开源后捐赠给Apache现在是Apache的一个顶级项目。 早期阿里使用ActiveMQ但是当消息开始逐渐增多后ActiveMQ的IO性能很快达到了瓶颈。于是阿里开始关注Kafka。但是Kafka是针对日志收集场景设计的他的高级功能并不是很贴合阿里的业务场景。尤其当他的Topic过多时由于Partition文件也会过多这就会加大文件索引的耗时会严重影响IO性能。于是阿里才决定自研中间件最早叫做MetaQ后来改名成为RocketMQ。最早他所希望解决的最大问题就是多Topic下的IO性能压力。但是产品在阿里内部的不断改进RocketMQ开始体现出一些不一样的优势。 二、下载压缩包
RocketMQ的官网地址http://rocketmq.apache.org
下载地址https://rocketmq.apache.org/download
选择4.9.5稳定版本进行下载
三、安装RocketMQ 将下载好的rocketmq-all-4.9.5-bin-release.zip上传至服务器/usr/local/目录下
解压 unzip rocketmq-all-4.9.5-bin-release.zip 四、启动namesever
修改/usr/local/rocketmq-all-4.9.5-bin-release/bin/runserver.sh配置:
JAVA_OPT${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m
修改为
JAVA_OPT${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m -- 进入rocketmq安装目录
cd /usr/local/rocketmq-all-4.9.5-bin-release-- 启动nameserver服务
nohup bin/mqnamesrv 查看nohup.out文件出现 The Name Server boot success. serializeTypeJSON 表示启动成功。
五、启动broker
1.修改配置文件/usr/local/rocketmq-all-4.9.5-bin-release/conf/broker.conf
添加如下配置 #自动创建topic
autoCreateTopicEnable true
#设置brokerip
brokerIP1 43.142.xx.xxx
#设置nameserverip
namesrvAddr 43.142.xx.xxx:9876 调整runbroker.sh中的内存大小
JAVA_OPT${JAVA_OPT} -server -Xms8g -Xmx8g
修改为
JAVA_OPT${JAVA_OPT} -server -Xms512m -Xmx512m
2.启动 broker服务
-- 指定配置文件启动
nohup bin/mqbroker -c conf/broker.conf
查看nohup.out文件出现The broker[broker-a, 43.142.91.252:10911] boot success.代表broker启动成功。
使用jps命令查看启动的服务 六、停止服务
# 1.关闭NameServer
bin/mqshutdown namesrv
# 2.关闭Broker
bin/mqshutdown broker
