如何在Java中配置mongodb連接

今天就跟大家聊聊有關如何在Java中配置mongodb連接，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

Java的特點有哪些

Java的特點有哪些 1.Java語言作為靜態面向對象編程語言的代表，實現了面向對象理論，允許程序員以優雅的思維方式進行復雜的編程。 2.Java具有簡單性、面向對象、分布式、安全性、平臺獨立與可移植性、動態性等特點。 3.使用Java可以編寫桌面應用程序、Web應用程序、分布式系統和嵌入式系統應用程序等。

1. MongoClientOptions中的連接池配置:

配置如下:

connectionPoolSettings = ConnectionPoolSettings.builder()
                            .minSize(getMinConnectionsPerHost())
                            .maxSize(getConnectionsPerHost())
                            .maxWaitQueueSize(getThreadsAllowedToBlockForConnectionMultiplier()
                                     * getConnectionsPerHost())
                            .maxWaitTime(getMaxWaitTime(), MILLISECONDS)
                            .maxConnectionIdleTime(getMaxConnectionIdleTime(), MILLISECONDS)
                            .maxConnectionLifeTime(getMaxConnectionLifeTime(), MILLISECONDS)
                            .build();

minSize: 線程池空閑時保持的最小連接數, 默認是0.

maxSize: 線程池允許的最大連接數,默認是100.

maxWaitQueueSize: 線程池等待隊列的大小, 默認是500.

maxWaitTime: 線程等待連接變為可用的最長時間.默認為2分鐘. 值為0意味著它不會等待. 負值意味著它將無限期地等待

maxConnectionIdleTime: 線程池中連接的最大空閑時間, 0標志Udine空閑時間沒有限制,超過這個時間會被關閉.

maxConnectionLifeTime: 線程池中連接的最長生存時間. 0表示沒有限制. 超過壽命的會被關閉,必要時通過新連接進行替換.

2. MongoClientOptions初始化

mongodb驅動中 MongoClientOptions 使用Buidler模式配置,有關所有屬性的默認值,都是在Builder里邊配置的.

關于Builder 的配置如下:

  public static class Builder {
    private String description;
    private String applicationName;
    //讀取偏好, 這里默認的是從主節點讀取.
    private ReadPreference readPreference = ReadPreference.primary();
    //使用服務器默認的寫關注?
    private WriteConcern writeConcern = WriteConcern.ACKNOWLEDGED;
    //使用服務的默認讀關注,默認是local
    private ReadConcern readConcern = ReadConcern.DEFAULT;
    private CodecRegistry codecRegistry = MongoClient.getDefaultCodecRegistry();
    private final List<CommandListener> commandListeners = new ArrayList<CommandListener>();
    private final List<ClusterListener> clusterListeners = new ArrayList<ClusterListener>();
    private final List<ServerListener> serverListeners = new ArrayList<ServerListener>();
    private final List<ServerMonitorListener> serverMonitorListeners = new ArrayList<ServerMonitorListener>();

    private int minConnectionsPerHost;
    private int maxConnectionsPerHost = 100;
    private int threadsAllowedToBlockForConnectionMultiplier = 5;
    //設置服務器選擇超時（以毫秒為單位），它定義驅動程序在拋出異常之前等待服務器選擇成功的時間
    //值為0表示如果沒有可用的服務器，它將立即超時。 負值意味著無限期等待
    private int serverSelectionTimeout = 1000 * 30;
    //線程等待連接變為可用的最長時間
    private int maxWaitTime = 1000 * 60 * 2;
    // 線程池中連接的最大空閑時間
    private int maxConnectionIdleTime;
    private int maxConnectionLifeTime;
    //連接超時時間,必須大于0
    private int connectTimeout = 1000 * 10;
    //socket超時時間
    private int socketTimeout = 0;
    //socket是否保活
    private boolean socketKeepAlive = false;
    private boolean sslEnabled = false;
    private boolean sslInvalidHostNameAllowed = false;
    private boolean alwaysUseMBeans = false;
    //設置心跳頻率。 這是驅動程序將嘗試確定群集中每個服務器的當前狀態的頻率。 默認值為10,000毫秒
    private int heartbeatFrequency = 10000;
    //設置最小心跳頻率。 如果驅動程序必須經常重新檢查服務器的可用性，它將至少在上一次檢查后等待很長時間，以避免浪費精力。 默認值為500毫秒。
    private int minHeartbeatFrequency = 500;
    //設置用于集群心跳的連接的連接超時
    private int heartbeatConnectTimeout = 20000;
    //設置用于集群心跳的連接的套接字超時
    private int heartbeatSocketTimeout = 20000;
    //本地閾值
    private int localThreshold = 15;

    private String requiredReplicaSetName;
    private DBDecoderFactory dbDecoderFactory = DefaultDBDecoder.FACTORY;
    private DBEncoderFactory dbEncoderFactory = DefaultDBEncoder.FACTORY;
    private SocketFactory socketFactory;
    private boolean cursorFinalizerEnabled = true;
...}

3. 需要關心的配置

這里就因人而異了, 我這列出比較重要的幾個配置,具體的值看業務場景.

 3.1 讀寫相關

這應該是程序最應該關注的配置了,讀關注,寫關注,讀取偏好.

//讀取偏好, 首先從從節點讀取.
private ReadPreference readPreference = ReadPreference.secondaryPreferred();
//寫關注為1 ,寫入主節點即返回.
private WriteConcern writeConcern = WriteConcern.W1;
//使用服務的默認讀關注,默認是local(決定到某個讀取數據時，能讀到什么樣的數據)
private ReadConcern readConcern = ReadConcern.LOCAL;

3.2 線程池配置

//線程池空閑時保持的最小連接數

minConnectionsPerHost=20

//線程池允許的最大連接數

connectionsPerHost=100

//connectionsPerHost* 5 =最大隊列數

threadsAllowedToBlockForConnectionMultiplier=5

//線程池中連接的最大空閑時間,5分鐘

maxConnectionIdleTime = 5*60*1000

 // 線程池中連接的最長生存時間,采用默認值

maxConnectionLifeTime

3.3 連接配置

//設置服務器選擇超時（以毫秒為單位），它定義驅動程序在拋出異常之前等待服務器選擇成功的時間
//值為0表示如果沒有可用的服務器，它將立即超時。 負值意味著無限期等待
private int serverSelectionTimeout = 1000 * 30;

//連接超時時間,必須大于0
private int connectTimeout = 1000 * 5;

//線程等待連接變為可用的最長時間.

maxWaitTime=6000

看完上述內容，你們對如何在Java中配置mongodb連接有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。