mongodb连接配置实践

之前百度,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的,并不是最优的,还在摸索实践....

转发注明出处: