当前位置: 首页 > java >正文

在Spring Boot 中如何配置MongoDB的副本集 (Replica Set) 或分片集群 (Sharded Cluster)?

在 Spring Boot 中配置 MongoDB 副本集 (Replica Set) 或分片集群 (Sharded Cluster) 非常相似,主要区别在于连接字符串 (URI) 中提供的主机列表和一些特定选项。

最常的方式是使用 spring.data.mongodb.uri 属性配置连接字符串。

1. 连接到 MongoDB 副本集 (Replica Set)

副本集提供高可用性。需要提供副本集中至少一个成员的地址,驱动会自动发现当前的主节点 (Primary)。

关键点:

  • 在 URI 中列出多个副本集成员的主机名和端口,用逗号分隔。
  • 必须指定 replicaSet 参数,其值为在 MongoDB 中配置的副本集名称。

配置示例 (application.properties):

# --- MongoDB Replica Set Configuration ---# 基本连接 URI,包含多个主机节点和副本集名称
# 格式: mongodb://[username:password@]host1[:port1],host2[:port2],...[,hostN[:portN]][/[database][?options]]
spring.data.mongodb.uri=mongodb://mongo-rs1:27017,mongo-rs2:27017,mongo-rs3:27017/mydatabase?replicaSet=myReplicaSet# 如果需要认证
# spring.data.mongodb.uri=mongodb://myuser:mypassword@mongo-rs1:27017,mongo-rs2:27017,mongo-rs3:27017/mydatabase?replicaSet=myReplicaSet&authSource=admin# --- 可选的其他常用选项 ---
# 读取 (例如,从次要节点读取以分散负载)
# spring.data.mongodb.uri=mongodb://.../mydatabase?replicaSet=myReplicaSet&readPreference=secondaryPreferred# 写入安全级别 (Write Concern) - 例如,要求写入大多数节点确认
# spring.data.mongodb.uri=mongodb://.../mydatabase?replicaSet=myReplicaSet&w=majority# 连接超时 (毫秒)
# spring.data.mongodb.uri=mongodb://.../mydatabase?replicaSet=myReplicaSet&connectTimeoutMS=5000# 套接字超时 (毫秒)
# spring.data.mongodb.uri=mongodb://.../mydatabase?replicaSet=myReplicaSet&socketTimeoutMS=10000# 启用 TLS/SSL
# spring.data.mongodb.uri=mongodb://.../mydatabase?replicaSet=myReplicaSet&ssl=true

配置示例 (application.yml):

spring:data:mongodb:# 基本连接 URIuri: mongodb://mongo-rs1:27017,mongo-rs2:27017,mongo-rs3:27017/mydatabase?replicaSet=myReplicaSet# 带认证的 URI# uri: mongodb://myuser:mypassword@mongo-rs1:27017,mongo-rs2:27017,mongo-rs3:27017/mydatabase?replicaSet=myReplicaSet&authSource=admin# 组合选项示例# uri: mongodb://myuser:mypassword@mongo-rs1:27017,mongo-rs2:27017,mongo-rs3:27017/mydatabase?replicaSet=myReplicaSet&authSource=admin&readPreference=secondaryPreferred&w=majority&retryWrites=true
  • mydatabase: 要连接的默认数据库名称。
  • myReplicaSet: 在 MongoDB 中设置的副本集的名称。
  • mongo-rs1, mongo-rs2, mongo-rs3: 副本集成​​员的主机名或 IP 地址。
  • 27017: 副本集成​​员的端口号(默认)。
  • myuser, mypassword: 用于认证的用户名和密码。
  • authSource=admin: 指定用于验证用户凭据的数据库( admin 数据库,除非用户是在特定数据库中创建的)。
  • retryWrites=true: 推荐启用,允许驱动程序在遇到某些网络错误或副本集选举时自动重试一次写入操作。

2. 连接到 MongoDB 分片集群 (Sharded Cluster)

分片集群提供水平扩展能力。需要连接到 mongos 路由进程,而不是直接连接到分片副本集。

关键点:

  • 在 URI 中列出一个或多个 mongos 实例的主机名和端口,用逗号分隔。
  • 不需要指定 replicaSet 参数,因为是连接到 mongos 而不是特定的副本集。

配置示例 (application.properties):

