mongodb連線配置實踐
之前百度,google了很多,發現並沒有介紹mongodb生產環境如何配置的文章, 當時想參考下都不行, 所以寫篇文章,大家可以一塊討論下.
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
這裡建議 這兩個引數: maxWaitTime,connectTimeout,根據公司具體的業務來..
這是目前我在公司的配置引數, 借鑑了其他的連線池配置比如: redis和mysql的,並不是最優的,還在摸索實踐....