springboot中怎么配置读写分离-php教程-PHP中文网

springboot中配置读写分离的方法：首先配置“spring.data.mongodb.uri”；然后创建一个Rest风格的“IndexController”；最后验证读写分离是否生效即可。

springboot中怎么配置读写分离

mongoDB的读写分离

一、ReadPreference读偏好

在副本集Replica Set中才涉及到ReadPreference的设置，默认情况下，读写都是分发都Primary节点执行，但是对于写少读多的情况，我们希望进行读写分离来分摊压力，所以希望使用Secondary节点来进行读取，Primary只承担写的责任（实际上写只能分发到Primary节点，不可修改）。

MongoDB有5种ReadPreference模式：

primary：主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。

primaryPreferred：首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。

secondary：从节点，读操作只在从节点，如果从节点不可用，报错或者抛出异常。

secondaryPreferred：首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。

nearest：最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点。

Spring中的设置ReadPreference：

Figma Slides

Figma Slides 是 Figma 发布的PPT制作和演示文稿生成工具，可以帮助创建、设计、定制和分享演示文稿

下载

二、springboot中配置读写分离

再重申下在副本集Replica Set中才涉及到ReadPreference的设置才有意义。

请仔细看好 spring.data.mongodb.uri 的配置，他的格式如下，可以参考mongodb连接：

mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]

例子：

# MongoDB URI配置 重要，添加了用户名和密码验证
spring.data.mongodb.uri=mongodb://zhuyu:zhuyu@192.168.68.138: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 getList(){
        List 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";
    }
}

更多相关技术知识，请访问PHP中文网！