NCC CAP 6.2 版本正式发布

原文：https://www.cnblogs.com/savorboard/p/cap-6-2.html

作者：杨晓东

前言

今天，我们很高兴宣布 CAP 发布 6.2 版本正式版，在这个版本中我们主要做了一些功能优化，以及针对目前已经发现的几个 BUG 进行了修复了。

那么，接下来我们具体看一下吧。

总览

可能有些人还不知道 CAP 是什么，老规矩来一个简介。

CAP 是一个用来解决微服务或者分布式系统中分布式事务问题的一个开源项目解决方案（https://github.com/dotnetcore/CAP）同样可以用来作为 EventBus 使用，该项目诞生于2016年，目前在 Github 已经有超过 5500+ Star 和 70+ 贡献者，以及在 NuGet超 250 万的下载量，并在越来越多公司的和项目中得到应用。

如果你想对 CAP 更多了解，请查看我们的官方文档。

本次在 CAP 6.2 版本中我们主要带来了以下新特性：

Dashboard 添加中文支持
事务对象更友好的对接第三方ORM
消费执行消息头记录 InstanceId
启动时对位于相同组的订阅者进行警告
BUG 修复
- Snowflake Id 算法生成时排除虚拟，回环和禁用的网卡
- 修复 RabbitMQ 丢失连接并快速恢复时的健康检测Bug。
- 修复 Dashboard 代理查询缺失 QueryString 的问题。
- 修复 MongoDB 查询元素未注册不返回结果的Bug。
- 修复 Scoped 生命周期工厂模式注册的订阅者报错的Bug。

Dashboard 添加中文支持

我们在 5.1.1 版本中使用 Vue 重构了我们的 Dashboard，由于时间原因，我们的新版本的 Dashboard 只对英文提供了支持。

在该版本中我们重新提供了对中文的支持，目前可自动根据你的浏览器检测使用的语言并展示。

你也可以在右上方进行手动切换。

img

感谢 @tetris1128 对此提交的PR！

事务对接第三方 ORM 更加友好

在 CAP 中，事务对象需要交给 CAP 进行提交从而在事务实现提交后对缓存消息到 Broker 的 Flush 动作，而目前的Orm大部分都有自己的事务管理对象进行事务的提交。CAP官方直接原生支持使用 ADO.NET 和 EntityFrameworkCore 进行事务集成，而对于第三方ORM则需要自行扩展。

在本版本中，我们做了一个小调整（将 CapTransactionBase 中的 DbTransaction 设置为了 Virtual），没想到这个小调整让我们对第三方ORM的兼容性得到了大大增强，现在第三方ORM可以更加友好的对接CAP。

以下是2个第三方ORM的集成示例：

FreeSql Repository+UnitOfWork 事务模式和 CAP 的集成
Chloe Orm 和 CAP 的集成

示例：与 FreeSql 集成

FreeSql Repository+UnitOfWork 事务模式和 CAP 的集成示例如下：

public class FreeSqlRepositoryPatternTransaction : CapTransactionBase
{public FreeSqlRepositoryPatternTransaction(IDispatcher dispatcher, IUnitOfWork uow) : base(dispatcher){Uow = uow;}public IUnitOfWork Uow { get; }public override object? DbTransaction => Uow.GetOrBeginTransaction();public override void Commit(){Uow.Commit();Flush();}public override Task CommitAsync(CancellationToken cancellationToken = default){throw new NotImplementedException();}public override void Rollback(){Uow.Rollback();}public override Task RollbackAsync(CancellationToken cancellationToken = default){throw new NotImplementedException();}public override void Dispose(){Uow.Dispose();}
}public static class Extensions
{// 注意：你可以酌情修改此扩展以支持你的使用习惯public static ICapTransaction BeginTransaction(this IFreeSql freeSql,ICapPublisher publisher, out IRepositoryUnitOfWork uow, bool autoCommit = false){var dispatcher = publisher.ServiceProvider.GetRequiredService<IDispatcher>();uow = freeSql.CreateUnitOfWork();var transaction = new FreeSqlRepositoryPatternTransaction(dispatcher, uow){AutoCommit = autoCommit};return publisher.Transaction.Value = transaction;}
}

使用发送带有事务的消息。

[Route("~/with/test")]
public IActionResult WithTransaction()
{using (var transaction = _freeSql.BeginTransaction(_capBus, out var uow, false)){_capBus.Publish("sample.rabbitmq.mysql", DateTime.Now);var person = _freeSql.GetRepository<Person2>();person.UnitOfWork = uow;person.Insert(new Person2() { Name = "HelloWorld2" });transaction.Commit();}return Ok();
}

你可以在这里查看到 FreeSql DbContext 事务模式的对接方式。

示例：与 Chloe 集成

Chloe Orm 和 CAP 进行集成如下：

public class ChloeTransaction : CapTransactionBase
{public ChloeTransaction(IDispatcher dispatcher, IDbSession session) : base(dispatcher){DbSession = session;      }public IDbSession DbSession { get; set; }public override object? DbTransaction => DbSession.CurrentTransaction;public override void Commit(){DbSession.CommitTransaction();Flush();}public override Task CommitAsync(CancellationToken cancellationToken = default){throw new NotImplementedException();}public override void Rollback(){DbSession.RollbackTransaction();}public override Task RollbackAsync(CancellationToken cancellationToken = default){throw new NotImplementedException();}public override void Dispose(){(DbTransaction as IDisposable)?.Dispose();}
}public static class Extensions
{public static ICapTransaction BeginTransaction(this IDbContext dbContext,ICapPublisher publisher, bool autoCommit = false){ var dispatcher = publisher.ServiceProvider.GetRequiredService<IDispatcher>();dbContext.Session.BeginTransaction();var transaction =  new ChloeTransaction(dispatcher,dbContext.Session){AutoCommit = autoCommit};return publisher.Transaction.Value = transaction;}
}

发送带有事务的消息：

[Route("~/with/test")]
public IActionResult WithTransaction()
{using (_dbContext.BeginTransaction(_capBus, true)){_dbContext.Insert(new Person2() { Name = "HelloWorld" });           _capBus.Publish("sample.rabbitmq.mysql", DateTime.Now);}return Ok();
}

相关链接：https://github.com/shuxinqin/Chloe/issues/328