.NET 开源分布式事务解决方案：CAP

我本地安装的是 DotNetCore.CAP.MongoDB。

//按需选择安装你正在使用的数据库:
PM> Install-Package DotNetCore.CAP.SqlServer
PM> Install-Package DotNetCore.CAP.MySql
PM> Install-Package DotNetCore.CAP.PostgreSql
PM> Install-Package DotNetCore.CAP.MongoDB 

配置 CAP 到 Program.cs 文件中

builder.Services.AddCap(x => 
{
    //如果你使用的 EF 进行数据操作，你需要添加如下配置：
    //配置数据库上下文
    x.UseEntityFramework<AppDbContext>();
    //如果你使用的 MongoDB，你可以添加如下配置：
    x.UseMongoDB("ConnectionStrings");  //注意，仅支持 MongoDB 4.0+ 集群
    //CAP RabbitMQ 配置
    x.UseRabbitMQ(rab => {
        rab.HostName = "192.0.1.1";
        rab.Password = "123456";
        rab.Port = 5672;
        rab.UserName = "123456";
    });
});

发布

在 Controller 中注入 ICapPublisher 然后使用 ICapPublisher 进行消息发送。

public class PublishController : Controller 
{
    private readonly ICapPublisher _capBus;
    public PublishController(ICapPublisher capPublisher)
    {
        _capBus = capPublisher;
    }
    
    //不使用事务
    [Route("~/without/transaction")]
    public IActionResult WithoutTransaction()
    {
        _capBus.Publish("xxx.services.show.time", DateTime.Now);
        // Publish delay message
        _capBus.PublishDelayAsync(TimeSpan.FromSeconds(delaySeconds), "xxx.services.show.time", DateTime.Now);

        return Ok();
    }
    //Ado.Net 中使用事务，自动提交
    [Route("~/adonet/transaction")]
    public IActionResult AdonetWithTransaction()
    {
        using (var connection = new MySqlConnection(ConnectionString))
        {
            using (var transaction = connection.BeginTransaction(_capBus, autoCommit: true))
            {
                //业务代码
                _capBus.Publish("xxx.services.show.time", DateTime.Now);
            }
        }
        return Ok();
    }
    //EntityFramework 中使用事务，自动提交
    [Route("~/ef/transaction")]
    public IActionResult EntityFrameworkWithTransaction([FromServices]AppDbContext dbContext)
    {
        using (var trans = dbContext.Database.BeginTransaction(_capBus, autoCommit: true))
        {
            //业务代码
            _capBus.Publish("xxx.services.show.time", DateTime.Now);
        }
        return Ok();
    }
}

订阅

Action Method

在 Action 上添加 CapSubscribeAttribute 来订阅相关消息。

public class PublishController : Controller 
{
    [CapSubscribe("xxx.services.show.time")]
    public void CheckReceivedMessage(DateTime datetime)
    {
        Console.WriteLine(datetime);
    }
}

Service Method

如果你的订阅方法没有位于 Controller 中，则你订阅的类需要继承 ICapSubscribe：

namespace xxx.Service 
{
    public interface ISubscriberService 
    {
        void CheckReceivedMessage(DateTime datetime);
    }
    public class SubscriberService:ISubscriberService,ICapSubscribe 
    {
        [CapSubscribe("xxx.services.show.time")]
        public void CheckReceivedMessage(DateTime datetime)
        {
        }
    }
}

官方文档

更多信息请参考官方文档：https://cap.dotnetcore.xyz/