다음을 통해 공유

방법: CRM(리소스 보상 관리자) 만들기

  • 아티클

코드 예제

COM+로 제공되는 CRM(리소스 보상 관리자)을 사용하면 Microsoft DTC(Distributed Transaction Coordinator) 트랜잭션에 비트랜잭션 개체를 포함할 수 있습니다. CRM이 완전한 리소스 관리자 기능을 제공하지는 않지만 전체 과정이 완료되지 않으면 아무 작업도 수행되지 않는 트랜잭션 원자성 및 복구 로그를 통한 영속성을 제공합니다.

리소스 보상 관리자를 만들려면

  1. EnterpriseServices 및 CompensatingResourceManager 네임스페이스를 가져옵니다.

    Imports System.EnterpriseServices
Imports System.EnterpriseServices.CompensatingResourceManager

    using System.EnterpriseServices;
using System.EnterpriseServices.CompensatingResourceManager;

  2. 어셈블리에 대해 CRM 지원을 사용합니다.

    <assembly: ApplicationCrmEnabled>

    [assembly: ApplicationCrmEnabled]

  3. ServicedComponent 클래스에서 파생되는 CRM Worker 클래스를 정의합니다. 예를 들어, 다음 코드에서는 ServicedComponent에서 직접 파생되는 CRMWorker 클래스를 보여 줍니다.

    <Transaction> Public Class CRMWorker
      Inherits Servicedcomponent

End Class

    [Transaction]
public class CRMWorker:ServicedComponent
{
}

  4. Clerk 개체를 만들고 트랜잭션을 커밋하거나 중단하는 public 메서드를 구현합니다. 이 메서드는 Clerk 개체를 사용하여 CRM 로그를 업데이트해야 합니다. 예를 들어, 다음 코드에서는 CRM 로그를 업데이트하고 트랜잭션을 커밋하거나 중단하는 CRMMethod 메서드를 보여 줍니다.

    Public Sub CRMMethod(filename As String, bCommit As Boolean)
     ' Create the clerk object.
     Dim myclerk As Clerk=New Clerk(GetType(CRMCompensator), _
               "CRMCompensator", CompensatorOptions.AllPhases)
     myclerk.WriteLogRecord(filename)
     myclerk.ForceLog()
     If bCommit=true Then
         ContextUtil.SetComplete()
     Else
         ContextUtil.SetAbort()
     End If
End Sub

    public void CRMMethod(string fileName, bool bCommit)
{
      // Create clerk object.
      Clerk clerk = new Clerk(typeof(CRMCompensator), 
                            "CRMCompensator",
                            CompensatorOptions.AllPhases);
      clerk.WriteLogRecord(fileName);
      clerk.ForceLog();
      if (bCommit)
           ContextUtil.SetComplete();
      else
           ContextUtil.SetAbort();
      }

  5. Compensation 클래스에서 파생되는 클래스를 정의합니다.

    JustInTimeActivation()
Public Class CRMCompensator
        Inherits Compensator
End Class

    [JustInTimeActivation]
public class CRMCompensator:Compensator
{
}
Note참고:

Compensator에 JustInTimeActivation 특성을 적용해야 합니다. 그렇지 않으면 중단이 두 번 호출됩니다.

  1. Compensator 클래스의 BeginPrepare, PrepareRecord, EndPrepare, BeginCommit, CommitRecord, EndCommit, BeginAbort, AbortRecord 및 EndAbort 멤버를 재정의합니다.

  2. CRM Worker 및 Compensator 구성 요소를 테스트하는 클라이언트 응용 프로그램을 만듭니다.

    1. System.EnterpriseServices와 같은 필요한 이름과 CRM Worker 및 Compensator 클래스를 구현하는 네임스페이스를 가져옵니다.

      Imports System
Imports System.IO
Imports System.EnterpriseServices
Imports CrmServer
Imports System.Runtime.InteropServices

      using System;
