当前位置:首页 > 数据库 > mongodb连接配置实践

mongodb连接配置实践

2022年09月16日 16:46:50数据库8

之前百度,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

 

作者:超超boy
来源链接:https://www.cnblogs.com/jycboy/p/10077080.html

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/database/42028.html

标签: MongoDB
分享给朋友:

“mongodb连接配置实践” 的相关文章

趣味编程|手写一个集成多数据源mongodb的 starter

趣味编程|手写一个集成多数据源mongodb的 starter

关注公众号“AI码师”领取2021最新面试资料一份,公众号内回复“源码”,获取本项目源码 【前言】 主演:老王(技术总监),小码(本猿) 老王:小码啊,我们项目中需要使用到mongodb,你集成下吧,完成了和我说下。...

springboot集成mongoDB遇到的一些坑

1.当mongoDB设置了账号密码时,且设置的db为admin(角色为root),此时登录且操作都是OK的,连接可视化工具进行各种操作也是ok的,但是springboot项目里面却是一直超时 原因:设置的账号密码是admin数据库的,然后连接的是自己的其他数据库(cloud...

UBUNTU下MONGODB出现PHP Fatal error: Uncaught exception 'MongoConnectionException' with message 和 Authentication failed on database 'admin' with username

MONGO 远程连接服务器,出现: PHP Fatal error: Uncaught exception 'MongoConnectionException' with message 'Failed to connect to: 63.141.xx.xxx:270...

mongodb二进制安装与yum安装

一.什么是mongodb       MongoDB是一个高性能,开源,无模式的文档型数据库,是当前NoSql数据库中比较热门的一种。MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能 最丰富,最像关...

springboot整合mongodb changestream

前言 changestream是monggodb的3.6版本之后出现的一种基于collection(数据库集合)的变更事件流,应用程序通过db.collection.watch()这样的命令可以获得被监听对象的实时变更 想必对mysql主从复...

yum安装MongoDB

yum安装MongoDB

1.配置MongoDB的yum源 创建yum源文件: #cd /etc/yum.repos.d  #vim mongodb-org-4.0.repo  使用阿里云的源 [...

Centos 使用yum安装MongoDB 4.0

Centos 使用yum安装MongoDB 4.0

1.配置MongoDB的yum源 创建yum源文件: #cd /etc/yum.repos.d  #vim mongodb-org-4.0.repo  添加以下内容:(我们这里使用阿里云的源) [mngodb-org] nam...

Navicat for MongoDB 破解

Navicat for MongoDB 破解

Navicat for MongoDB是一款功能强大,直观的,易于使用MongoDB管理和开发的终极解决方案。Navicat for MongoDB为您提供了一个高度可用的GUI,以简化您的日常数据库任务。我们精心设...

mongodb与mysql命令对比

mongodb与mysql命令对比 传统的关系数据库一般由数据库(database)、表(table)、记录(record)三个层次概念组成,MongoDB是由数据库(database)、集合(collection)、文档对象(document)三个层次组成。MongoDB对于关...

Centos7下yum安装mongodb

  简介 MongoDB 是一个基于分布式 文件存储的NoSQL数据库 由C++语言编写,运行稳定,性能高 旨在为 WEB 应用提供可扩展的高性能数据存储解决方案 查看官方网站 MongoDB特点...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。