MongoDB随记

<!-- mongodb配置 --> <mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}" write-concern="NORMAL" > <mongo:options connections-per-host="${mongo.connectionsPerHost}" threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}" connect-timeout="${mongo.connectTimeout}" max-wait-time="${mongo.maxWaitTime}" auto-connect-retry="${mongo.autoConnectRetry}" socket-keep-alive="${mongo.socketKeepAlive}" socket-timeout="${mongo.socketTimeout}" slave-ok="${mongo.slaveOk}" write-number="1" write-timeout="0" write-fsync="false" /> </mongo:mongo>  <!-- mongo的工厂，通过它来取得mongo实例,dbname为mongodb的数据库名，没有的话会自动创建 --> <mongo:db-factory id="mongoDbFactory" dbname="uba" mongo-ref="mongo" />  <!-- 读写分离级别配置  --> <!-- 首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。 --> <bean id="primaryPreferredReadPreference" class="com.mongodb.TaggableReadPreference.PrimaryPreferredReadPreference" />  <!-- 最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点。  --> <bean id="nearestReadPreference" class="com.mongodb.TaggableReadPreference.NearestReadPreference" />  <!-- 从节点，读操作只在从节点， 如果从节点不可用，报错或者抛出异常。存在的问题是secondary节点的数据会比primary节点数据旧。  --> <bean id="secondaryReadPreference" class="com.mongodb.TaggableReadPreference.SecondaryReadPreference" />  <!-- 优先从secondary节点进行读取操作，secondary节点不可用时从主节点读取数据  --> <bean id="secondaryPreferredReadPreference" class="com.mongodb.TaggableReadPreference.SecondaryPreferredReadPreference" />  <!-- mongodb的主要操作对象，所有对mongodb的增删改查的操作都是通过它完成 --> <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate"> <constructor-arg name="mongoDbFactory" ref="mongoDbFactory" /> <property name="readPreference" ref="primaryPreferredReadPreference" /> </bean>

1. public class MongoClientOption {  
2.     private String description;  
3.     private ReadPreference readPreference = ReadPreference.primary();//读写分离  
4.     private WriteConcern writeConcern = WriteConcern.ACKNOWLEDGED;//write concern 来让用户自己衡量性能和写安全 Acknowledged 中等级别，能够拿到mongodb返回的信息。默认是这个设置  
5.     private CodecRegistry codecRegistry = MongoClient.getDefaultCodecRegistry();  
6.     private int minConnectionsPerHost;  
7.     private int maxConnectionsPerHost = 100; //最大的连接数  
8.     private int threadsAllowedToBlockForConnectionMultiplier = 5;//线程队列数，它以上面connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出“Out of semaphores to get db”错误。  
9.     private int serverSelectionTimeout = 1000 * 30;  
10.     private int maxWaitTime = 1000 * 60 * 2;//最大等待连接的线程阻塞时间2分钟  
11.     private int maxConnectionIdleTime;  
12.     private int maxConnectionLifeTime;//最大连接存活数  
13.     private int connectTimeout = 1000 * 10;//连接超时的毫秒。0是默认和无限  
14.     private int socketTimeout = 0;//socket超时。0是默认和无限  
15.     private boolean socketKeepAlive = false;  
16.     private boolean sslEnabled = false;  
17.     private boolean sslInvalidHostNameAllowed = false;  
18.     private boolean alwaysUseMBeans = false;  
19.     private int heartbeatFrequency = 10000;  
20.     private int minHeartbeatFrequency = 500;  
21.     private int heartbeatConnectTimeout = 20000;  
22.     private int heartbeatSocketTimeout = 20000;  
23.     private int localThreshold = 15;  
24.     private boolean autoConnectRetry = true;//是否自动连接  
25.     private String requiredReplicaSetName;  
26.     private DBDecoderFactory dbDecoderFactory = DefaultDBDecoder.FACTORY;//Mongo Java驱动程序配置  
27.     private DBEncoderFactory dbEncoderFactory = DefaultDBEncoder.FACTORY;//mongo java 编码工厂  
28.     private SocketFactory socketFactory = SocketFactory.getDefault();//socket 工厂  
29.     private boolean cursorFinalizerEnabled = true;