如何获取MongoDB等待队列当前条目数并排查队列满异常？

好问题！要获取MongoDB连接池等待队列的当前条目数，以及搞清楚为什么设置了WaitQueueSize=5000（配合maxPoolSize=1000）还会触发MongoWaitQueueFullException，咱们可以从以下几个方向入手：

一、获取当前等待队列的条目数 #

不同语言的MongoDB驱动都提供了连接池统计信息的API，以Java驱动为例，你可以通过连接池统计类直接获取等待队列的实时大小：

// 假设你已经初始化了MongoClient
MongoClient mongoClient = MongoClients.create("mongodb://your-host:27017");

// 获取目标主机的连接池统计信息
ServerAddress targetHost = mongoClient.getSettings().getClusterSettings().getHosts().get(0);
ConnectionPoolStatistics poolStats = mongoClient.getConnectionPoolStatistics(targetHost);

// 提取当前等待队列大小
int currentWaitQueueSize = poolStats.getWaitQueueSize();
System.out.printf("当前等待队列条目数: %d%n", currentWaitQueueSize);

除了getWaitQueueSize()，这个统计类还能提供其他关键指标帮你分析负载：

• getActiveConnections()：当前活跃的连接数
• getWaitQueueTotalTime()：所有请求在队列中等待的总时长
• getConnectionsCreated()：连接池创建的总连接数

二、为什么等待队列会被填满？ #

设置了5000的队列容量却还是触发异常，通常和以下几个原因有关：

• 连接泄漏：应用代码没有正确释放MongoDB连接（比如忘记关闭游标、没用到try-with-resources管理资源），导致连接池里的连接被长期占用，最终1000个连接全处于活跃状态，新请求只能进队列，很快填满上限。
• 慢查询拖垮连接池：如果存在执行时间极长的查询（比如未加索引的全表扫描），这些查询会占用连接数分钟甚至更久，连接池无法及时释放连接给新请求，队列会迅速累积请求直到满额。
• 请求量突增：应用在某个时间段遭遇流量峰值，短时间内的请求数超过了连接池处理能力（1000个活跃连接）+ 队列容量（5000）的总和，直接触发异常。
• 配置未生效：检查你的WaitQueueSize配置是否真的被应用到了MongoClient上。比如Java驱动中，需要通过ConnectionPoolSettings.builder().maxWaitQueueSize(5000)来配置，并且要把这个设置传入MongoClientSettings才能生效，别漏了这一步。

三、记录队列数据并关联应用活动 #

要找出队列满的根因，你需要把队列指标和应用的业务活动关联起来：

• 定时采集并记录指标：用定时任务（比如Java的ScheduledExecutorService）每隔几秒采集一次等待队列大小、活跃连接数等指标，把这些数据写入应用日志或者内部监控系统，方便后续回溯。
• 关联应用日志：在记录队列指标的同时，标记应用中的关键活动（比如批量数据导入任务、用户流量峰值时间段），对比队列增长的时间点，看是否和这些活动强相关。
• 开启MongoDB慢查询日志：在MongoDB实例上设置slowms参数（比如设为1000，即记录执行时间超过1秒的查询），找出耗时最久的查询，这些往往是占用连接、导致队列拥堵的元凶。
• 审计连接使用逻辑：检查应用代码中获取和释放连接的逻辑，确保所有MongoDB资源（比如游标、会话）都能被正确关闭，避免连接泄漏。

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