mongoDB的读写分离
一、ReadPreference读偏好
在副本集Replica Set中才涉及到ReadPreference的设置，默认情况下，读写都是分发都Primary节点执行，但是对于写少读多的情况，我们希望进行读写分离来分摊压力，所以希望使用Secondary节点来进行读取，Primary只承担写的责任（实际上写只能分发到Primary节点，不可修改）。
MongoDB有5种ReadPreference模式：
primary： 主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。
primaryPreferred：首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。
secondary：从节点，读操作只在从节点， 如果从节点不可用，报错或者抛出异常。
secondaryPreferred：首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。
nearest：最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点。
Spring中的设置ReadPreference：
<!-- 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>二、springboot中配置读写分离
再重申下在副本集Replica Set中才涉及到ReadPreference的设置才有意义。
请仔细看好 spring.data.mongodb.uri 的配置，他的格式如下，可以参考mongodb连接：
mongodb://[username:]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
例子：
# MongoDB URI配置 重要，添加了用户名和密码验证 spring.data.mongodb.uri=mongodb://zhuyu::27017,192.168.68.137:27017,192.168.68.139:27017/ai?slaveOk=true&replicaSet=zypcy&write=1&readPreference=secondaryPreferred&connectTimeoutMS=300000 #每个主机的连接数 spring.data.mongodb.connections-per-host=50 #线程队列数，它以上面connectionsPerHost值相乘的结果就是线程队列最大值 spring.data.mongodb.threads-allowed-to-block-for-connection-multiplier=50 spring.data.mongodb.connect-timeout=5000 spring.data.mongodb.socket-timeout=3000 spring.data.mongodb.max-wait-time=1500 #控制是否在一个连接时，系统会自动重试 spring.data.mongodb.auto-connect-retry=true spring.data.mongodb.socket-keep-alive=true
验证读写分离是否生效：
创建一个 Rest风格的 IndexController ，提供：添加与查询接口，访问这2个接口，看控制台输出，是否查操作自动分配到从库，写操作分配到主库
@RequestMapping("/index")
@RestController
public class IndexController {
@Autowired private MongoTemplate mongoTemplate;
@RequestMapping("/getList")
public List<TestModel> getList(){
List<TestModel> list = mongoTemplate.findAll(TestModel.class,"test");
return list;
}
@RequestMapping("/add")
public String add(){
TestModel model = new TestModel("zhuyu" + System.currentTimeMillis());
mongoTemplate.insert(model , "test");
return "success";
}
}转自：https://blog.csdn.net/zhuyu19911016520/article/details/82998162?depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromBaidu-3&utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromBaidu-3