在 ASP.NET Core 中自動啟用 CAP 事務詳情

更新時間：2021年10月11日 15:29:44 作者：楊曉東

本篇文章旨在描述如何在 ASP.NET Core項目中并以一種簡便的方式啟用CAP事務，因為在我們的示例中都是直接演示比較直觀的方式，沒有進行封裝，有些初學者同學不太會，找到問我如何封裝，本篇文章主要基于 Entity Framework 來進行演示

一、發(fā)布端事務

由于大部分人都是在 Web 中使用，所以可以通過使用 ASP.NET Core 過濾器的方式進行，當然也可以通過中間件，原理是一致的。

1、創(chuàng)建一個 TypeFilter，命名為 CapTransactionFilterAttribute

public class CapTransactionFilterAttribute : TypeFilterAttribute
{
    public CapTransactionFilterAttribute() : base(typeof(TransactionActionFilter))
    {

    }

    public class TransactionActionFilter : IActionFilter
    {
        private IDbContextTransaction _transaction;

        public void OnActionExecuting(ActionExecutingContext context)
        {
            var dbContext = context.HttpContext.RequestServices.GetRequiredService<AppDbContext>();
            var capPublisher = context.HttpContext.RequestServices.GetService<ICapPublisher>();
            _transaction = dbContext.Database.BeginTransaction(capPublisher);
        }

        public void OnActionExecuted(ActionExecutedContext context)
        {
            if (context.Exception == null)
            {
                _transaction.Commit();
            }
            else
            {
                _transaction.Rollback();
            }

            _transaction?.Dispose();
        }
    }
}

2、使用方式，在需要進行事務控制的 Action 上添加 [TypeFilter(typeof(CapTransactionFilterAttribute))] 即可生效。

[Route("~/ef/trans-filter")]
[TypeFilter(typeof(CapTransactionFilterAttribute))]
public IActionResult EntityFrameworkWithTransactionFilter(
    [FromServices] AppDbContext dbContext)
{
    dbContext.Persons.Add(new Person() { Name = "ef.transaction" });

    _capBus.Publish("sample.rabbitmq.mysql", DateTime.Now);

    dbContext.SaveChanges();

    return Ok();
}

二、消費端事務

消費端自動事務主要利用 CAP 提供的過濾器來進行開啟，需要 CAP 版本大于 5.1.0。

1、創(chuàng)建一個 CAP 過濾器

public class MyCapFilter : SubscribeFilter
{
    private readonly AppDbContext _dbContext;
    private IDbContextTransaction _transaction;

    public MyCapFilter(AppDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public override void OnSubscribeExecuting(ExecutingContext context)
    {
        _transaction = _dbContext.Database.BeginTransaction();
    }

    public override void OnSubscribeExecuted(ExecutedContext context)
    {
        _transaction.Commit();
    }

    public override void OnSubscribeException(DotNetCore.CAP.Filter.ExceptionContext context)
    {
       _transaction.Rollback();
    }
}

2、配置過濾器

services.AddCap(opt =>
{
    // ***
}.AddSubscribeFilter<MyCapFilter>();

以上就是消費端的一個簡單示例。

到此這篇關于在 ASP.NET Core 中自動啟用 CAP 事務詳情的文章就介紹到這了,更多相關在 ASP.NET Core 中自動啟用 CAP 事務內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

.NET項目在k8s中運行的Dapr持續(xù)集成流程
這篇文章主要介紹了.NET項目在k8s中運行的Dapr持續(xù)集成流程，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步早日升職加薪
2022-04-04
在NET?Core?中獲取?CPU?使用率
這篇文章我們分享一種如何在?.NETCore?中獲取?CPU使用率的方法,?它所報告的這個值和?任務管理器?中報告的?CPU?使用值?差不多是一致的，下面來看看文中的具體詳細介紹吧
2022-01-01
修改 asp.net core 5 程序的默認端口號
這篇文章主要介紹了修改 asp.net core 5 程序的默認端口號，我們知道可以通過修改 launchSettings.json 文件中的端口號來實現(xiàn)端口切換，下面來看看具體的修改過程吧
2022-01-01
.NET6新特性之隱式命名空間引用
本文給大家分享的是 .NET6特新隱式命名空間引用,如果我們要在新加一個命名空間的引用,可以在項目文件中配置增加<Using Include="命名空間"/>,如果需要移除一個命名空間可以這么做<Using Remove="命名空間"/>,下面來看看文章詳細介紹內(nèi)容吧,需要的朋友可以參考一下
2021-11-11
ASP.NET Web API教程創(chuàng)建Admin視圖詳細介紹
現(xiàn)在我們轉(zhuǎn)入客戶端，并添加一個能夠使用從Admin控制器而來的數(shù)據(jù)的頁面。通過給控制器發(fā)送AJAX請求的方式，該頁面將允許用戶創(chuàng)建、編輯，或刪除產(chǎn)品
2012-11-11
ASP.NET Core MVC 依賴注入View與Controller
本文重點給大家介紹的是ASP.NET Core MVC 之依賴注入 View 和ASP.NET Core MVC 之依賴注入 Controller的相關資料,需要的小伙伴可以參考下面文章具體內(nèi)容
2021-09-09
Oracle中TO_DATE格式介紹
Oracle中TO_DATE格式介紹;可供需求的朋友參考
2012-11-11
利用ASP.NET技術動態(tài)生成HTML頁面
利用ASP.NET技術動態(tài)生成HTML頁面...
2006-07-07
ASP.net中md5加密碼的方法
ASP.net中md5加密碼的方法...
2006-07-07
.NET?Core?中對象池?Object?Pool的使用
這篇文章主要介紹了?.NET?Core?中對象池?Object?Pool的使用，對象池簡單來說就是一種為對象提供可復用能力的軟件設計思路，對象池最常用的場景是游戲設計，因為在游戲中大量存在著可復用的對象，源源不斷的子彈出現(xiàn)并不是循環(huán)再生的，下面一起進入文章了解具體內(nèi)容吧
2021-11-11