Использование транзакций между процессами

Question

Я пытаюсь использовать System.Transactions (TransactionScope) для координации набора процессов, каждый из которых выполняет некоторую работу с базой данных. В конечном итоге все процессы должны фиксироваться или откатываться атомарно через один родительский процесс. К сожалению, ничего, что я пробовал до сих пор не работает.

Моя основная стратегия - TransactionScope в родительском процессе, сохранить его в файл и вызвать дочерний процесс, который загружает файл, использует транзакцию внутри своего собственного TransactionScope и возвращает его родителю.

Но это не работает для меня. Когда я возвращаюсь от вызова первого потомка, я иногда вижу, что родительская транзакция помечена как прерванная. Попытка клонировать его затем вызывает TransactionAbortedException.

Я также видел исключения, когда второй дочерний элемент пытается десериализовать транзакцию, я получаю исключение TransactionException с кодом 0x8004d00e.

Я пытаюсь сделать то, что описано в TransactionScope для доменов приложений и процессов и http://blogs.microsoft.co.il/blogs/sasha/archive/2010/04/30/propagating-a-transaction-across-appdomains.aspx. Несмотря ни на что, не повезло.

Вот некоторые вещи, которые я попробовал, но безуспешно:

1. Создание DependentTransaction с помощью DependentClone() в дочернем процессе из загруженной транзакции
2. Создание DependentTransaction с помощью DependentClone() в родительском процессе перед сохранением транзакции в файл
3. Создание Clone () в родительском процессе перед сохранением транзакции в файл
4. Сохранение транзакции с использованием сериализации
5. Сохранение транзакции с использованием TransactionInterop.GetTransactionFromTransmitterPropagationToken()
6. Явное открытие соединения перед TransactionScope родителя
7. Явное завершение транзакции внутри родителя
8. Явное завершение транзакции внутри дочернего
9. Завершение / не завершение области на родительском
10. Завершение / не завершение области на ребенке
11. Явное создание CommittableTransaction в родительском

Вот одно сообщение об исключении:

System.Transactions.TransactionException: транзакция уже была явно или неявно зафиксирована или прервана. ---> System.Runtime.InteropServices.COMException: транзакция уже была явно или неявно зафиксирована или прервана (исключение из HRESULT: 0x8004D00E)

И другое (при использовании DependentClone()):

System.Transactions.TransactionAbortedException: транзакция прервана. в System.Transactions.TransactionStatePromotedAborted.CreateBlockingClone(в ternalTransaction tx) в System.Transactions.DependentTransaction..ctor(IsolationLevel isoLevel, в ternalTransaction internalTransaction, логическое блокирование) в System.Transactions.ToneactionOoneOoneOone (

Есть идеи, что я делаю не так? Я попробовал много перестановок этого без какой-либо удачи.

Вот некоторый код (который не пытается продемонстрировать все варианты, описанные выше):

        // one variant I have tried is to create a CommittableTransaction
        // and pass that in the scope below

        using (TransactionScope scope = new TransactionScope())
        {
            // optionally, do some parent-level EF work

            // invoke child operations in other processes
            DoChildOperation_OutOfProc(1, Transaction.Current);
            DoChildOperation_OutOfProc(2, Transaction.Current);

            scope.Complete();
        }

        // in the variant where I created a CommittableTransaction,
        // I committed it here

    ...

    private static void DoChildOperation_OutOfProc(int id, Transaction transaction)
    {
        string tranFile = string.Format("ChildTran_{0}.txt", id);
        SaveTransactionToFile(transaction, tranFile);

        Process process = new Process();
        process.StartInfo = new ProcessStartInfo(Process.GetCurrentProcess().MainModule.FileName.Replace(".vshost", string.Empty),
            string.Format("-CHILDID={0} -TRANFILE={1}", id, tranFile));
        process.StartInfo.UseShellExecute = false;
        process.Start();
        process.WaitForExit();
    }

    private static void SaveTransactionToFile(Transaction transaction, string tranFile)
    {
        byte[] transactionBytes =
            TransactionInterop.GetTransmitterPropagationToken(transaction);

        string tranFileContents = Convert.ToBase64String(transactionBytes);

        File.WriteAllText(tranFile, tranFileContents);
    }

    private static Transaction LoadTransactionFromFile(string tranFile)
    {
        string tranFileContents = File.ReadAllText(tranFile);
        File.Delete(tranFile);

        byte[] tranBytes = Convert.FromBase64String(tranFileContents);

        Transaction tran = 
            TransactionInterop.GetTransactionFromTransmitterPropagationToken(tranBytes);
        return tran;
    }

    // the child instance of the app runs this after decoding the arguments
    // from DoChildOperation_OutOfProc() and loading the transaction out of the file

    private static void DoChildOperation(int id, Transaction childTransaction)
    {
        // in one variant, I call 
        // childTransaction.DependentClone(DependentCloneOption.BlockCommitUntilComplete)
        // and then use that inside the TransactionScope

        using (TransactionScope scope = new TransactionScope(childTransaction))
        {
            // do EF work and call SaveChanges()

            scope.Complete();
        }

        // if I created a dependent clone, call Complete() here on it

Answer 1

Хорошо, похоже, что ключ в том, что вы можете использовать TransactionScope в родительском объекте, но не в дочернем. Для ребенка я открываю соединение EF, вызываю connection.EnlistTransaction() с переданной транзакцией и выполняю EF SaveChanges() или транзакции.Rollback(), но не фиксирую (класс Transaction не предлагает этого). Делая это таким образом, получается, что я получаю желаемое поведение.

Разрыв в моем понимании заключался в том, была ли транзакция вложенной (как вы можете сделать в SQL Server) или нет. Похоже, что это действительно не так; это та же транзакция. Примечание. Даже если вы создадите DependentTransaction с помощью Transaction.DependentClone() в дочернем элементе, вы все равно не сможете выполнить его, если поместите его в TransactionScope.

Это оказывается немного неудачно, потому что это означает, что если ваш процесс является родительским, вы можете использовать TransactionScope, но если это дочерний процесс, вы не можете.