MongoDB Java 驱动返回的 FindIterable.iterator() 生成的是实现了 AutoCloseable 的 MongoCursor，若未显式关闭将导致连接、内存或游标资源长期占用，引发资源泄漏；正确做法是确保迭代完成后调用 close() 或使用 try-with-resources 管理生命周期。
mongodb java 驱动返回的 `finditerable.iterator()` 生成的是实现了 `autocloseable` 的 `mongocursor`，若未显式关闭将导致连接、内存或游标资源长期占用，引发资源泄漏；正确做法是确保迭代完成后调用 `close()` 或使用 try-with-resources 管理生命周期。
在 MongoDB Java Driver（3.x+）中，FindIterable.iterator() 返回的实际类型是 MongoCursor
❗ 问题本质：封装破坏了资源契约
你通过匿名内部类封装 it，虽隐藏了 MongoDB API，却也切断了 close() 调用路径。hasNext()/next() 不会自动触发关闭，且 Iterator 接口本身无 close() 方法，导致游标永不释放，尤其在大批量查询或高并发场景下易引发连接池耗尽、MongoDB 游标超时错误（如 Cursor not found）或内存泄漏。
✅ 正确解决方案（推荐两种模式）
方案一：改用 try-with-resources（适用于消费端控制迭代）
若调用方能配合资源管理，应避免返回裸 Iterator，转而提供函数式接口或直接执行消费逻辑：
public void forEachErrorUrl(int pCrawlId, Consumer<string> consumer) {
String collectionName = "collectionName";
MongoCollection<document> c = mongoDB.getCollection(collectionName);
Bson filter = Filters.not(eq("exploreStatus", "OK"));
Bson projection = fields(include("url"), excludeId());
FindIterable<document> docs = c.find(filter).projection(projection).batchSize(1000);
try (MongoCursor<document> cursor = docs.iterator()) { // ✅ 自动关闭
while (cursor.hasNext()) {
String url = cursor.next().getString("url");
consumer.accept(url);
}
} // cursor.close() 在此处被自动调用
}</document></document></document></string>
方案二：返回 AutoCloseableIterator（兼容现有 API 设计）
若必须保留 Iterator
public static class CloseableIterator<t> implements Iterator<t>, AutoCloseable {
private final Iterator<t> delegate;
private final Runnable onClose;
public CloseableIterator(Iterator<t> delegate, Runnable onClose) {
this.delegate = delegate;
this.onClose = onClose;
}
@Override
public boolean hasNext() { return delegate.hasNext(); }
@Override
public T next() { return delegate.next(); }
@Override
public void close() { onClose.run(); }
}
// 修改原方法：
@Override
public CloseableIterator<string> getErrorUrls(int pCrawlId) {
// ... 同前获取 docs 和 it ...
MongoCursor<document> cursor = (MongoCursor<document>) it; // 安全向下转型
return new CloseableIterator(
new Iterator<string>() {
@Override public boolean hasNext() { return cursor.hasNext(); }
@Override public String next() { return cursor.next().getString("url"); }
},
cursor::close // 绑定关闭动作
);
}</string></document></document></string></t></t></t></t>
调用方必须显式关闭：
try (CloseableIterator<string> iter = dao.getErrorUrls(123)) {
iter.forEachRemaining(System.out::println);
} // ✅ 自动触发 cursor.close()</string>
⚠️ 注意事项与最佳实践
- 禁止返回未封装的 MongoCursor：即使类型擦除后看似普通 Iterator，其 close() 语义不可忽略；
- 避免 iterator() 后长期持有引用：游标有默认超时（通常 10 分钟），但主动关闭更可靠；
- 批量处理优先使用 forEach() 或 into()：它们内部已做资源清理，比手动迭代更安全；
- Eclipse/IDEA 警告非误报：这是 JVM 资源泄漏检测的经典信号，务必响应而非忽略。
总之，资源安全不是“可选优化”，而是驱动层契约的一部分。封装 API 时，应将 AutoCloseable 责任向上透传或内置管理，而非隐藏——这才是真正健壮的抽象。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
