MongoDB读写分离

以你之姓@ 2023-02-14 01:34 7阅读 0赞

#### 背景 ####

最近项目数据量越来越大，导致mongo的数据库压力也越来越大。在结构优化、索引优化之后，为了进一步优化系统，想到读写分离。

#### java端配置读写分离 ####

这里，mongo采用的是副本集（Replica Set）的部署方式  
这里采用的事xml配置文件形式:  
read-preference=“SECONDARY\_PREFERRED”，这个配置。

<mongo:mongo-client id="mongo" replica-set="${mongo.replicationSet}">
    		<mongo:client-options
    				write-concern="NORMAL"
    				connections-per-host="${mongo.connectionsPerHost}"
    				threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
    				connect-timeout="${mongo.connectTimeout}"
    				read-preference="SECONDARY_PREFERRED"
    				max-wait-time="${mongo.maxWaitTime}"
    				socket-keep-alive="${mongo.socketKeepAlive}"
    				socket-timeout="${mongo.socketTimeout}"
    		/>
    	</mongo:mongo-client>

**支持五种 read preference模式：**  
1.primary：主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。  
2.primaryPreferred：首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。  
3.secondary：从节点，读操作只在从节点，如果从节点不可用，报错或者抛出异常。  
4.secondaryPreferred：首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。  
5.nearest：最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点，关于最邻近的成员请参考。

**配置host的时候尽量把主节点和副节点都配置上，如果发生主被切换能保证项目正常运行。**  
java使用Jongo的配置

List<ServerAddress> list = new ArrayList<>();
     ServerAddress serverAddress = new ServerAddress(host, port);
     list.add(serverAddress);
    serverAddress = new ServerAddress(host, port);
      list.add(serverAddress);
            MongoCredential credential = MongoCredential.createCredential(userName, database, pwd.toCharArray());
            MongoClientOptions.Builder build = new MongoClientOptions.Builder();
            build.minConnectionsPerHost(10);
            build.connectionsPerHost(300);   //与目标数据库能够建立的最大connection数量为50
            build.threadsAllowedToBlockForConnectionMultiplier(500); //如果
            build.maxWaitTime(1000*60*2);
            build.connectTimeout(1000*60*1);    //与数据库建立连接的timeout设置为1分钟
            MongoClientOptions myOptions = build.readPreference(ReadPreference.secondaryPreferred()).build();
                //数据库连接实例
            MongoClient mongoClient = new MongoClient(list,Arrays.asList(credential), myOptions);
            DB mondb = mongoClient.getDB(database);
            jongo = new Jongo(mondb);

#### mongo的集群方式有三种： ####

1、副本集（Replica Set）  
其实简单来说就是集群当中包含了多份数据，保证主节点挂掉了，备节点能继续提供数据服务，提供的前提就是数据需要和主节点一致  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5Njc0MjYz_size_16_color_FFFFFF_t_70]  
2、Master-Slaver（主从）  
也就是主备，官方已经不推荐使用。  
3、Sharding（分片集群）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5Njc0MjYz_size_16_color_FFFFFF_t_70 1]  
————————————————  
版权声明：本文为CSDN博主「冰\_先森」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。  
原文链接：https://blog.csdn.net/Goodmorning\_Java/article/details/90695845

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5Njc0MjYz_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2020053013213877.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5Njc0MjYz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5Njc0MjYz_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200530132148496.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5Njc0MjYz,size_16,color_FFFFFF,t_70