之前百度,google了很多,发现并没有介绍mongodb生产环境如何配置的文章, 当时想参考下都不行, 所以写篇文章,大家可以一块讨论下.
1. mongoclientoptions中的连接池配置:
配置如下:
1
2
3
4
5
6
7
8
9
|
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 的配置如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
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 读写相关
这应该是程序最应该关注的配置了,读关注,写关注,读取偏好.
1
2
3
4
5
6
|
//读取偏好, 首先从从节点读取. private readpreference readpreference = readpreference.secondarypreferred(); //写关注为1 ,写入主节点即返回. private writeconcern writeconcern = writeconcern.w1; //使用服务的默认读关注,默认是local(决定到某个读取数据时,能读到什么样的数据) private readconcern readconcern = readconcern.local; |
3.2 线程池配置
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
//线程池空闲时保持的最小连接数 minconnectionsperhost= 20 //线程池允许的最大连接数 connectionsperhost= 100 //connectionsperhost* 5 =最大队列数 threadsallowedtoblockforconnectionmultiplier= 5 //线程池中连接的最大空闲时间,5分钟 maxconnectionidletime = 5 * 60 * 1000 // 线程池中连接的最长生存时间,采用默认值 maxconnectionlifetime |
3.3 连接配置
1
2
3
4
5
6
7
8
9
10
|
//设置服务器选择超时(以毫秒为单位),它定义驱动程序在抛出异常之前等待服务器选择成功的时间 //值为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