经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 数据库/运维 » MongoDB » 查看文章
mongodb连接配置实践
来源:cnblogs  作者:超超boy  时间:2018/12/7 9:20:40  对本文有异议

之前百度,google了很多,发现并没有介绍mongodb生产环境如何配置的文章, 当时想参考下都不行, 所以写篇文章,大家可以一块讨论下.

1. MongoClientOptions中的连接池配置:

配置如下:

  1. connectionPoolSettings = ConnectionPoolSettings.builder()
  2. .minSize(getMinConnectionsPerHost())
  3. .maxSize(getConnectionsPerHost())
  4. .maxWaitQueueSize(getThreadsAllowedToBlockForConnectionMultiplier()
  5. * getConnectionsPerHost())
  6. .maxWaitTime(getMaxWaitTime(), MILLISECONDS)
  7. .maxConnectionIdleTime(getMaxConnectionIdleTime(), MILLISECONDS)
  8. .maxConnectionLifeTime(getMaxConnectionLifeTime(), MILLISECONDS)
  9. .build();

minSize: 线程池空闲时保持的最小连接数, 默认是0.

maxSize: 线程池允许的最大连接数,默认是100.

maxWaitQueueSize: 线程池等待队列的大小, 默认是500.

maxWaitTime: 线程等待连接变为可用的最长时间.默认为2分钟. 值为0意味着它不会等待. 负值意味着它将无限期地等待

maxConnectionIdleTime: 线程池中连接的最大空闲时间, 0标志Udine空闲时间没有限制,超过这个时间会被关闭.

maxConnectionLifeTime: 线程池中连接的最长生存时间. 0表示没有限制. 超过寿命的会被关闭,必要时通过新连接进行替换.

2. MongoClientOptions初始化

mongodb驱动中 MongoClientOptions 使用Buidler模式配置,有关所有属性的默认值,都是在Builder里边配置的.

关于Builder 的配置如下:

  1. public static class Builder {
  2. private String description;
  3. private String applicationName;
  4. //读取偏好, 这里默认的是从主节点读取.
  5. private ReadPreference readPreference = ReadPreference.primary();
  6. //使用服务器默认的写关注?
  7. private WriteConcern writeConcern = WriteConcern.ACKNOWLEDGED;
  8. //使用服务的默认读关注,默认是local
  9. private ReadConcern readConcern = ReadConcern.DEFAULT;
  10. private CodecRegistry codecRegistry = MongoClient.getDefaultCodecRegistry();
  11. private final List<CommandListener> commandListeners = new ArrayList<CommandListener>();
  12. private final List<ClusterListener> clusterListeners = new ArrayList<ClusterListener>();
  13. private final List<ServerListener> serverListeners = new ArrayList<ServerListener>();
  14. private final List<ServerMonitorListener> serverMonitorListeners = new ArrayList<ServerMonitorListener>();
  15. private int minConnectionsPerHost;
  16. private int maxConnectionsPerHost = 100;
  17. private int threadsAllowedToBlockForConnectionMultiplier = 5;
  18. //设置服务器选择超时(以毫秒为单位),它定义驱动程序在抛出异常之前等待服务器选择成功的时间
  19. //值为0表示如果没有可用的服务器,它将立即超时。 负值意味着无限期等待
  20. private int serverSelectionTimeout = 1000 * 30;
  21. //线程等待连接变为可用的最长时间
  22. private int maxWaitTime = 1000 * 60 * 2;
  23. // 线程池中连接的最大空闲时间
  24. private int maxConnectionIdleTime;
  25. private int maxConnectionLifeTime;
  26. //连接超时时间,必须大于0
  27. private int connectTimeout = 1000 * 10;
  28. //socket超时时间
  29. private int socketTimeout = 0;
  30. //socket是否保活
  31. private boolean socketKeepAlive = false;
  32. private boolean sslEnabled = false;
  33. private boolean sslInvalidHostNameAllowed = false;
  34. private boolean alwaysUseMBeans = false;
  35. //设置心跳频率。 这是驱动程序将尝试确定群集中每个服务器的当前状态的频率。 默认值为10,000毫秒
  36. private int heartbeatFrequency = 10000;
  37. //设置最小心跳频率。 如果驱动程序必须经常重新检查服务器的可用性,它将至少在上一次检查后等待很长时间,以避免浪费精力。 默认值为500毫秒。
  38. private int minHeartbeatFrequency = 500;
  39. //设置用于集群心跳的连接的连接超时
  40. private int heartbeatConnectTimeout = 20000;
  41. //设置用于集群心跳的连接的套接字超时
  42. private int heartbeatSocketTimeout = 20000;
  43. //本地阈值
  44. private int localThreshold = 15;
  45. private String requiredReplicaSetName;
  46. private DBDecoderFactory dbDecoderFactory = DefaultDBDecoder.FACTORY;
  47. private DBEncoderFactory dbEncoderFactory = DefaultDBEncoder.FACTORY;
  48. private SocketFactory socketFactory;
  49. private boolean cursorFinalizerEnabled = true;
  50. ...}

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

 

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号