一、启动RocketMQ
1)先启动NameServer
nohup sh mqnamesrv > ns.log 2>&1 &
实质启动的是com.alibaba.rocketmq.namesrv.NamesrvStartup对应的main()
备注runserver.sh 是一堆JVM参数
2)再启动Broker,默认端口9876
nohup sh mqbroker -n IP:Port > bk.log 2>&1 &
实质启动的是com.alibaba.rocketmq.broker.BrokerStartup对应的main()
备注runbroker.sh 是一堆JVM参数
总结:一步到位启动只需要运行 sh play.sh即可
[root@master bin]# sh play.sh
Start Name Server and Broker Successfully, 192.168.1.103:9876
二、查看帮助
[root@master bin]# sh mqadmin
The most commonly used mqadmin commands are:
updateTopic Update or create topic
deleteTopic Delete topic from broker and NameServer.
updateSubGroup Update or create subscription group
deleteSubGroup Delete subscription group from broker.
updateBrokerConfig Update broker's config
topicRoute Examine topic route info
topicStatus Examine topic Status info
brokerStatus Fetch broker runtime status data
queryMsgById Query Message by Id
queryMsgByKey Query Message by Key
queryMsgByOffset Query Message by offset
printMsg Print Message Detail
producerConnection Query producer's socket connection and client version
consumerConnection Query consumer's socket connection, client version and subscription
consumerProgress Query consumers's progress, speed
consumerStatus Query consumer's internal data structure
cloneGroupOffset clone offset from other group.
clusterList List all of clusters
topicList Fetch all topic list from name server
updateKvConfig Create or update KV config.
deleteKvConfig Delete KV config.
wipeWritePerm Wipe write perm of broker in all name server
resetOffsetByTime Reset consumer offset by timestamp(without client restart).
updateOrderConf Create or update or delete order conf
cleanExpiredCQ Clean expired ConsumeQueue on broker.
startMonitoring Start Monitoring
checkMsg Check Message Store
statsAll Topic and Consumer tps stats
syncDocs Synchronize wiki and issue to github.com
See 'mqadmin help <command>' for more information on a specific command.
1)查看Topic列表
[root@master bin]# sh mqadmin help topicList
usage: mqadmin topicList [-c] [-h] [-n <arg>]
-c,--clusterModel clusterModel
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
[root@master bin]# sh mqadmin topicList -n 192.168.1.103:9876
BenchmarkTest
TopicTest
DefaultCluster
SELF_TEST_TOPIC
%RETRY%please_rename_unique_group_name_4
TBW102
master
OFFSET_MOVED_EVENT
[root@master bin]#
2)创建Topic
[root@master bin]# sh mqadmin help updateTopic
usage: mqadmin updateTopic [-b <arg>] [-c <arg>] [-h] [-n <arg>] [-o <arg>] [-p <arg>] [-r <arg>] [-s <arg>]
-t <arg> [-u <arg>] [-w <arg>]
-b,--brokerAddr <arg> create topic to which broker
-c,--clusterName <arg> create topic to which cluster
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-o,--order <arg> set topic's order(true|false
-p,--perm <arg> set topic's permission(2|4|6), intro[2:R; 4:W; 6:RW]
-r,--readQueueNums <arg> set read queue nums
-s,--hasUnitSub <arg> has unit sub (true|false
-t,--topic <arg> topic name
-u,--unit <arg> is unit topic (true|false
-w,--writeQueueNums <arg> set write queue nums
[root@m bin]# sh mqadmin updateTopic -n 192.168.1.103:9876 -b 192.168.1.103:10911 -t gaojingsong
create topic to 192.168.1.103:10911 success.
TopicConfig [topicName=gaojingsong, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]
[root@master bin]# sh mqadmin topicList -n 192.168.1.103:9876
BenchmarkTest
TopicTest
DefaultCluster
SELF_TEST_TOPIC
%RETRY%please_rename_unique_group_name_4
TBW102
gaojingsong
master
OFFSET_MOVED_EVENT
3)统计Topic信息
[root@master bin]# sh mqadmin help topicStatus
usage: mqadmin topicStatus [-h] [-n <arg>] -t <arg>
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin topicStatus -n 192.168.1.103:9876 -t gaojingsong
#Broker Name #QID #Min Offset #Max Offset #Last Updated
master 0 0 0
master 1 0 0
master 2 0 0
master 3 0 0
master 4 0 0
master 5 0 0
master 6 0 0
master 7 0 0
[root@master bin]#
4)查看topicRoute信息
[root@master bin]# sh mqadmin help topicRoute
usage: mqadmin topicRoute [-h] [-n <arg>] -t <arg>
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin topicRoute -n 192.168.1.103:9876 -t gaojingsong
{
"brokerDatas":[
{
"brokerAddrs":{0:"192.168.1.103:10911"
},
"brokerName":"master"
}
],
"filterServerTable":{},
"queueDatas":[
{
"brokerName":"master",
"perm":6,
"readQueueNums":8,
"topicSynFlag":0,
"writeQueueNums":8
}
]
}
[root@master bin]#
4)查看所有Topic信息
[root@master bin]# sh mqadmin help statsAll
usage: mqadmin statsAll [-a] [-h] [-n <arg>]
-a,--activeTopic print active topic only
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
[root@master bin]# sh mqadmin statsAll -n 192.168.1.103:9876
#Topic #Consumer Group #InTPS #OutTPS #InMsg24Hour #OutMsg24Hour
BenchmarkTest 0.00 0 NO_CONSUMER
TopicTest please_rename_unique_group_name_ 0.00 0.00 0 0
DefaultCluster 0.00 0 NO_CONSUMER
SELF_TEST_TOPIC 0.00 0 NO_CONSUMER
TBW102 0.00 0 NO_CONSUMER
gaojingsong 0.00 0 NO_CONSUMER
master 0.00 0 NO_CONSUMER
OFFSET_MOVED_EVENT 0.00 0 NO_CONSUMER
[root@master bin]#
5)查看所有clusterList信息
[root@master bin]# sh mqadmin help clusterList
usage: mqadmin clusterList [-h] [-m] [-n <arg>]
-h,--help Print help
-m,--moreStats Print more stats
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
[root@master bin]# sh mqadmin clusterList -n 192.168.1.103:9876
#Cluster Name #Broker Name #BID #Addr #Version #InTPS #OutTPS
DefaultCluster master 0 192.168.1.103:10911 V3_2_6 0.00 0.00
[root@master bin]#
5)Delete相关的Topic
[root@master bin]# sh mqadmin help deleteTopic
usage: mqadmin deleteTopic -c <arg> [-h] [-n <arg>] -t <arg>
-c,--clusterName <arg> delete topic from which cluster
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin deleteTopic -n 192.168.1.103:9876 -t TopicTest
usage: mqadmin deleteTopic -c <arg> [-h] [-n <arg>] -t <arg>
-c,--clusterName <arg> delete topic from which cluster
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin deleteTopic -n 192.168.1.103:9876 -c DefaultCluster -t TopicTest
delete topic [TopicTest] from cluster [DefaultCluster] success.
delete topic [TopicTest] from NameServer success.
[root@master bin]# sh mqadmin statsAll -n 192.168.1.103:9876
#Topic #Consumer Group #InTPS #OutTPS #InMsg24Hour #OutMsg24Hour
BenchmarkTest 0.00 0 NO_CONSUMER
DefaultCluster 0.00 0 NO_CONSUMER
SELF_TEST_TOPIC 0.00 0 NO_CONSUMER
TBW102 0.00 0 NO_CONSUMER
gaojingsong 0.00 0 NO_CONSUMER
master 0.00 0 NO_CONSUMER
OFFSET_MOVED_EVENT 0.00 0 NO_CONSUMER
[root@master bin]#
相关推荐
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域。RocketMQ Console是其官方提供的管理控制台,用于监控、管理和运维RocketMQ集群。在这个更新中,RocketMQ Console增加了...
RocketMQ是一款由阿里巴巴开源的消息中间件,广泛应用于电子商务、金融服务等领域,尤其适合用于高并发、高可用的消息处理场景。本文档提供了详细的使用指南,涵盖了客户端的配置与使用方法、消息结构、消息收发、...
Apache RocketMQ是一款开源的分布式消息中间件,由阿里巴巴开源并贡献给了Apache社区,它主要用于企业级消息通讯领域,提供低延迟、高可靠的消息传递服务。在本文中,我们将详细介绍如何使用RocketMQ的一些常用命令...
RocketMQ 是一款开源的分布式消息中间件,由阿里巴巴开发并贡献给Apache基金会,它主要用于解决大规模分布式系统中的异步处理和解耦问题。本话题主要围绕RocketMQ的安装以及RocketMQ控制台JAR包的使用进行详细介绍。...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据处理和实时计算场景。在Windows环境中部署RocketMQ,有助于开发者在本地进行快速测试和学习。以下将详细介绍如何在Windows上部署RocketMQ。 首先,...
- 运行:通过Java命令行运行JAR文件,指定相关的RocketMQ集群配置。 - 访问:在浏览器中输入服务器IP和端口号,即可访问管理界面。 4. **使用注意事项**: - 需要确保RocketMQ集群正常运行,并且NameServer地址...
9. 命令行操作:用户可以通过执行cd /d C:/window命令,进入Windows系统文件夹等方式来操作消息队列RocketMQ版。 10. 参数设置:用户可以通过bae log list --instanceidInstance_ID[]或者[a|b]表示可选项,至多选择...
RocketMQ是阿里巴巴开源的消息中间件,在阿里内部历经了双十一等很多高并发场景的考验,能够处理亿万级别的消息。2016年开源后捐赠给Apache,现在是Apache的一个顶级项目。目前RocketMQ在阿里云上有一个购买即可用的...
- rocketmq_admin.zip:这是RocketMQ的命令行管理工具,用于执行各种管理操作,如启动、停止、发送消息等。 - rocketmq_namesrv.zip:包含RocketMQ的名字服务器(NameServer),它是整个MQ集群的核心组件,负责...
8. **bin**: 可执行脚本目录,包含了启动、停止RocketMQ服务的相关脚本,如start.sh、stop.sh等,方便用户在命令行中操作。 在部署RocketMQ时,你需要按照以下步骤进行: 1. 解压下载的安装包到一个合适的目录。 2...
RocketMQ消息队列是阿里巴巴开源的一款分布式消息中间件,它主要设计用于处理大规模并发消息传输,提供高可用、高可靠以及高性能的消息服务。RocketMQ在阿里巴巴内部被广泛应用于订单、交易、用户行为等核心业务场景...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域,具有高吞吐量、低延迟、高可用性以及可靠的消息传递能力。本压缩包包含RocketMQ在Linux和Windows两个操作系统上的安装...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域,具有高可用、高并发、低延迟等特性。本压缩包"rocketmq.zip"包含了在Linux系统下安装RocketMQ所需的全部资源。 一、...
RocketMQ 4.1.0 是一款开源的分布式消息中间件,由阿里巴巴贡献给Apache基金会,成为Apache顶级项目。此版本的RocketMQ已经完成了编译过程,确保了所有源代码都已成功转化为可执行的二进制文件,存放在"target"目录...
在“rocketmq-all-5.0.0-bin-release.zip”压缩包中,包含了RocketMQ的最新版本5.0.0的所有二进制文件和相关资源。这个版本的发布标志着RocketMQ功能的增强和性能的优化,旨在更好地满足开发者和企业的各种需求。 ...
RocketMQ 是阿里巴巴开源的一款分布式消息中间件,它提供了高吞吐量、低延迟、高可用性和可扩展性的消息传递服务。而 Spring Cloud Stream 是一个框架,用于简化构建与云平台相集成的应用程序,特别是处理消息传递的...
Apache RocketMQ是一款开源的消息中间件,它由阿里巴巴开发并捐赠给了Apache软件基金会,现在是一个顶级项目。RocketMQ设计用于大规模分布式系统中的高并发、低延迟、高可用性和高可扩展性的消息传递。在这个"apache...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域。本文将详细介绍如何在Windows环境下安装RocketMQ,包括单机模式和集群模式,并且讲解如何进行后台服务注册。 **一、...
6. **消息队列云服务接口**:对于云环境,RocketMQ-Externals可能包含与云平台对接的API和服务,例如阿里云的RocketMQ服务,方便用户快速部署和管理RocketMQ实例。 7. **性能测试与基准**:为了评估RocketMQ的性能...