Azure не удалось маршалировать транзакцию в токен распространения для эластичной транзакции (работает для MSDTC)

В 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/Test/Transaction/Commit) возникает какое-либо исключение внутри этой области транзакции (либо в первом API, либо во втором API), все изменения базы данных, сделанные обоими API, будут отменены. Это работает нормально локально. Так же локально получаем поддержку MSDTC. Но в Azure нет поддержки MSDTC. В Azure мы получаем поддержку от транзакции Elastic. Из-за этого, когда мы пытаемся получить токен распространения транзакции с первого сервера, мы получаем исключение. Поэтому, когда мы пытаемся выполнить приведенный ниже код, var transaction = TransactionInterop.GetTransactionFromTransmitterPropagationToken(transactionToken); Мы получаем исключение с сообщением "Значение не попадает в ожидаемый диапазон". В этом сообщении говорится, что этот метод потребует продвижения до MSDTC с помощью System.Transactions, но для эластичной транзакции, как мы заставим ее работать? Для эластичной транзакции нам нужно маршалировать транзакцию в токен распространения. Как это сделать? Ищем решение.


person Anup    schedule 19.12.2017    source источник


Ответы (1)


Эластичные транзакции предназначены для обеспечения транзакций между базой данных SQL Azure и Управляемым экземпляром Azure SQL из одного приложения .net в Azure.

Он не предназначен для распределения транзакций между клиентами.

Поддерживаются только скоординированные клиентом транзакции из приложения .NET.

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

person Shiraz Bhaiji    schedule 19.12.2020