Java mongodb连接配置实践

connectionpoolsettings = connectionpoolsettings.builder()

                             .minsize(getminconnectionsperhost())

                             .maxsize(getconnectionsperhost())

                             .maxwaitqueuesize(getthreadsallowedtoblockforconnectionmultiplier()

                                      * getconnectionsperhost())

                             .maxwaittime(getmaxwaittime(), milliseconds)

                             .maxconnectionidletime(getmaxconnectionidletime(), milliseconds)

                             .maxconnectionlifetime(getmaxconnectionlifetime(), milliseconds)

                             .build();

   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 ;

...}

//读取偏好, 首先从从节点读取.

private readpreference readpreference = readpreference.secondarypreferred();

//写关注为1 ,写入主节点即返回.

private writeconcern writeconcern = writeconcern.w1;

//使用服务的默认读关注,默认是local(决定到某个读取数据时，能读到什么样的数据)

private readconcern readconcern = readconcern.local;

//线程池空闲时保持的最小连接数

minconnectionsperhost= 20

//线程池允许的最大连接数

connectionsperhost= 100

//connectionsperhost* 5 =最大队列数

threadsallowedtoblockforconnectionmultiplier= 5

//线程池中连接的最大空闲时间,5分钟

maxconnectionidletime = 5 * 60 * 1000

  // 线程池中连接的最长生存时间,采用默认值

maxconnectionlifetime

//设置服务器选择超时（以毫秒为单位），它定义驱动程序在抛出异常之前等待服务器选择成功的时间

//值为0表示如果没有可用的服务器，它将立即超时。 负值意味着无限期等待

private int serverselectiontimeout = 1000 * 30 ;

//连接超时时间,必须大于0

private int connecttimeout = 1000 * 5 ;

//线程等待连接变为可用的最长时间.

maxwaittime= 6000