HMENetCore.MongoDB 10.0.9

HMENetCore.MongoDB

简介

HMENetCore.MongoDB 是基于官方MongoDB.Driver的增强封装库，专为.NET Core应用提供更便捷的MongoDB集成方案。支持MongoDB 4.0+版本，提供符合领域驱动设计(DDD)的仓储模式实现。

核心优势

🚀 性能优化

• 智能连接池管理（默认100-500连接）
• 批量操作自动优化
• 异步全链路支持

🔐 企业级安全

• TLS/SSL加密支持
• 完善的错误重试机制
• 事务ACID保证

🧩 开箱即用

• 自动集合命名映射
• 内置常用CRUD操作
• 支持LINQ表达式查询

功能特性

• 清洁架构：Context → Repository → Service 清晰分层
• 全异步支持：所有方法均提供Async版本
• 事务支持：跨操作事务一致性保证
• 灵活配置：支持多节点集群、SSL连接、连接池调优
• 智能映射：自动处理集合命名与类型映射

运行环境

• 跨平台支持: Supports .NET Standard 2.1, .NET 8, and .NET 10.

安装

dotnet add package HMENetCore.MongoDB

配置数据库连接

添加配置到 appsettings.json：

{
 "MongoConfig": {
 "ConnectionStrings": ["server1:27017", "server2:27017"],
 "DbName": "your_db",
 "UserName": "user",
 "Password": "pwd",
 "UseSsl": true,
 "MaxPoolSize": 500
 }
}

服务注册

builder.Services.Configure<MongoConfig>(builder.Configuration.GetSection("MongoConfig"));
builder.Services.AddMongoDBSetup(builder.Configuration.Get<MongoConfig>()!);

使用案例：

1.定义实体

[Table("users")]
public class User 
{
 [BsonId]
 public string Id { get; set; }
 public string Name { get; set; }
 public DateTime CreateTime { get; set; }
}

2.创建仓储

public class UserRepository : BaseMongoRepository<User>
{
 public UserRepository(IMongoContext context) : base(context) 
 {
 }
 
 // 自定义查询方法
 public async Task<List<User>> GetActiveUsersAsync()
 {
 var collection = GetCollection();
 return await collection.Find(u => u.CreateTime > DateTime.UtcNow.AddDays(-30))
 .ToListAsync();
 }
}

3.业务服务

public class UserService : BaseMongoService<User>
{
 public UserService(IMongoCRUD<User> repository) : base(repository) 
 {
 }

 public async Task UpdateUserWithTransactionAsync(string userId, Action<User> update)
 {
 using var session = await StartSessionAsync();
 session.StartTransaction();
 
 try {
 var user = await FindByIdAsync(userId);
 update(user);
 await ReplaceOneAsync(userId, user);
 
 await session.CommitTransactionAsync();
 }
 catch {
 await session.AbortTransactionAsync();
 throw;
 }
 }
}

核心组件

1. IMongoContext

提供对 MongoContext 的基本操作接口。

2. BaseMongoRepository

仓储层基类，实现了 IMongoCRUD 接口，提供对特定实体的 CRUD 操作。

3. BaseMongoService

服务层基类，封装了仓储层的操作，可以在此基础上添加业务逻辑。