MongoDb with java：创建新的连接池并销毁前一个

Question

我正在用 java 实现 mongodb。每当我的应用程序启动时，就会为 mongoDB 创建新的连接池。有什么方法可以破坏该连接池并创建一个新连接池，而无需重新启动我的应用程序。我知道，如果 mongoURI 中的任何参数发生变化，连接池将重新初始化，但我想知道是否有任何方法可以在不更改 URI 参数的情况下做到这一点。主要目标是销毁连接池并创建新的连接池！这个连接池是由 MongoClient bean 创建的。因此我想销毁并重新创建 MongoClient Bean。

<bean id="monURI" class="com.mongodb.MongoClientURI"> <constructor-arg name="uri" value="${MONGO_URI}"/> </bean>

<bean id="mongoC" class="com.mongodb.MongoClient"> <constructor-arg ref="monURI"/> </bean>

Answer 1

您是否可以分享一些代码，以便我们对您的具体情况更有帮助？

在我工作的地方，我们使用的是com.mongodb.MongoClient。如果你也在使用它，你可以在销毁连接管理器组件之前调用mongoClient.close()（使用Spring，所以我们在组件的@PreDestroy 方法中调用close()）

------- 编辑 -------

按照我们的 cmets 回答这个问题，我会采用以下任何一种方法：

1. 使用您自己的包含 MongoClient 实例的类来包装 MongoClient。此类将公开一个方法（我们称之为 resetConnectionPool），在该方法中您将调用 mongoClient.close() 和 mongoClient = new MongoClient()。
   您可能必须 @Autowire MongoClientURI bean 才能在您创建的类中使用它。与此类类似的东西：

;

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.net.UnknownHostException;

@Component
public class MongoClientWrapper {
    @Autowired
    private MongoClientURI mongoClientURI;

    private MongoClient mongoClient;

    @PostConstruct
    public void init() {
        mongoClient = getNewMongoClientInstance();
    }

    @PreDestroy
    public void beforeTearDown() {
        mongoClient.close();
    }

    public void resetConnectionPool() {
        mongoClient.close();
        mongoClient = getNewMongoClientInstance();
    }

    private MongoClient getNewMongoClientInstance() {
        MongoClient client = null;
        try {
            client = new MongoClient(mongoClientURI.getURI());
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } finally {
            return client;
        }
    }
}

1. 重新考虑 MongoClient bean 的范围。也许它应该是每个请求或每个 http 会话而不是单例？查看这些链接以获取有关 bean 范围的更多信息：
   • https://docs.spring.io/spring/docs/3.0.0.M3/reference/html/ch04s04.html
   • https://www.tutorialspoint.com/spring/spring_bean_scopes.htm
   • https://www.baeldung.com/spring-bean-scopes
2. 根据此 javadoc：https://mongodb.github.io/mongo-java-driver/3.4/javadoc/com/mongodb/MongoClientURI.html，您可以向 URI 添加选项。您可以添加一个没有人使用但包含当前时间戳的选项。如果要重置池，只需更改该时间戳，然后“更改”URI，从而重置您的连接池。类似的东西：
   mongodb://[username:password@]host1:port1/dbName?_=1534228866003

----- 结束编辑 -----