RocketMQ User Guide
OPS Page
- You can change dashboard's namesrvAddr here
- You can change the value of useVIPChannel here (if you rocketMQ version < 3.5.8,the value of useVIPChannel should be false)
DashBoard Page
- broker's message count (broker total message count/5 min trend)
- topic's message count(topic total message count/5 min trend)
Cluster Page
- Cluster Detail
- relation between cluster and broker
- broker's master / salve node
- broker'a detail info(runtime info)
- broker's config
Topic Page
- show all the topics,you can filter topic by search bar
- filter (Normal/retry/dead) topic
- Add/Update Topic
- clusterName (create on which cluster)
- brokerName (create on which broker)
- topicName
- writeQueueNums
- readQueueNums
- perm //2 for write 4 for read 6 for write and read
- STATUS look over message send status(send to which broker/which queue/how many messages)
- ROUTER look update topic‘s router(this topic send to which broker,the broker’s queue info)
- CONSUMER MANAGE(this topic consume by which group,how about the consume state)
- TOPIC CONFIG(check or change the topic's config)
- SEND MESSAGE(send a test message)
- Reset CONSUMER OFFSET (the consumer online or not online is different,you need check the reset result)
- DELETE (will delete the topic on all broker and namesrv)
Consumer Page
- show all the consumers,you can filter consumer by search bar
- refresh page/refresh page per 5 seconds
- order by SubscriptionGroup/Quantity/TPS/Delay
- Add/Update Consumer
- clusterName (create on which cluster)
- brokerName (create on which broker)
- groupName (consumer group name)
- consumeEnable (this group can't consume message if this is false)
- consumeBroadcastEnable (can't use broadcast is this is false)
- retryQueueNums
- brokerId (consume form where when broker is normal)
- whichBrokerWhenConsumeSlowly(consume form where when broker has problem)
- CLIENT (look over online consumer's client,include subscribe info and consume mode)
- CONSUME DETAIL (look over this consumer's consume detail,broker offset and the consumer offset,queue consumed by which client)
- CONFIG (check or change the consumer's config)
- DELETE (delete the consumer group on selected group)
Producer Page
- Query online producer client by topic and group
- show client's server / version
Message Page
- Query By Topic And Time *Only Return 2000 Messages,the message more than 2000 will be hide
- Query By Topic And Key
- Query By Topic And MessageId
- look over this message‘s detail info.you can see the message’s consume state(each group has one line),show the exception message if has exception. you can send this message to the group you selected
Access Dashboard with HTTPS
- SpringBoot itself has provided the SSL configuration. You can use the project test Keystore:resources/rmqcngkeystore.jks. The store is generated with the following unix keytool commands:
#Generate Keystore and add alias rmqcngKey
keytool -genkeypair -alias rmqcngKey -keyalg RSA -validity 3650 -keystore rmqcngkeystore.jks
#View keystore content
keytool -list -v -keystore rmqcngkeystore.jks
#Transfer type as official
keytool -importkeystore -srckeystore rmqcngkeystore.jks -destkeystore rmqcngkeystore.jks -deststoretype pkcs12
- Uncomment the following SSL properties in resources/application.properties. restart Dashboard then access with HTTPS.
#Set https port
server.port=8443
### SSL setting
server.ssl.key-store=classpath:rmqcngkeystore.jks
server.ssl.key-store-password=rocketmq
server.ssl.keyStoreType=PKCS12
server.ssl.keyAlias=rmqcngkey
Login/Logout on Dashboard
Access Dashboard with username and password and logout to leave the dashboard。To stage the function on, we need the steps below:
- 1.Turn on the property in resources/application.properties.
# open the login func
rocketmq.config.loginRequired=true
# Directory of ashboard & login user configure file
rocketmq.config.dataPath=/tmp/rocketmq-console/data
- 2.Make sure the directory defined in property ${rocketmq.config.dataPath} exists and the file “users.properties” is created under it. The dashboard system will use the resources/users.properties by default if a customized file is not found。
The format in the content of users.properties:
# This file supports hot change, any change will be auto-reloaded without Console restarting.
# Format: a user per line, username=password[,N] #N is optional, 0 (Normal User); 1 (Admin)
# Define Admin
admin=admin,1
# Define Normal users
user1=user1
user2=user2
- 3.Restart Console Application after above configuration setting well.
Permission Control
If the login function is enabled when a user accesses the Console, the user controls the access permission of the interface based on the login role.
- 1.Turn on the property in resources/application.properties.
# open the login func
rocketmq.config.loginRequired=true
# Directory of ashboard & login user configure file
rocketmq.config.dataPath=/tmp/rocketmq-console/data
- 2.Make sure the directory defined in property ${rocketmq.config.dataPath} exists and the permission control file “role-permission.yml” is created under it. The console system will use the resources/role-permission.yml by default if a customized file is not found。
The format in the content of role-permission.yml:
# This file supports hot change, any change will be auto-reloaded without Console restarting.
# Format: To add or delete interface permissions, add or delete interface addresses from the list.
# the interface paths can be configured with wildcard characters.
# ?: Matches 1 characters.
# *: Matches 0 or more characters that are not /.
# **: Matches 0 or more characters.
rolePerms:
# ordinary user
ordinary:
- /rocketmq/nsaddr
- /ops/*
- /dashboard/**
- /topic/*.query
- /topic/sendTopicMessage.do
- /producer/*.query
- /message/*
- /messageTrace/*
- /monitor/*
....
- 3.On the front page, operation buttons such as deleting and updating resources are not displayed for common users in order to better distinguish the rights of common users and admin users. If need to operate related resources, log out and use the admin role to log in