using System.IO;
using System.EnterpriseServices;
using CrmServer;
using System.Runtime.InteropServices;

    2. 클래스를 정의하고 Main 메서드를 구현하여 CRM Worker 클래스의 인스턴스를 만든 다음 CRM Clerk 개체를 만드는 해당 메서드를 호출합니다. 예를 들어, 다음 코드에서는 CRMWorker 형식의 개체를 만들고 CRMMethod 메서드를 호출하여 CRM Clerk 개체를 만듭니다.

      Public Class CRM
    Public Shared Sub Main()                        
       dim logfilename As String = "crm.log"
       Console.WriteLine("Creating a managed CRM worker"+ _ 
                                             "object...")
       dim crmworker As CRMWorker = new CRMWorker()
       Console.WriteLine("Demonstrating a worker commit...")
       crmworker.CRMMethod(logfilename, True)
       Console.WriteLine("Demonstrating a worker abort...")
       crmworker.CRMMethod(logfilename, False)
       Console.WriteLine("DONE!")
    End Sub
End Class

      class CRM
{
    public static int Main()
    { 
       string logfilename = "crm.log";
       Console.WriteLine("Creating a managed CRM worker 
                                          object...");
       CRMWorker crmworker = new CRMWorker();
       Console.WriteLine("Demonstrating a worker commit...");
       crmworker.CRMMethod(logfilename, true);
       Console.WriteLine("Demonstrating a worker abort...");
       crmworker.CRMMethod(logfilename, false);
       Console.WriteLine("DONE!");
       return 0;   
    }
}

  3. 강력한 키를 생성하고 다음 예제를 컴파일합니다.

    sn –k crm.key
vbc /t:library /r:System.EnterpriseServices.dll crm.vb
vbc /r:crm.dll /r:System.EnterpriseServices.dll crmclient.vb

    sn –k crm.key
csc /t:library /r:System.EnterpriseServices.dll crm.cs
csc /r:crm.dll crmclient.cs

예제

Imports System
Imports System.IO
Imports System.Reflection
Imports System.EnterpriseServices
Imports System.EnterpriseServices.CompensatingResourceManager

<assembly: ApplicationActivation(ActivationOption.Server)>
<assembly: ApplicationCrmEnabled>
<assembly: AssemblyKeyFile("crm.key")>

Namespace CrmServer
' Create a Worker class.
<Transaction> Public Class CRMWorker
    Inherits Servicedcomponent
          Public Sub CRMMethod(filename As String, bCommit As Boolean)
              ' Create the clerk object.
              Dim myclerk As Clerk=New Clerk(GetType(CRMCompensator), _ 
                        "CRMCompensator", CompensatorOptions.AllPhases)
              myclerk.WriteLogRecord(filename)
              myclerk.ForceLog()
              If bCommit=true Then
                    ContextUtil.SetComplete()
              Else
                    ContextUtil.SetAbort()
              End If
        End Sub
    End Class

    ' Create a class derived from the Compensator class.
    JustInTimeActivation()
    Public Class CRMCompensator
      Inherits Compensator
            Dim bBeginPrepareCalled As Boolean = False
            Dim bPrepareRecordCalled As Boolean = False
            Dim bBeginCommitCalled As Boolean = False
            Dim bCommitRecordCalled As Boolean = False
            Dim bBeginAbortCalled As Boolean = False
            Dim bAbortRecordCalled As Boolean = False
            Dim _filename as String

            Public Overrides Sub BeginPrepare()
                  bBeginPrepareCalled = True
            End Sub

            Public Overrides Function PrepareRecord(rec As LogRecord) _
                                                           As Boolean
                  dim o as Object = rec.Record
                  _fileName = o.ToString()
                  bPrepareRecordCalled = True
                  Return False
            End Function

            Public Overrides Function EndPrepare() As Boolean
                  if not bBeginPrepareCalled then Return False   

                  if not bPrepareRecordCalled then Return False
                  if _fileName="" then Return False
                  ' This is a Prepare Phase success.
                  Return True
            End Function

            Public Overrides Sub BeginCommit(fRecovery As Boolean)
                  bBeginCommitCalled = True
            End Sub

            Public Overrides Function CommitRecord(rec As LogRecord) _
                                                          As Boolean
                  bCommitRecordCalled = True
                  Return True
            End Function

