本地部署 RocketMQ

参考：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart

修改conf/broker.conf

# 增加acl配置
#aclEnable=true
namesrvAddr 
authenticationEnabled = true
authenticationProvider = org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
initAuthenticationUser = {"username":"rocketmq","password":"12345678"}
innerClientAuthenticationCredentials = {"accessKey":"rocketmq","secretKey":"12345678"}
authenticationMetadataProvider = org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
authorizationEnabled = true
authorizationProvider = org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
authorizationMetadataProvider = org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider

修改conf/tools.yml

accessKey: rocketmq
secretKey: 12345678

启动服务

# 启动NameServer
nohup sh bin/mqnamesrv >> logs/mqnamesrv.log &
tail -f logs/mqnamesrv.log
# 启动Broker+Proxy
nohup sh bin/mqbroker -c conf/broker.conf --enable-proxy >> logs/mqbroker.log &
tail -f logs/mqbroker.log
# 停止NameServer
bin/mqshutdown namesrv
# 停止Broker+Proxy
bin/mqshutdown broker

使用命令行工具

# 查看cluster状态
bin/mqadmin clusterList
# 查看broker状态
 bin/mqadmin brokerStatus -c DefaultCluster
# 创建topic
bin/mqadmin updatetopic -c DefaultCluster -t TestTopic
# 主题列表
bin/mqadmin topicList -c DefaultCluster
# 创建组
bin/mqadmin updateSubGroup -c DefaultCluster -g TestGroup
# 创建用户
bin/mqadmin createUser -c DefaultCluster -u TestUser -p TestPassWd
# 查看用户
bin/mqadmin listUser -c DefaultCluster
# 创建acl
bin/mqadmin createAcl -c DefaultCluster -s User:TestUser -r Topic:TestTopic -a ALL -d ALLOW
# 查看当前acl
bin/mqadmin listAcl -c DefaultCluster