`
gaojingsong
  • 浏览: 1210327 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
文章分类
社区版块
存档分类
最新评论

【阿里之RocketMQ相关的命令行操作】

阅读更多

一、启动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]# 

 

  • 大小: 58.2 KB
0
1
分享到:
评论

相关推荐

    阿里RocketMQ用户指南

    RocketMQ是一款由阿里巴巴开源的消息中间件,广泛应用于电子商务、金融服务等领域,尤其适合用于高并发、高可用的消息处理场景。本文档提供了详细的使用指南,涵盖了客户端的配置与使用方法、消息结构、消息收发、...

    rocketmq-console控制台已增加ACL鉴权和配置控制台登录验证

    RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域。RocketMQ Console是其官方提供的管理控制台,用于监控、管理和运维RocketMQ集群。在这个更新中,RocketMQ Console增加了...

    rocketMQ常用命令

    Apache RocketMQ是一款开源的分布式消息中间件,由阿里巴巴开源并贡献给了Apache社区,它主要用于企业级消息通讯领域,提供低延迟、高可靠的消息传递服务。在本文中,我们将详细介绍如何使用RocketMQ的一些常用命令...

    rocketmq安装包及RocketMQ 控制台JAR包

    RocketMQ 是一款开源的分布式消息中间件,由阿里巴巴开发并贡献给Apache基金会,它主要用于解决大规模分布式系统中的异步处理和解耦问题。本话题主要围绕RocketMQ的安装以及RocketMQ控制台JAR包的使用进行详细介绍。...

    rocketmq在windows中的部署

    RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据处理和实时计算场景。在Windows环境中部署RocketMQ,有助于开发者在本地进行快速测试和学习。以下将详细介绍如何在Windows上部署RocketMQ。 首先,...

    rocketmq管理工具,项目之前名字rocketmq-console后来项目独立并更名为rocketmq-dashboard

    - 运行:通过Java命令行运行JAR文件,指定相关的RocketMQ集群配置。 - 访问:在浏览器中输入服务器IP和端口号,即可访问管理界面。 4. **使用注意事项**: - 需要确保RocketMQ集群正常运行,并且NameServer地址...

    阿里云 专有云企业版 V3.8.1 消息队列 RocketMQ 版 用户指南 20200525

    9. 命令行操作:用户可以通过执行cd /d C:/window命令,进入Windows系统文件夹等方式来操作消息队列RocketMQ版。 10. 参数设置:用户可以通过bae log list --instanceidInstance_ID[]或者[a|b]表示可选项,至多选择...

    RocketMQ黑马笔记

    RocketMQ是阿里巴巴开源的消息中间件,在阿里内部历经了双十一等很多高并发场景的考验,能够处理亿万级别的消息。2016年开源后捐赠给Apache,现在是Apache的一个顶级项目。目前RocketMQ在阿里云上有一个购买即可用的...

    rockermq3.4.6安装包(含rockermq-console)

    - rocketmq_admin.zip:这是RocketMQ的命令行管理工具,用于执行各种管理操作,如启动、停止、发送消息等。 - rocketmq_namesrv.zip:包含RocketMQ的名字服务器(NameServer),它是整个MQ集群的核心组件,负责...

    RocketMq4.0下载安装包

    8. **bin**: 可执行脚本目录,包含了启动、停止RocketMQ服务的相关脚本,如start.sh、stop.sh等,方便用户在命令行中操作。 在部署RocketMQ时,你需要按照以下步骤进行: 1. 解压下载的安装包到一个合适的目录。 2...

    RocketMQ消息队列demo

    RocketMQ消息队列是阿里巴巴开源的一款分布式消息中间件,它主要设计用于处理大规模并发消息传输,提供高可用、高可靠以及高性能的消息服务。RocketMQ在阿里巴巴内部被广泛应用于订单、交易、用户行为等核心业务场景...

    rocketMQ文件,已打包

    RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域,具有高吞吐量、低延迟、高可用性以及可靠的消息传递能力。本压缩包包含RocketMQ在Linux和Windows两个操作系统上的安装...

    rocketmq.zip

    RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域,具有高可用、高并发、低延迟等特性。本压缩包"rocketmq.zip"包含了在Linux系统下安装RocketMQ所需的全部资源。 一、...

    RocketMQ 4.1.0 版本。已经编译通过版本

    RocketMQ 4.1.0 是一款开源的分布式消息中间件,由阿里巴巴贡献给Apache基金会,成为Apache顶级项目。此版本的RocketMQ已经完成了编译过程,确保了所有源代码都已成功转化为可执行的二进制文件,存放在"target"目录...

    rocketmq-all-5.0.0-bin-release.zip

    在“rocketmq-all-5.0.0-bin-release.zip”压缩包中,包含了RocketMQ的最新版本5.0.0的所有二进制文件和相关资源。这个版本的发布标志着RocketMQ功能的增强和性能的优化,旨在更好地满足开发者和企业的各种需求。 ...

    RocketMQ+Spring Cloud Stream环境搭建

    RocketMQ 是阿里巴巴开源的一款分布式消息中间件,它提供了高吞吐量、低延迟、高可用性和可扩展性的消息传递服务。而 Spring Cloud Stream 是一个框架,用于简化构建与云平台相集成的应用程序,特别是处理消息传递的...

    apache-rocketmq.tar.gz

    Apache RocketMQ是一款开源的消息中间件,它由阿里巴巴开发并捐赠给了Apache软件基金会,现在是一个顶级项目。RocketMQ设计用于大规模分布式系统中的高并发、低延迟、高可用性和高可扩展性的消息传递。在这个"apache...

    rocketmq windows版本 安装(单机和集群) 后台服务注册

    RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域。本文将详细介绍如何在Windows环境下安装RocketMQ,包括单机模式和集群模式,并且讲解如何进行后台服务注册。 **一、...

    rocketmq-externals-master.zip

    6. **消息队列云服务接口**:对于云环境,RocketMQ-Externals可能包含与云平台对接的API和服务,例如阿里云的RocketMQ服务,方便用户快速部署和管理RocketMQ实例。 7. **性能测试与基准**:为了评估RocketMQ的性能...

Global site tag (gtag.js) - Google Analytics