mongodb鏈接配置實踐

時間 2019-11-06

原文原文鏈接

以前百度,google了不少,發現並無介紹mongodb生產環境如何配置的文章, 當時想參考下都不行, 因此寫篇文章,你們能夠一塊討論下.html

1. MongoClientOptions中的鏈接池配置:

配置以下:mysql

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

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

maxSize: 線程池容許的最大鏈接數,默認是100.sql

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

maxWaitTime: 線程等待鏈接變爲可用的最長時間.默認爲2分鐘. 值爲0意味着它不會等待. 負值意味着它將無限期地等待服務器

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

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

2. MongoClientOptions初始化

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

關於Builder 的配置以下:google

    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;