HMENetCore.MongoDB 6.0.48

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连接、连接池调优
• 智能映射：自动处理集合命名与类型映射

.NET支持

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

安装

dotnet add package HMENetCore.MongoDB --version 6.0.48

配置数据库连接

添加配置到 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

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