            Public Overrides Sub EndCommit()
                  if not bBeginCommitCalled then Return 
                  if not bCommitRecordCalled then Return 
                  if _fileName="" then Return 
                  ' This is a Commit Phase success.
            End Sub

            Public Overrides Sub BeginAbort(fRecovery As Boolean)
                  bBeginAbortCalled = True
            End Sub
            
            Public Overrides Function AbortRecord(rec As LogRecord) _
                                                          As Boolean
                  bAbortRecordCalled = True
                  dim o as Object = rec.Record
                  _fileName = o.ToString()
                  Return True
            End Function

            Public Overrides Sub EndAbort()
                  if not bBeginAbortCalled then Return 
                  if not bAbortRecordCalled then Return 
                  if _fileName="" then Return
                  ' This is an Abort Phase success.
            End Sub
      End Class
End Namespace
      
      

using System;
using System.IO;
using System.Reflection;
using System.EnterpriseServices;
using System.EnterpriseServices.CompensatingResourceManager;

[assembly: ApplicationActivation(ActivationOption.Server)]
[assembly: ApplicationCrmEnabled]
[assembly: AssemblyKeyFile("crm.key")]

namespace CrmServer 
{
      [Transaction]
      // Create a Worker class.
      public class CRMWorker:ServicedComponent
      {
            public void CRMMethod(string fileName, bool bCommit)
            {
                  // Create clerk object.
                  Clerk clerk = new Clerk(typeof(CRMCompensator),
                       "CRMCompensator", CompensatorOptions.AllPhases);
                  clerk.WriteLogRecord(fileName);
                  clerk.ForceLog();
                  if (bCommit)
                        ContextUtil.SetComplete();
                  else
                        ContextUtil.SetAbort();
            }
      
      }
      // Create class derived from Compensator class.
      [JustInTimeActivation]
      public class CRMCompensator:Compensator
      {
            bool bBeginPrepareCalled = false;
            bool bPrepareRecordCalled = false;
            bool bBeginCommitCalled = false;
            bool bCommitRecordCalled = false;
            bool bBeginAbortCalled = false;
            bool bAbortRecordCalled = false;
      
            String _fileName;
      
            public override void BeginPrepare()
            {
                  bBeginPrepareCalled = true;
            }
      
            public override bool PrepareRecord(LogRecord rec)
            {
                  Object o = rec.Record;
                  _fileName = o.ToString();
                  bPrepareRecordCalled = true;
                  return false;
            }
      
            public override bool EndPrepare()
            {
                  if (!bBeginPrepareCalled)
                  {return false;}   
                  if (!bPrepareRecordCalled)
                  {return false;}   
                  if (_fileName==null)
                  {return false;}
                  // This is a Prepare Phase success.
                  return true;
            }
      
            public override void BeginCommit(bool fRecovery)
            {
                  bBeginCommitCalled = true;
            }
      
            public override bool CommitRecord(LogRecord rec)
            {
                  bCommitRecordCalled = true;
                  return true;
            }
      
            public override void EndCommit()
            {
                  if (!bBeginCommitCalled)
                  {return;}   
                  if (!bCommitRecordCalled)
                  {return;}
                  if (_fileName==null)
                  {return;}
                  // This is a Commit Phase success.
            }
      
            public override void BeginAbort(bool fRecovery)
            {
                  bBeginAbortCalled = true;
            }
      
            public override bool AbortRecord(LogRecord rec)
            {
                  bAbortRecordCalled = true;
                  Object o = rec.Record;
                  _fileName = o.ToString();
                  return true;
            }
      
            public override void EndAbort()
            {
                  if (!bBeginAbortCalled)
                  {return;}   
                  if (!bAbortRecordCalled)
                  {return;}               
                  if (_fileName==null)
                  {return;}
                  // This is an Abort Phase success.
            }
      
      }

}

참고 항목

참조

System.EnterpriseServices Namespace

개념

사용 가능한 COM+ 서비스 요약

Footer image

Copyright © 2007 by Microsoft Corporation. All rights reserved.