最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java mongodb連接配置實(shí)踐

 更新時(shí)間:2018年12月07日 09:20:31   作者:超超boy  
這篇文章主要介紹了Java mongodb連接配置實(shí)踐,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧

之前百度,google了很多,發(fā)現(xiàn)并沒(méi)有介紹mongodb生產(chǎn)環(huán)境如何配置的文章, 當(dāng)時(shí)想?yún)⒖枷露疾恍? 所以寫(xiě)篇文章,大家可以一塊討論下.

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ù)值意味著它將無(wú)限期地等待

maxConnectionIdleTime: 線程池中連接的最大空閑時(shí)間, 0標(biāo)志Udine空閑時(shí)間沒(méi)有限制,超過(guò)這個(gè)時(shí)間會(huì)被關(guān)閉.

maxConnectionLifeTime: 線程池中連接的最長(zhǎng)生存時(shí)間. 0表示沒(méi)有限制. 超過(guò)壽命的會(huì)被關(guān)閉,必要時(shí)通過(guò)新連接進(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)的寫(xiě)關(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表示如果沒(méi)有可用的服務(wù)器,它將立即超時(shí)。 負(fù)值意味著無(wú)限期等待
    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 讀寫(xiě)相關(guān)

這應(yīng)該是程序最應(yīng)該關(guān)注的配置了,讀關(guān)注,寫(xiě)關(guān)注,讀取偏好.

//讀取偏好, 首先從從節(jié)點(diǎn)讀取.
private ReadPreference readPreference = ReadPreference.secondaryPreferred();
//寫(xiě)關(guān)注為1 ,寫(xiě)入主節(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表示如果沒(méi)有可用的服務(wù)器,它將立即超時(shí)。 負(fù)值意味著無(wú)限期等待
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ù)來(lái)..

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

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論

新化县| 江西省| 垦利县| 正阳县| 鹤山市| 清涧县| 瑞安市| 开鲁县| 桑日县| 顺昌县| 册亨县| 佳木斯市| 梧州市| 乐平市| 顺平县| 白朗县| 漳浦县| 云林县| 诸暨市| 蒙自县| 朝阳市| 神池县| 峡江县| 兴安县| 大田县| 长沙市| 阿拉善右旗| 杂多县| 庆云县| 临潭县| 蓬莱市| 新田县| 仲巴县| 麻栗坡县| 孝义市| 松原市| 喀喇沁旗| 崇礼县| 偏关县| 隆化县| 岢岚县|