国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > Java > 正文

Java mongodb連接配置實踐

2024-07-14 08:43:02
字體:
來源:轉載
供稿:網友

之前百度,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;//連接超時時間,必須大于0private int connectTimeout = 1000 * 5;//線程等待連接變為可用的最長時間.maxWaitTime=6000

這里建議 這兩個參數: maxWaitTime,connectTimeout,根據公司具體的業務來..

這是目前我在公司的配置參數, 借鑒了其他的連接池配置比如: redis和mysql的,并不是最優的,還在摸索實踐....

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VeVb武林網。


注:相關教程知識閱讀請移步到JAVA教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 浮山县| 拉萨市| 濮阳县| 茌平县| 鹤山市| 长丰县| 灵台县| 永春县| 伊宁市| 长白| 富宁县| 灵石县| 容城县| 凤山县| 郧西县| 吴川市| 莎车县| 鲁甸县| 凌源市| 蓝田县| 宣城市| 刚察县| 抚远县| 仁怀市| 外汇| 通化县| 登封市| 乌鲁木齐县| 那曲县| 喀喇| 工布江达县| 波密县| 德兴市| 汪清县| 简阳市| 光山县| 宾阳县| 合水县| 靖西县| 马关县| 南雄市|