mongodb連接配置實踐

来源:https://www.cnblogs.com/jycboy/archive/2018/12/06/10077080.html
-Advertisement-
Play Games

之前百度,google了很多,發現並沒有介紹mongodb生產環境如何配置的文章, 當時想參考下都不行, 所以寫篇文章,大家可以一塊討論下. 1. MongoClientOptions中的連接池配置: 配置如下: minSize: 線程池空閑時保持的最小連接數, 預設是0. maxSize: 線程池 ...


之前百度,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的,並不是最優的,還在摸索實踐....

轉發註明出處: https://www.cnblogs.com/jycboy/p/10077080.html

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Linux系統中的wc(Word Count)命令的功能為統計指定文件中的位元組數、字數、行數,並將統計結果顯示輸出。 一.命令格式 wc [ clw][ help][ version][文件...] 二.命令功能 利用wc指令我們可以計算文件的Byte數、字數、或是列數,若不指定文件名稱、或是所給予 ...
  • 截至寫這篇博客為止,MariaDB官方的穩定版本為,詳情訪問官方地址:https://downloads.mariadb.org/ 安裝之前先簡單說一下MariaDB: MariaDB由MySQL的創始人麥克爾·維德紐斯主導開發,他早前曾以10億美元的價格,將自己創建的公司MySQL賣給了SUN,此 ...
  • 個人原創,轉載請在文章頭部明顯位置註明出處:https://www.cnblogs.com/sunshine5683/p/10080102.html 在上一篇進階中大概講解了一些關於進階方面的知識,今天就將進階內容做個總結! 一、OracleServer實例DB的概念: 1、Oracle關係資料庫管 ...
  • 1. 下載版本,官網:https://dev.mysql.com/downloads/mysql/ 2. 解壓 3. mysql-5.7.24-winx64目錄下創建一個名為data的空文件夾、創建一個my.ini的文件放在bin目錄裡面(不要放在mysql文件夾下),內容: [mysql] # 設 ...
  • 今天主要介紹一下如何將 Spark dataframe 的數據轉成 json 數據。用到的是 scala 提供的 json 處理的 api。 用過 Spark SQL 應該知道,Spark dataframe 本身有提供一個 api 可以供我們將數據轉成一個 JsonArray,我們可以在 spar ...
  • 一. 準備工作 1 刪除本地centos7中的mariadb: 查看系統中是否已安裝 mariadb 服務: rpm -qa | grep mariadb 或 yum list installed | grep mariadb 如果已安裝則刪除 mariadb及其依賴的包: yum -y remov ...
  • Database Design(資料庫設計)(視頻下載) (全部書籍) 馬克-to-win: (一對多:one-to-many) 1) teacher and student. (teacher表:兩列id(主鍵),name。pupil表: 三列:id(主鍵),name,tid(外鍵)) 舉例: T ...
  • 表A中id與表B中aid為一對多的關係 例如: 表A: 表B: 使用for xml path('') 和stuff合併顯示多行數據到一行中 : 第一種,不使用stuff,結果如下: 結果: 第二種,使用stuff將最後的逗號去掉 結果: ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...