如何查看Hazelcast集群中各分区队列的大小？

当然有办法查看Hazelcast的分区队列大小，结合你的场景（1399个分区、EntryProcessor更新IMap导致部分操作耗时久），我整理了几种实用的方案：

1. 借助Hazelcast Management Center（管理中心） #

这是最直观的可视化方式，管理中心内置了分区监控面板：

• 登录管理中心后，进入集群详情页面，找到分区标签页
• 在这里可以看到所有分区的列表，点击任意分区就能查看其详细统计，包括操作队列大小、待处理操作数、处理延迟等指标，完全满足你查看每个分区队列大小的需求。

2. 通过JMX监控获取指标 #

Hazelcast会暴露大量JMX MBean用于监控，每个分区都有对应的监控节点：

• 用JConsole、VisualVM这类工具连接到集群中的任意节点
• 找到com.hazelcast域下的Partition相关MBean，其中operationQueueSize属性直接对应分区的队列大小
• 如果需要批量采集或自动化监控，也可以用JMX客户端脚本（比如基于Jolokia的脚本）来批量获取所有分区的队列数据。

3. 编程方式自定义获取 #

如果需要在应用内部直接获取分区队列大小，可以通过Hazelcast API实现：

• 先获取HazelcastInstance实例，再通过getPartitionService()拿到分区服务
• 遍历所有分区，针对每个本地负责的分区（每个分区仅由一个节点托管），调用getLocalPartitionStats()获取统计信息，其中getOperationQueueSize()方法返回队列大小
• 示例代码如下：

HazelcastInstance hazelcastInstance = Hazelcast.getHazelcastInstanceByName("your-cluster-name");
PartitionService partitionService = hazelcastInstance.getPartitionService();

for (Partition partition : partitionService.getPartitions()) {
    if (partition.isLocal()) {
        PartitionStats stats = partitionService.getLocalPartitionStats(partition.getPartitionId());
        int queueSize = stats.getOperationQueueSize();
        System.out.printf("分区ID: %d, 当前队列大小: %d%n", partition.getPartitionId(), queueSize);
    }
}

• 注意：这个方法只能获取当前节点托管的分区数据，若要收集全集群的分区队列信息，需要在每个节点上执行，或者通过分布式任务（比如ExecutorService）来汇总数据。

4. 使用Hazelcast CLI工具（适用于5.x及以上版本） #

如果你用的是Hazelcast 5.x或更高版本，可以通过官方CLI工具快速查询：

• 在终端执行hz-cli partition stats命令
• 命令会输出所有分区的详细统计数据，其中包含每个分区的操作队列大小，适合快速排查问题，无需额外配置。

额外排查建议 #

你提到部分EntryProcessor更新操作耗时久，除了查看队列大小，还可以关注：

• 分区的负载均衡：如果某个分区队列持续偏大，可能是该分区存在热点数据，导致操作集中
• 节点资源状态：CPU、内存、磁盘IO是否瓶颈，影响了分区操作的处理速度

内容的提问来源于stack exchange，提问作者user2966021