Azure 无法将事务编组为弹性事务的传播令牌（适用于 MSDTC）

Posted 2023-03-31

【中文标题】Azure 无法将事务编组为弹性事务的传播令牌（适用于 MSDTC）

【英文标题】：Azure failed to marshal transaction into propagation token for elastic transaction (Works for MSDTC)

【发布时间】：2018-06-01 12:40:45

【问题描述】：

在 windows azure 中，我们托管了两个 asp.net webapi 项目作为应用服务。我们需要在这里启用分布式事务。我们在一个 api 中启动事务。然后在该事务范围内，我们获取该事务的传播令牌，并在另一个 api 调用期间将其作为标头发送。代码如下所示。

[HttpGet]
[Route("api/Test/Transaction/Commit")]
public async Task<string> Commit()

    using (var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
    
        IsolationLevel = IsolationLevel.ReadCommitted
    ,
    TransactionScopeAsyncFlowOption.Enabled))
    
        // cross app domain call
        using (var client = new HttpClient())
        
            using (var request = new HttpRequestMessage(HttpMethod.Get, ConfigurationManager.AppSettings["IdentityServerUri"] + "api/Test/Transaction/NoCommit"))
            
                // forward transaction token
                request.AddTransactionPropagationToken();
                var response = await client.SendAsync(request);
                response.EnsureSuccessStatusCode();
            
        
        this.Repository.Insert(new Currency  Ccy = "x", IsoCode = "XIS", Name = "XYZ", CurrencyId = 9 );
        await this.Repository.SaveChangesAsync();

        scope.Complete();
        return "value";
    


public static class HttpRequestMessageExtension

    public static void AddTransactionPropagationToken(this HttpRequestMessage request)
    
        if (Transaction.Current != null)
        
            var token = TransactionInterop.GetTransmitterPropagationToken(Transaction.Current);
            request.Headers.Add("TransactionToken", Convert.ToBase64String(token));
        
    

在我们在事务范围内进行调用的 api(...api/Test/Transaction/NoCommit) 内部，从标头中获取事务的封送传播令牌并使用它创建该事务的实例并实例化 TransactionScope使用该交易。稍后我们使用这个事务范围来完成那个事务。我们引入了一个动作过滤器来应用它，并将该过滤器添加到负责该 API 调用的动作中。该 API 和操作过滤器的代码如下所示。

    [HttpGet]
    [EnlistToDistributedTransactionActionFilter]
    [Route("api/Test/Transaction/NoCommit")]
    public async Task<string> NoCommit()
    
        this.Repository.Insert(new Client
        
            Name = "Test",
            AllowedOrigin = "*",
            Active = true,
            ClientGuid = Guid.NewGuid(),
            RefreshTokenLifeTime = 0,
            ApplicationType = ApplicationTypes.javascript,
            Secret = "ffff",
            Id = "Test"
        
        );
        await this.Repository.SaveChangesAsync();
        return "value";
    

public class EnlistToDistributedTransactionActionFilter : ActionFilterAttribute

    private const string TransactionId = "TransactionToken";

    /// <summary>
    /// Retrieve a transaction propagation token, create a transaction scope and promote the current transaction to a distributed transaction.
    /// </summary>
    /// <param name="actionContext">The action context.</param>
    public override void OnActionExecuting(HttpActionContext actionContext)
    
            if (actionContext.Request.Headers.Contains(TransactionId))
            
                var values = actionContext.Request.Headers.GetValues(TransactionId);
                if (values != null && values.Any())
                
                    byte[] transactionToken = Convert.FromBase64String(values.FirstOrDefault());
                    var transaction = TransactionInterop.GetTransactionFromTransmitterPropagationToken(transactionToken);
                    var transactionScope = new TransactionScope(transaction, TransactionScopeAsyncFlowOption.Enabled);

                    actionContext.Request.Properties.Add(TransactionId, transactionScope);
                
                        
    

    /// <summary>
    /// Rollback or commit transaction.
    /// </summary>
    /// <param name="actionExecutedContext">The action executed context.</param>
    public override void OnActionExecuted(HttpActionExecutedContext actionExecutedContext)
    
            if (actionExecutedContext.Request.Properties.Keys.Contains(TransactionId))
            
                var transactionScope = actionExecutedContext.Request.Properties[TransactionId] as TransactionScope;
                if (transactionScope != null)
                
                    if (actionExecutedContext.Exception != null)
                    
                        Transaction.Current.Rollback();
                    
                    else
                    
                        transactionScope.Complete();
                    

                    transactionScope.Dispose();
                    actionExecutedContext.Request.Properties[TransactionId] = null;
                
                                  
    

因此，如果在该事务范围内（在第一个 api 或第二个 api 中）的此调用（api/Test/Transaction/Commit）期间发生任何异常，则两个 api 完成的所有数据库更改都将被回滚。这在本地运行良好。在本地，我们得到了 MSDTC 的支持。但是在 Azure 中没有 MSDTC 支持。在 azure 中，我们从 Elastic 事务中获得支持。因此，当我们尝试从第一台服务器获取交易的传播令牌时，我们会遇到异常。所以当我们尝试执行下面的代码时 var transaction = TransactionInterop.GetTransactionFromTransmitterPropagationToken(transactionToken); 我们收到异常消息“值不在预期范围内”。 This post 说这种方法需要 System.Transactions 升级到 MSDTC，但是对于弹性事务，我们将如何使其工作？ 对于弹性交易，我们需要将交易编组为传播令牌。如何做到这一点？正在寻找解决方案。

【参考方案1】：

弹性事务旨在允许从 Azure 中的单个 .net 应用程序跨 Azure SQL 数据库和 Azure SQL 托管实例进行事务。

它不是为跨客户端分发交易而构建的。

“仅支持来自 a .NET 应用程序的客户端协调事务”

https://docs.microsoft.com/en-us/azure/azure-sql/database/elastic-transactions-overview