rocketmq

参考网址

安装

cd /var/ftp/
wget https://dlcdn.apache.org/rocketmq/4.9.1/rocketmq-all-4.9.1-bin-release.zip

2、
unzip /var/ftp/rocketmq-all-4.9.1-bin-release.zip -d /usr/local/

3、
mv /usr/local/rocketmq-all-4.9.1-bin-release/ /usr/local/rocketmq


4、
mkdir /usr/local/rocketmq/logs

5、
mv jdk jdk-11
tar xzvf /var/ftp/jdk-8u191-linux-x64.tar.gz -C /usr/local/
mv /usr/local/jdk1.8.0_191/ /usr/local/jdk
javac -version

6、
/usr/local/rocketmq/bin/mqnamesrv

7、
vi /usr/local/rocketmq/bin/runserver.sh

8、
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m"

9、
nohup /usr/local/rocketmq/bin/mqnamesrv > /usr/local/rocketmq/logs/rocketmq-namesrv.log 2>&1 &

10、
mkdir -p /usr/local/rocketmq/store/commitlog

11、
vi /usr/local/rocketmq/conf/broker.conf

namesrvAddr=rocketmq-server:9876
storePathRootDir=/usr/local/rocketmq/store
storePathCommitLog=/usr/local/rocketmq/store/commitlog
aclEnable=true
enablePropertyFilter=true
2、
vi /usr/local/rocketmq/conf/plain_acl.yml

3、
globalWhiteRemoteAddresses:
- 10.10.103.*
- 192.168.0.*
- 127.0.0.1

accounts:
- accessKey: RocketMQMuyan
  secretKey: helloyootk
  whiteRemoteAddress:
  admin: false
  defaultTopicPerm: PUB|SUB
  defaultGroupPerm: PUB|SUB
  topicPerms:
  - TopicMuyan=DENY
  - TopicYootk=PUB|SUB
  - TopicBenchmark=PUB|SUB
  groupPerms:
  # the group should convert to retry topic
  - yootk-group=DENY
  - muyan-group=PUB|SUB
  - happy-group=SUB

- accessKey: RocketMQAdmin
  secretKey: hello123456
  whiteRemoteAddress: 192.168.1.*
  # if it is admin, it could access all resources
  admin: true


12、vi /usr/local/rocketmq/bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"

13、
nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker.conf > /usr/local/rocketmq/logs/rocketmq-broker.log 2>&1 &

14、
vi /etc/profile
export NAMESRV_ADDR=rocketmq-server:9876

15、
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --zone=public --add-port=10911/tcp --permanent
firewall-cmd --zone=public --add-port=10912/tcp --permanent
firewall-cmd --zone=public --add-port=10909/tcp --permanent
firewall-cmd --reload


16、
org.apache.rocketmq.example.quickstart.Producer
org.apache.rocketmq.example.quickstart.Consumer

/usr/local/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
/usr/local/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

3、
#if this value is empty,use env value rocketmq.config.namesrvAddr  NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876
rocketmq.config.namesrvAddr=rocketmq-server:9876
rocketmq.config.accessKey=RocketMQMuyan
rocketmq.config.secretKey=helloyootk


4、
#Must create userInfo file: ${rocketmq.config.dataPath}/users.properties if the login is required
rocketmq.config.loginRequired=true


5、
# Define Admin，1：管理员、0：普通用户
admin=admin,1

# Define Users
muyan=yootk

7、
firewall-cmd --zone=public --add-port=8080/tcp --permanent
firewall-cmd --reload

8、
rocketmq-server:8080

9、
/usr/local/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
/usr/local/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

java -jar /usr/local/rocketmq/rocketmq-console-ng-1.0.1.jar > /usr/local/rocketmq/logs/rocketmq-console.log 2>&1 &

命令

jps
kill -9 XXX
nohup /usr/local/rocketmq/bin/mqnamesrv > /usr/local/rocketmq/logs/rocketmq-namesrv.log 2>&1 &
nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker.conf > /usr/local/rocketmq/logs/rocketmq-broker.log 2>&1 &
java -jar /mnt/project/boot/rocketmq-console/rocketmq-dashboard-1.0.1-SNAPSHOT.jar > /usr/local/rocketmq/logs/rocketmq-console.log 2>&1 &