mongodb 什么是master或primary?思维导图 代码示例（java 架构)-爱代码爱编程
在 MongoDB 中，术语 “master” 并不常用，而 “primary” 是指复制集（Replica Set）中的一个特定角色。在一个复制集中，主节点（Primary）是唯一可以接受写操作的成员。其他成员被称为次节点（Secondary），它们从主节点复制数据以确保高可用性和数据冗余。如果主节点发生故障，复制集会自动选举一个新的主节点来继续服务。
主节点 (Primary) - 思维导图概要
您可以创建一个以 “MongoDB 主节点 (Primary)” 为核心节点的思维导图，并根据以下分类展开：
- 定义
- 复制集中的主节点
- 唯一可接受写操作的节点
- 职责
- 接受所有写入操作
- 将操作记录到操作日志 (Oplog)
- 向次节点传播更改
- 选举机制
- 如何选择主节点
- 优先级和心跳检查
- 故障转移
- 主节点故障时的行为
- 自动选举新的主节点
- 读取首选项
- 支持从主节点或次节点读取
- 性能影响
- 写入压力集中在主节点上
- 次节点分担读取负载
- 监控与管理
- 使用命令和工具监控状态
- 手动干预选举过程
Java 代码示例
接下来是一些简单的 Java 代码示例，展示了如何与 MongoDB 的主节点交互以及获取有关主节点的信息。为了简化，假设我们已经有一个连接到复制集的 MongoClient 实例。
导入必要的包
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
连接到 MongoDB 复制集
public class PrimaryNodeExample {
public static void main(String[] args) {
// 使用连接字符串连接到复制集
String connectionString = "mongodb://rs0-member1:27017,rs0-member2:27017,rs0-member3:27017/?replicaSet=rs0";
try (MongoClient mongoClient = MongoClients.create(connectionString)) {
MongoDatabase adminDb = mongoClient.getDatabase("admin");
// ... 操作将在这里添加 ...
}
}
}
获取复制集状态
通过 replSetGetStatus 命令查看当前复制集的状态，包括哪个节点是主节点。
// 获取复制集状态
Document rsStatus = adminDb.runCommand(new Document("replSetGetStatus", 1));
System.out.println("Replica Set Status:\n" + rsStatus.toJson());
// 提取主节点信息
for (Document member : (List<Document>) rsStatus.get("members")) {
if ("PRIMARY".equals(member.getString("stateStr"))) {
System.out.println("Primary Node: " + member.getString("name"));
break;
}
}
设置读取首选项
可以根据业务需求设置读取首选项，例如总是从主节点读取或者允许从次节点读取。
import com.mongodb.ReadPreference;
// 设置读取首选项为 primary，即只从主节点读取
ReadPreference readPreference = ReadPreference.primary();
collection.withReadPreference(readPreference);
// 执行查询
collection.find().forEach(doc -> System.out.println(doc.toJson()));
插入数据并验证主节点行为
插入一些数据后，可以通过查询确认这些数据是否被正确地传播到了所有次节点。
// 获取 sample 集合实例
MongoCollection<Document> collection = mongoClient.getDatabase("testdb").getCollection("sample");
// 插入文档
collection.insertOne(new Document("name", "Alice").append("age", 30));
System.out.println("Inserted document into the primary node.");
// 等待几秒钟让次节点同步数据
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 查看次节点的数据
// 注意：这里假设您有办法直接连接到某个次节点进行验证
以上代码片段展示了如何使用 MongoDB Java 驱动程序与主节点交互，并获取有关主节点的信息。请确保您已经在项目中正确配置了 MongoDB Java 驱动依赖，并且 MongoDB 服务正在运行并可访问。此外，请根据您的具体需求调整这些代码示例。理解和管理主节点对于设计高效、可靠的 MongoDB 应用至关重要。
最佳实践建议
- 定期监控复制集状态：使用监控工具跟踪主节点和其他成员的状态，及时发现潜在问题。
- 优化写入性能：考虑将某些类型的写操作分散到多个集合或数据库中，减轻主节点的压力。
- 合理设置读取首选项：根据应用的需求灵活配置读取策略，平衡读取性能和一致性。
- 测试灾难恢复计划：确保有明确的灾难恢复流程，并定期测试，以便在出现问题时快速响应。
通过合理配置和管理主节点，MongoDB 能够提供高可用性和良好的性能表现。