# --- MongoDB Sharded Cluster Configuration ---# 连接到多个 mongos 实例
# 格式: mongodb://[username:password@]mongos1[:port1],mongos2[:port2],...[,mongosN[:portN]][/[database][?options]]
spring.data.mongodb.uri=mongodb://mongos1.example.com:27017,mongos2.example.com:27017/mydatabase# 如果需要认证 (在 admin 数据库进行认证)
# spring.data.mongodb.uri=mongodb://myuser:mypassword@mongos1.example.com:27017,mongos2.example.com:27017/mydatabase?authSource=admin# --- 可选的其他常用选项 (与副本集类似,但作用于 mongos) ---
# 读取偏好 (mongos 会根据设置将读请求路由到合适的分片节点)
# spring.data.mongodb.uri=mongodb://.../mydatabase?readPreference=nearest# 写入安全级别
# spring.data.mongodb.uri=mongodb://.../mydatabase?w=majority# 启用 TLS/SSL (如果 mongos 配置了 SSL)
# spring.data.mongodb.uri=mongodb://.../mydatabase?ssl=true

配置示例 (application.yml):

spring:data:mongodb:# 连接到多个 mongos 实例uri: mongodb://mongos1.example.com:27017,mongos2.example.com:27017/mydatabase# 带认证的 URI# uri: mongodb://myuser:mypassword@mongos1.example.com:27017,mongos2.example.com:27017/mydatabase?authSource=admin# 组合选项示例# uri: mongodb://myuser:mypassword@mongos1.example.com:27017,mongos2.example.com:27017/mydatabase?authSource=admin&readPreference=nearest&w=majority&retryWrites=true
  • mongos1.example.com, mongos2.example.com: mongos 实例的主机名或 IP 地址。
  • 27017: mongos 实例的端口号(默认)。
  • 其他参数(mydatabase, myuser, mypassword, authSource, readPreference, w, retryWrites, ssl 等)的含义与连接副本集时相同。

3. 依赖项

确保 pom.xml (Maven) 或 build.gradle (Gradle) 文件中包含了 Spring Data MongoDB 的 starter 依赖:

Maven:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

Gradle:

implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'

总结与注意事项

  1. 主要区别: 连接副本集需要 replicaSet=name 参数并列出副本集成员;连接分片集群则列出 mongos 实例地址,不需要 replicaSet 参数。
  2. URI 是首选: 使用 spring.data.mongodb.uri 是配置 MongoDB 连接最简洁、最标准的方式。
  3. 主机列表: 在 URI 中提供多个主机地址(无论是副本集成员还是 mongos 实例)可以提高应用程序启动时的健壮性。即使列表中的某个主机暂时不可用,驱动程序也可以尝试连接其他主机。
  4. 认证: 如果 MongoDB 启用了认证,务必在 URI 中提供用户名、密码,并需要指定 authSource
  5. 安全性: 不要在配置文件中硬编码密码。考虑使用环境变量、Spring Cloud Config、Vault 或其他安全机制来管理敏感凭据。
  6. 网络: 确保 Spring Boot 应用程序可以从其运行环境中访问 URI 中指定的 MongoDB 主机和端口。
  7. 选项:readPreference, w (Write Concern), retryWrites, ssl 等,以满足应用程序的可用性、一致性和性能要求。

通过在 application.propertiesapplication.yml 中设置 spring.data.mongodb.uri,Spring Boot 会自动配置 MongoClient bean,我们可以直接在服务或仓库中注入并使用它。

http://www.xdnf.cn/news/4243.html

相关文章:

  • C++ STL 基础与多线程安全性说明文档
  • 如何开发一个笑话管理小工具
  • 盛最多水的容器
  • conda 安装cudnn
  • SpringBoot中使用MCP和通义千问来处理和分析数据
  • 强啊!Oracle Database 23aiOracle Database 23ai:使用列别名进行分组排序!
  • 高光谱相机赋能烟叶分选:精准、高效与智能化的新突破
  • 美团后端开发一面
  • 第十五届蓝桥杯单片机国赛-串口解析
  • 前端封装框架依赖管理全攻略:构建轻量可维护的私有框架
  • 关于Java多态简单讲解
  • 【表设计】外键的取舍-分布式中逐渐消失的外键
  • 【firewall-cmd】--的作用以及使用方法
  • FlinkCDC采集MySQL8.4报错
  • 第六节:图像基本操作-像素级操作
  • Windows11下ESP-IDF开发环境搭建【基于Cursor/VS Code插件】
  • 【25软考网工】第五章(7)路由协议、静态与默认路由、路由协议分类
  • 代码随想录训练营第十八天| 150.逆波兰表达式求值 239.滑动窗口最大值 347.前k个高频元素
  • 了解一下OceanBase中的表分区
  • C++:实现线程池
  • 【Spring Boot 注解】@SpringBootApplication
  • 力扣-hot100 (矩阵置零)
  • C++命名空间
  • Windows11下通过Docker安装mysql8.0
  • FPGA----基于ZYNQ 7020实现petalinux文件持久化存储
  • Linux主机时间设置操作指南及时间异常影响
  • LeetCode 解题思路 45(Hot 100)
  • 科普文:丰田凯美瑞三代混动(THS II)技术解析
  • Golang领域Beego框架的中间件开发实战
  • 【Linux】用户与组管理