searchusermenu
  • 发布文章
  • 消息中心
点赞
收藏
评论
分享
原创

RocketMQ常用运维命令总结

2024-05-31 09:20:44
76
0

1:集群列表查询

sh mqadmin clusterList -n <nameserver_address> [-c <clusterName>] [-t <topic>] [-r] [-w <timeout>] [-s <statusSet>]

用于查询 RocketMQ 集群状态的一个命令,其中 -n--namesrvAddr 参数是必须指定的,用于指定 NameServer 地址。这个命令可以帮助运维人员快速了解整个RocketMQ集群的概览信息,包括 Broker 的分布、状态等。下是这个命令的详细解释和可选参数以及输出内容:

-c, --clusterName: 指定集群名称。如果RocketMQ集群配置了多个集群,可以通过这个参数指定查询特定集群的信息。默认情况下,如果没有指定,会查询默认集群的信息。

-t, --topic: 查询特定主题相关的Broker信息。加上这个参数后,输出会更侧重于指定主题的队列分配和Broker状态。

-r, --showRemote: 显示远程Broker(即从Broker)的信息。默认情况下,命令可能只显示Master Broker的信息,这个选项可以让输出包括从Broker的详情。

-w, --timeout: 设置超时时间(单位毫秒)。用于指定执行该命令时等待响应的最长时间,超过此时间则命令视为失败。默认值通常是3000毫秒。

-s, --statusSet: 指定输出Broker的状态集合。比如,可以指定输出所有"STARTING"和"STOPPING"状态的Broker。如果未指定,则默认输出所有状态的Broker信息。

2:Broker配置自检

sh mqadmin brokerConfig -n <nameserver_address> -b <broker_ip>:<broker_port>

输出参数:

brokerName:Broker的名称,用于标识不同的Broker实例。

brokerId:Broker的唯一ID,用于区分同一集群中的不同Broker实例。

namesrvAddr:Broker连接的NameServer地址列表,以逗号分隔,如需连接多个NameServer。

storePathRootDir:RocketMQ存储消息和配置文件的根目录路径。

storePathCommitLog:Commit Log存储路径,Commit Log是RocketMQ用来存储消息主体的地方。

storePathConsumerQueue:Consumer Queue存储路径,存储消息消费队列的元数据信息。

messageStoreConfig:这部分包含消息存储相关的配置,如mapedFileSizeCommitLog(Commit Log文件大小)、flushDiskType(刷盘策略)、deleteWhen(消息删除策略)等。

brokerRole:Broker的角色,可以是SYNC_MASTER(同步Master)、ASYNC_MASTER(异步Master)、SLAVE(从节点)。

flushDiskType:数据刷盘方式,如SYNC_FLUSH(同步刷盘)或ASYNC_FLUSH(异步刷盘)。

brokerIP1:Broker监听的IP地址,用于客户端连接。

listenPort:Broker的监听端口,客户端通过此端口与Broker通信。

fetchMinBytes:从Broker拉取消息时,允许的最小字节数。

fetchWaitMaxMs:拉取请求的最大等待时间,单位为毫秒。

0条评论
作者已关闭评论
吴****斌
1文章数
0粉丝数
吴****斌
1 文章 | 0 粉丝
吴****斌
1文章数
0粉丝数
吴****斌
1 文章 | 0 粉丝
原创

RocketMQ常用运维命令总结

2024-05-31 09:20:44
76
0

1:集群列表查询

sh mqadmin clusterList -n <nameserver_address> [-c <clusterName>] [-t <topic>] [-r] [-w <timeout>] [-s <statusSet>]

用于查询 RocketMQ 集群状态的一个命令,其中 -n--namesrvAddr 参数是必须指定的,用于指定 NameServer 地址。这个命令可以帮助运维人员快速了解整个RocketMQ集群的概览信息,包括 Broker 的分布、状态等。下是这个命令的详细解释和可选参数以及输出内容:

-c, --clusterName: 指定集群名称。如果RocketMQ集群配置了多个集群,可以通过这个参数指定查询特定集群的信息。默认情况下,如果没有指定,会查询默认集群的信息。

-t, --topic: 查询特定主题相关的Broker信息。加上这个参数后,输出会更侧重于指定主题的队列分配和Broker状态。

-r, --showRemote: 显示远程Broker(即从Broker)的信息。默认情况下,命令可能只显示Master Broker的信息,这个选项可以让输出包括从Broker的详情。

-w, --timeout: 设置超时时间(单位毫秒)。用于指定执行该命令时等待响应的最长时间,超过此时间则命令视为失败。默认值通常是3000毫秒。

-s, --statusSet: 指定输出Broker的状态集合。比如,可以指定输出所有"STARTING"和"STOPPING"状态的Broker。如果未指定,则默认输出所有状态的Broker信息。

2:Broker配置自检

sh mqadmin brokerConfig -n <nameserver_address> -b <broker_ip>:<broker_port>

输出参数:

brokerName:Broker的名称,用于标识不同的Broker实例。

brokerId:Broker的唯一ID,用于区分同一集群中的不同Broker实例。

namesrvAddr:Broker连接的NameServer地址列表,以逗号分隔,如需连接多个NameServer。

storePathRootDir:RocketMQ存储消息和配置文件的根目录路径。

storePathCommitLog:Commit Log存储路径,Commit Log是RocketMQ用来存储消息主体的地方。

storePathConsumerQueue:Consumer Queue存储路径,存储消息消费队列的元数据信息。

messageStoreConfig:这部分包含消息存储相关的配置,如mapedFileSizeCommitLog(Commit Log文件大小)、flushDiskType(刷盘策略)、deleteWhen(消息删除策略)等。

brokerRole:Broker的角色,可以是SYNC_MASTER(同步Master)、ASYNC_MASTER(异步Master)、SLAVE(从节点)。

flushDiskType:数据刷盘方式,如SYNC_FLUSH(同步刷盘)或ASYNC_FLUSH(异步刷盘)。

brokerIP1:Broker监听的IP地址,用于客户端连接。

listenPort:Broker的监听端口,客户端通过此端口与Broker通信。

fetchMinBytes:从Broker拉取消息时,允许的最小字节数。

fetchWaitMaxMs:拉取请求的最大等待时间,单位为毫秒。

文章来自个人专栏
消息中间件RocketMQ
1 文章 | 1 订阅
0条评论
作者已关闭评论
作者已关闭评论
0
0