Прикрепление ресурсов в качестве участников транзакции
[Этот раздел является частью предварительной документации и может быть изменен в следующих версиях. Пустые разделы включены в документацию в качестве прототипов.]
Каждым участвующим в транзакции ресурсом управляет диспетчер ресурсов, действия которого координируются диспетчером транзакций. Координация осуществляется посредством уведомлений, которые передаются подписчикам, зачисленным в транзакцию с помощью диспетчера транзакций.
В этом разделе описывается, как зачислить в транзакцию один или несколько ресурсов, и рассматриваются различные типы зачисления. В разделе Однофазная и многофазная фиксация транзакции описывается порядок координации процесса фиксации транзакции между зачисленными ресурсами.
Зачисление ресурсов в транзакцию
Для участия в транзакции ресурс должен зачислиться в нее. Класс Transaction определяет набор методов, имена которых начинаются с Enlist, обеспечивающий данную функциональную возможность. Различные методы Enlist соответствуют различным типам зачисления, которые могут использоваться диспетчером ресурсов. В частности, методы EnlistVolatile используются для неустойчивых ресурсов, а метод EnlistDurable — для устойчивых ресурсов. Устойчивость (или наоборот, неустойчивость) диспетчера ресурсов определяет, поддерживает ли он восстановление после сбоя. Если диспетчер ресурсов поддерживает восстановление после сбоя, он сохраняет данные в устойчивом хранилище во время фазы 1 (подготовка); таким образом, если диспетчер ресурсов выходит из строя, он может повторно зачислиться в транзакцию после восстановления и выполнить соответствующие действия на основе уведомлений, полученных от диспетчера транзакций. В основном, диспетчеры неустойчивых ресурсов управляют неустойчивыми ресурсами, такими как структура данных, расположенная в оперативной памяти (например транзакционная хэш-таблица), а диспетчеры устойчивых ресурсов управляют устойчивыми ресурсами, которые имеют более устойчивое резервное хранилище (например, базой данных, резервным хранилищем которой является диск).
После выбора используемого метода (EnlistDurable или EnlistVolatile) в зависимости от поддержки ресурсом восстановления после сбоя необходимо зачислить ресурс для участия в двухфазной фиксации путем реализации интерфейса IEnlistmentNotification для диспетчера ресурсов. Дополнительные сведения о двухфазной фиксации см. в разделе Однофазная и многофазная фиксация транзакции.
Один участник может зачислиться в транзакцию с использованием более одного протокола, вызвав методы EnlistDurable и EnlistVolatile несколько раз.
Зачисление устойчивых ресурсов
Методы EnlistDurable используются для зачисления диспетчера ресурсов в транзакцию в качестве устойчивого ресурса. Предполагается, что в случае выхода из строя в ходе транзакции диспетчер устойчивых ресурсов может выполнить восстановление после повторного зачисления (с помощью метода Reenlist) во все транзакции, в которых он участвовал, но в которых он не выполнил операции фазы 2, и вызвать метод RecoveryComplete после завершения восстановления. Дополнительные сведения о восстановлении см. в разделе Выполнение восстановления.
Все методы EnlistDurable принимают в качестве первого параметра объект Guid. Объект Guid используется диспетчером транзакций для связывания зачисленного устойчивого ресурса с конкретным диспетчером ресурсов. Поэтому крайне важно, чтобы диспетчер ресурсов согласованно использовал один и тот же объект Guid для идентификации себя среди различных диспетчеров ресурсов при перезапуске, иначе может не удастся выполнить восстановление.
Второй параметр метода EnlistDurable является ссылкой на объект, реализуемый диспетчером ресурсов для получения уведомлений транзакции. Используемый перегруженный метод сообщает диспетчеру транзакций, поддерживает ли диспетчер ресурсов оптимизацию однофазной фиксации. В большинстве случаев требуется реализовать интерфейс IEnlistmentNotification для принятия участия в двухфазной фиксации. Однако если требуется оптимизировать процесс фиксации, можно реализовать интерфейс ISinglePhaseNotification для однофазной фиксации. Дополнительные сведения об однофазной фиксации см. в разделах Однофазная и многофазная фиксация транзакции и Оптимизация производительности с помощью механизмов уведомления об однофазной фиксации и повышаемого однофазного уведомления.
Третий параметр — это перечисление EnlistmentOptions, значением которого может являться None или EnlistDuringPrepareRequired. Если задано значение EnlistDuringPrepareRequired, при получении уведомления о подготовке от диспетчера транзакций можно зачислить дополнительные диспетчеры ресурсов. Однако следует иметь в виду, что данный тип зачисления не подходит для оптимизации однофазной фиксации.
Зачисление неустойчивых ресурсов
Участникам, управляющим неустойчивыми ресурсами, такими как кэш, необходимо зачисляться с помощью методов EnlistVolatile. Такие объекты могут быть неспособны получить результат транзакции или восстановить состояние какой-либо транзакции, к которой они присоединяются после сбоя.
Как уже было отмечено, диспетчер ресурсов выполняет зачисление неустойчивого ресурса, если он управляет неустойчивым ресурсом, расположенным в оперативной памяти. Одно из преимуществ использования метода EnlistVolatile заключается в том, что он не приводит к передаче транзакции на следующий уровень иерархии, если эта передача не является необходимой. Дополнительные сведения о передаче транзакции на следующий уровень иерархии см. в разделе Передача управления транзакцией на следующий уровень иерархии. Зачисление неустойчивых ресурсов предполагает различие как в обработке зачисления диспетчером транзакций, так и в действиях диспетчера ресурсов, ожидаемых диспетчером транзакций. Это обусловлено тем, что диспетчер неустойчивых ресурсов не выполняет восстановление. Методы EnlistVolatile не принимают параметр Guid, поскольку диспетчер неустойчивых ресурсов не выполняет восстановление и не вызывает метод Reenlist, которому требуется объект Guid.
Как и в случае зачисления устойчивых ресурсов используемый для зачисления перегруженный метод указывает диспетчеру транзакций, поддерживает ли диспетчер ресурсов оптимизацию однофазной фиксации. Поскольку диспетчер неустойчивых ресурсов не может выполнять восстановление, никакие данные для восстановления не записываются для зачисленного неустойчивого ресурса во время фазы подготовки. Таким образом, при вызове метода RecoveryInformation возникает исключение InvalidOperationException.
В следующем примере показано, как с помощью метода EnlistVolatile зачислить объект в транзакцию в качестве участника.
Public Shared Sub Main()
Try
Using scope As TransactionScope = New TransactionScope()
'Create an enlistment object
Dim myEnlistmentClass As New EnlistmentClass
'Enlist on the current transaction with the enlistment object
Transaction.Current.EnlistVolatile(myEnlistmentClass, EnlistmentOptions.None)
'Perform transactional work here.
'Call complete on the TransactionScope based on console input
Dim c As ConsoleKeyInfo
While (True)
Console.Write("Complete the transaction scope? [Y|N] ")
c = Console.ReadKey()
Console.WriteLine()
If (c.KeyChar = "Y") Or (c.KeyChar = "y") Then
scope.Complete()
Exit While
ElseIf ((c.KeyChar = "N") Or (c.KeyChar = "n")) Then
Exit While
End If
End While
End Using
Catch ex As TransactionException
Console.WriteLine(ex)
Catch
Console.WriteLine("Cannot complete transaction")
Throw
End Try
End Sub
End Class
Public Class EnlistmentClass
Implements IEnlistmentNotification
Public Sub Prepare(ByVal myPreparingEnlistment As PreparingEnlistment) Implements System.Transactions.IEnlistmentNotification.Prepare
Console.WriteLine("Prepare notification received")
'Perform transactional work
'If work finished correctly, reply with prepared
myPreparingEnlistment.Prepared()
End Sub
Public Sub Commit(ByVal myEnlistment As Enlistment) Implements System.Transactions.IEnlistmentNotification.Commit
Console.WriteLine("Commit notification received")
'Do any work necessary when commit notification is received
'Declare done on the enlistment
myEnlistment.Done()
End Sub
Public Sub Rollback(ByVal myEnlistment As Enlistment) Implements System.Transactions.IEnlistmentNotification.Rollback
Console.WriteLine("Rollback notification received")
'Do any work necessary when rollback notification is received
'Declare done on the enlistment
myEnlistment.Done()
End Sub
Public Sub InDoubt(ByVal myEnlistment As Enlistment) Implements System.Transactions.IEnlistmentNotification.InDoubt
Console.WriteLine("In doubt notification received")
'Do any work necessary when indout notification is received
'Declare done on the enlistment
myEnlistment.Done()
End Sub
End Class
static void Main(string[] args)
{
try
{
using (TransactionScope scope = new TransactionScope())
{
//Create an enlistment object
myEnlistmentClass myElistment = new myEnlistmentClass();
//Enlist on the current transaction with the enlistment object
Transaction.Current.EnlistVolatile(myElistment, EnlistmentOptions.None);
//Perform transactional work here.
//Call complete on the TransactionScope based on console input
ConsoleKeyInfo c;
while(true)
{
Console.Write("Complete the transaction scope? [Y|N] ");
c = Console.ReadKey();
Console.WriteLine();
if ((c.KeyChar == 'Y') || (c.KeyChar == 'y'))
{
scope.Complete();
break;
}
else if ((c.KeyChar == 'N') || (c.KeyChar == 'n'))
{
break;
}
}
}
}
catch (System.Transactions.TransactionException ex)
{
Console.WriteLine(ex);
}
catch
{
Console.WriteLine("Cannot complete transaction");
throw;
}
}
class myEnlistmentClass : IEnlistmentNotification
{
public void Prepare(PreparingEnlistment preparingEnlistment)
{
Console.WriteLine("Prepare notification received");
//Perform transactional work
//If work finished correctly, reply prepared
preparingEnlistment.Prepared();
// otherwise, do a ForceRollback
preparingEnlistment.ForceRollback();
}
public void Commit(Enlistment enlistment)
{
Console.WriteLine("Commit notification received");
//Do any work necessary when commit notification is received
//Declare done on the enlistment
enlistment.Done();
}
public void Rollback(Enlistment enlistment)
{
Console.WriteLine("Rollback notification received");
//Do any work necessary when rollback notification is received
//Declare done on the enlistment
enlistment.Done();
}
public void InDoubt(Enlistment enlistment)
{
Console.WriteLine("In doubt notification received");
//Do any work necessary when indout notification is received
//Declare done on the enlistment
enlistment.Done();
}
}
Оптимизация производительности
Класс Transaction также предоставляет метод EnlistPromotableSinglePhase для PSPE-зачисления. Это позволяет диспетчеру устойчивых ресурсов "владеть" и управлять транзакцией, которая затем при необходимости может быть повышена до транзакции MSDTC. Дополнительные сведения см. в разделе Оптимизация производительности с помощью механизмов уведомления об однофазной фиксации и повышаемого однофазного уведомления.
См. также
Основные понятия
Оптимизация производительности с помощью механизмов уведомления об однофазной фиксации и повышаемого однофазного уведомления
Однофазная и многофазная фиксация транзакции