rocketmq-单机搭建
一、单机安装与启动
1、准备工作
JDK要求1.8及以上版本
下载RocketMQ安装包
https://rocketmq.apache.org/
将下载的安装包上传到服务器,解压安装包。
unzip rocketmq-all-4.8.0-bin-release.zip
2、修改初始内存
去bin目录下找到runserver.sh,搜索JAVA_OPT="${JAVA_OPT} -server,修改值
去bin目录下找到runbroker.sh
2、启动
启动NameServer
在安装目录下执行内容如下
> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...
启动broker
在安装目录下执行内容如下
> nohup sh bin/mqbroker -n localhost:9876 &
> tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 172.30.30.233:10911] boot success...
3、停止
停止broker
> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
停止NameServer
> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
二、RocketMQ控制台安装与启动
RocketMQ有一个可视化的dashboard界面,通过控制台可以直观的看到很多数据。
1、下载
https://github.com/apache/rocketmq-externals/tags
2、修改配置
解压 rocketmq-externals-rocketmq-console-1.0.0.zip,找到application.properties并修改。
1)、修改默认端口,这里改为7000
2)、指定rocketmq的nameserver地址
3、添加maven依赖
javax.xml.bind
jaxb-api
2.3.0
com.sun.xml.bind
jaxb-impl
2.3.0
com.sun.xml.bind
jaxb-core
2.3.0
javax.activation
activation
1.1.1
4、打包,打成jar包
mvn clean package -Dmaven.test.skip=true
5、启动
java -jar rocketmq-console-ng-1.0.0.jar