Java mongodb連接配置實(shí)踐
之前百度,google了很多,發(fā)現(xiàn)并沒有介紹mongodb生產(chǎn)環(huán)境如何配置的文章, 當(dāng)時(shí)想?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í)保持的最小連接數(shù), 默認(rèn)是0.
maxSize: 線程池允許的最大連接數(shù),默認(rèn)是100.
maxWaitQueueSize: 線程池等待隊(duì)列的大小, 默認(rèn)是500.
maxWaitTime: 線程等待連接變?yōu)榭捎玫淖铋L(zhǎng)時(shí)間.默認(rèn)為2分鐘. 值為0意味著它不會(huì)等待. 負(fù)值意味著它將無限期地等待
maxConnectionIdleTime: 線程池中連接的最大空閑時(shí)間, 0標(biāo)志Udine空閑時(shí)間沒有限制,超過這個(gè)時(shí)間會(huì)被關(guān)閉.
maxConnectionLifeTime: 線程池中連接的最長(zhǎng)生存時(shí)間. 0表示沒有限制. 超過壽命的會(huì)被關(guān)閉,必要時(shí)通過新連接進(jìn)行替換.
2. MongoClientOptions初始化
mongodb驅(qū)動(dòng)中 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ù)器選擇超時(shí)(以毫秒為單位),它定義驅(qū)動(dòng)程序在拋出異常之前等待服務(wù)器選擇成功的時(shí)間
//值為0表示如果沒有可用的服務(wù)器,它將立即超時(shí)。 負(fù)值意味著無限期等待
private int serverSelectionTimeout = 1000 * 30;
//線程等待連接變?yōu)榭捎玫淖铋L(zhǎng)時(shí)間
private int maxWaitTime = 1000 * 60 * 2;
// 線程池中連接的最大空閑時(shí)間
private int maxConnectionIdleTime;
private int maxConnectionLifeTime;
//連接超時(shí)時(shí)間,必須大于0
private int connectTimeout = 1000 * 10;
//socket超時(shí)時(shí)間
private int socketTimeout = 0;
//socket是否?;?
private boolean socketKeepAlive = false;
private boolean sslEnabled = false;
private boolean sslInvalidHostNameAllowed = false;
private boolean alwaysUseMBeans = false;
//設(shè)置心跳頻率。 這是驅(qū)動(dòng)程序?qū)L試確定群集中每個(gè)服務(wù)器的當(dāng)前狀態(tài)的頻率。 默認(rèn)值為10,000毫秒
private int heartbeatFrequency = 10000;
//設(shè)置最小心跳頻率。 如果驅(qū)動(dòng)程序必須經(jīng)常重新檢查服務(wù)器的可用性,它將至少在上一次檢查后等待很長(zhǎng)時(shí)間,以避免浪費(fèi)精力。 默認(rèn)值為500毫秒。
private int minHeartbeatFrequency = 500;
//設(shè)置用于集群心跳的連接的連接超時(shí)
private int heartbeatConnectTimeout = 20000;
//設(shè)置用于集群心跳的連接的套接字超時(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)心的配置
這里就因人而異了, 我這列出比較重要的幾個(gè)配置,具體的值看業(yè)務(wù)場(chǎng)景.
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(決定到某個(gè)讀取數(shù)據(jù)時(shí),能讀到什么樣的數(shù)據(jù)) private ReadConcern readConcern = ReadConcern.LOCAL;
3.2 線程池配置
//線程池空閑時(shí)保持的最小連接數(shù) minConnectionsPerHost=20 //線程池允許的最大連接數(shù) connectionsPerHost=100 //connectionsPerHost* 5 =最大隊(duì)列數(shù) threadsAllowedToBlockForConnectionMultiplier=5 //線程池中連接的最大空閑時(shí)間,5分鐘 maxConnectionIdleTime = 5*60*1000 // 線程池中連接的最長(zhǎng)生存時(shí)間,采用默認(rèn)值 maxConnectionLifeTime
3.3 連接配置
//設(shè)置服務(wù)器選擇超時(shí)(以毫秒為單位),它定義驅(qū)動(dòng)程序在拋出異常之前等待服務(wù)器選擇成功的時(shí)間 //值為0表示如果沒有可用的服務(wù)器,它將立即超時(shí)。 負(fù)值意味著無限期等待 private int serverSelectionTimeout = 1000 * 30; //連接超時(shí)時(shí)間,必須大于0 private int connectTimeout = 1000 * 5; //線程等待連接變?yōu)榭捎玫淖铋L(zhǎng)時(shí)間. maxWaitTime=6000
這里建議 這兩個(gè)參數(shù): maxWaitTime,connectTimeout,根據(jù)公司具體的業(yè)務(wù)來..
這是目前我在公司的配置參數(shù), 借鑒了其他的連接池配置比如: redis和mysql的,并不是最優(yōu)的,還在摸索實(shí)踐....
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
在Spring Boot中處理文件上傳功能實(shí)現(xiàn)
這篇文章主要介紹了如何在Spring Boot中處理文件上傳,通過配置文件上傳屬性、創(chuàng)建控制器來處理上傳的文件,并通過異常處理器來管理錯(cuò)誤情況,可以快速實(shí)現(xiàn)文件上傳功能,需要的朋友可以參考下2024-06-06
spring cloud gateway 限流的實(shí)現(xiàn)與原理
這篇文章主要介紹了spring cloud gateway 限流的實(shí)現(xiàn)與原理,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-12-12
Java中synchronized關(guān)鍵字修飾方法同步的用法詳解
synchronized可以用來同步靜態(tài)和非靜態(tài)方法,下面就具體來看一下Java中synchronized關(guān)鍵字修飾方法同步的用法詳解:2016-06-06
java開發(fā)gui教程之jframe監(jiān)聽窗體大小變化事件和jframe創(chuàng)建窗體
這篇文章主要介紹了java開發(fā)gui教程中jframe監(jiān)聽窗體大小變化事件和jframe創(chuàng)建窗體的示例,需要的朋友可以參考下2014-03-03
struts2實(shí)現(xiàn)簡(jiǎn)單文件下載功能
這篇文章主要為大家詳細(xì)介紹了struts2實(shí)現(xiàn)簡(jiǎn)單文件下載功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-01-01
java增強(qiáng)for循環(huán)的實(shí)現(xiàn)方法
下面小編就為大家?guī)硪黄猨ava增強(qiáng)for循環(huán)的實(shí)現(xiàn)方法。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2016-09-09
Spring的連接數(shù)據(jù)庫(kù)以及JDBC模板(實(shí)例講解)
下面小編就為大家?guī)硪黄猄pring的連接數(shù)據(jù)庫(kù)以及JDBC模板(實(shí)例講解)。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-10-10
Java利用for循環(huán)輸出空心菱形的實(shí)例代碼
這篇文章主要介紹了Java利用for循環(huán)輸出空心菱形的實(shí)例代碼,需要的朋友可以參考下2014-02-02
使用Java DOM解析器修改XML文件內(nèi)容的操作方法
在Java中,XML文件的解析和修改可以通過多種方法實(shí)現(xiàn),其中DOM(Document Object Model)是一種常用的方式,在本文中,我們將介紹如何使用Java DOM解析器修改XML文件中的內(nèi)容,并給出一個(gè)具體的示例,需要的朋友可以參考下2024-08-08

