Java mongodb連接配置實(shí)踐
之前百度,google了很多,發(fā)現(xiàn)并沒有介紹mongodb生產(chǎn)環(huán)境如何配置的文章, 當(dāng)時想?yún)⒖枷露疾恍? 所以寫篇文章,大家可以一塊討論下.
1. MongoClientOptions中的連接池配置:
配置如下:
connectionPoolSettings = ConnectionPoolSettings.builder() .minSize(getMinConnectionsPerHost()) .maxSize(getConnectionsPerHost()) .maxWaitQueueSize(getThreadsAllowedToBlockForConnectionMultiplier() * getConnectionsPerHost()) .maxWaitTime(getMaxWaitTime(), MILLISECONDS) .maxConnectionIdleTime(getMaxConnectionIdleTime(), MILLISECONDS) .maxConnectionLifeTime(getMaxConnectionLifeTime(), MILLISECONDS) .build();
minSize: 線程池空閑時保持的最小連接數(shù), 默認(rèn)是0.
maxSize: 線程池允許的最大連接數(shù),默認(rèn)是100.
maxWaitQueueSize: 線程池等待隊(duì)列的大小, 默認(rèn)是500.
maxWaitTime: 線程等待連接變?yōu)榭捎玫淖铋L時間.默認(rèn)為2分鐘. 值為0意味著它不會等待. 負(fù)值意味著它將無限期地等待
maxConnectionIdleTime: 線程池中連接的最大空閑時間, 0標(biāo)志Udine空閑時間沒有限制,超過這個時間會被關(guān)閉.
maxConnectionLifeTime: 線程池中連接的最長生存時間. 0表示沒有限制. 超過壽命的會被關(guān)閉,必要時通過新連接進(jìn)行替換.
2. MongoClientOptions初始化
mongodb驅(qū)動中 MongoClientOptions 使用Buidler模式配置,有關(guān)所有屬性的默認(rèn)值,都是在Builder里邊配置的.
關(guān)于Builder 的配置如下:
public static class Builder { private String description; private String applicationName; //讀取偏好, 這里默認(rèn)的是從主節(jié)點(diǎn)讀取. private ReadPreference readPreference = ReadPreference.primary(); //使用服務(wù)器默認(rèn)的寫關(guān)注? private WriteConcern writeConcern = WriteConcern.ACKNOWLEDGED; //使用服務(wù)的默認(rèn)讀關(guān)注,默認(rèn)是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; //設(shè)置服務(wù)器選擇超時(以毫秒為單位),它定義驅(qū)動程序在拋出異常之前等待服務(wù)器選擇成功的時間 //值為0表示如果沒有可用的服務(wù)器,它將立即超時。 負(fù)值意味著無限期等待 private int serverSelectionTimeout = 1000 * 30; //線程等待連接變?yōu)榭捎玫淖铋L時間 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; //設(shè)置心跳頻率。 這是驅(qū)動程序?qū)L試確定群集中每個服務(wù)器的當(dāng)前狀態(tài)的頻率。 默認(rèn)值為10,000毫秒 private int heartbeatFrequency = 10000; //設(shè)置最小心跳頻率。 如果驅(qū)動程序必須經(jīng)常重新檢查服務(wù)器的可用性,它將至少在上一次檢查后等待很長時間,以避免浪費(fèi)精力。 默認(rèn)值為500毫秒。 private int minHeartbeatFrequency = 500; //設(shè)置用于集群心跳的連接的連接超時 private int heartbeatConnectTimeout = 20000; //設(shè)置用于集群心跳的連接的套接字超時 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. 需要關(guān)心的配置
這里就因人而異了, 我這列出比較重要的幾個配置,具體的值看業(yè)務(wù)場景.
3.1 讀寫相關(guān)
這應(yīng)該是程序最應(yīng)該關(guān)注的配置了,讀關(guān)注,寫關(guān)注,讀取偏好.
//讀取偏好, 首先從從節(jié)點(diǎn)讀取. private ReadPreference readPreference = ReadPreference.secondaryPreferred(); //寫關(guān)注為1 ,寫入主節(jié)點(diǎn)即返回. private WriteConcern writeConcern = WriteConcern.W1; //使用服務(wù)的默認(rèn)讀關(guān)注,默認(rèn)是local(決定到某個讀取數(shù)據(jù)時,能讀到什么樣的數(shù)據(jù)) private ReadConcern readConcern = ReadConcern.LOCAL;
3.2 線程池配置
//線程池空閑時保持的最小連接數(shù) minConnectionsPerHost=20 //線程池允許的最大連接數(shù) connectionsPerHost=100 //connectionsPerHost* 5 =最大隊(duì)列數(shù) threadsAllowedToBlockForConnectionMultiplier=5 //線程池中連接的最大空閑時間,5分鐘 maxConnectionIdleTime = 5*60*1000 // 線程池中連接的最長生存時間,采用默認(rèn)值 maxConnectionLifeTime
3.3 連接配置
//設(shè)置服務(wù)器選擇超時(以毫秒為單位),它定義驅(qū)動程序在拋出異常之前等待服務(wù)器選擇成功的時間 //值為0表示如果沒有可用的服務(wù)器,它將立即超時。 負(fù)值意味著無限期等待 private int serverSelectionTimeout = 1000 * 30; //連接超時時間,必須大于0 private int connectTimeout = 1000 * 5; //線程等待連接變?yōu)榭捎玫淖铋L時間. maxWaitTime=6000
這里建議 這兩個參數(shù): maxWaitTime,connectTimeout,根據(jù)公司具體的業(yè)務(wù)來..
這是目前我在公司的配置參數(shù), 借鑒了其他的連接池配置比如: redis和mysql的,并不是最優(yōu)的,還在摸索實(shí)踐....
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
使用迭代器模式來進(jìn)行Java的設(shè)計(jì)模式編程
這篇文章主要介紹了使用迭代器模式來進(jìn)行Java的設(shè)計(jì)模式編程,文中對迭代器模式中的容器封裝方面的知識進(jìn)行了講解,需要的朋友可以參考下2016-02-02IDEA中編寫并運(yùn)行shell腳本的實(shí)現(xiàn)
這篇文章主要介紹了IDEA中編寫并運(yùn)行shell腳本的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08Springboot使用RestTemplate調(diào)用第三方接口的操作代碼
這篇文章主要介紹了Springboot使用RestTemplate調(diào)用第三方接口,我只演示了最常使用的請求方式get、post的簡單使用方法,當(dāng)然RestTemplate的功能還有很多,感興趣的朋友可以參考RestTemplate源碼2022-12-12Springboot jdbctemplate整合實(shí)現(xiàn)步驟解析
這篇文章主要介紹了Springboot jdbctemplate整合實(shí)現(xiàn)步驟解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-08-08Java?SpringBoot整合shiro-spring-boot-starterqi項(xiàng)目報錯解決
這篇文章主要介紹了Java?SpringBoot整合shiro-spring-boot-starterqi項(xiàng)目報錯解決,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考一下2022-08-08詳解IntelliJ IDEA創(chuàng)建spark項(xiàng)目的兩種方式
這篇文章主要介紹了詳解IntelliJ IDEA創(chuàng)建spark項(xiàng)目的兩種方式,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2019-01-01Java實(shí)現(xiàn)餐廳點(diǎn)餐系統(tǒng)的實(shí)例代碼
這篇文章主要介紹了Java實(shí)現(xiàn)餐廳點(diǎn)餐系統(tǒng),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-06-06mybatis攔截器實(shí)現(xiàn)數(shù)據(jù)權(quán)限項(xiàng)目實(shí)踐
本文主要介紹了mybatis攔截器實(shí)現(xiàn)數(shù)據(jù)權(quán)限項(xiàng)目實(shí)踐,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06