189 8069 5689
今天就跟大家聊聊有关如何在Java中配置MongoDB连接，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。
目前创新互联已为1000+的企业提供了网站建设、域名、网页空间、网站托管、服务器托管、企业网站设计、安塞网站维护等服务，公司将坚持客户导向、应用为本的策略，正道将秉承"和谐、参与、激情"的文化，与客户和合作伙伴齐心协力一起成长，共同发展。
Java的特点有哪些 1.Java语言作为静态面向对象编程语言的代表，实现了面向对象理论，允许程序员以优雅的思维方式进行复杂的编程。 2.Java具有简单性、面向对象、分布式、安全性、平台独立与可移植性、动态性等特点。 3.使用Java可以编写桌面应用程序、Web应用程序、分布式系统和嵌入式系统应用程序等。
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 commandListeners = new ArrayList();
private final List clusterListeners = new ArrayList();
private final List serverListeners = new ArrayList();
private final List serverMonitorListeners = new ArrayList();
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
看完上述内容，你们对如何在Java中配置mongodb连接有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注创新互联行业资讯频道，感谢大家的支持。