1     public class TransferEvent : DomainEvent  //转帐消息
  2     {
  3         public TransferEvent(Guid fromBankAccountId, Guid toBankAccountId, double moneyAmount, DateTime transferDate)
  4         {
  5             this.FromBankAccountId = fromBankAccountId;
  6             this.ToBankAccountId = toBankAccountId;
  7             this.MoneyAmount = moneyAmount;
  8             this.TransferDate = transferDate;
  9         }
 10         public Guid FromBankAccountId { get; private set; }
 11         public Guid ToBankAccountId { get; private set; }
 12         public double MoneyAmount { get; private set; }
 13         public DateTime TransferDate { get; private set; }
 14     }
 15     public class BankAccount : DomainObject<Guid>  //银行帐号类
 16     {
 17         #region Private Variables
 18 
 19         private List<TransferHistory> transferHistories;
 20 
 21         #endregion
 22 
 23         #region Constructors
 24 
 25         public BankAccount(Guid customerId)
 26             : this(customerId, 0D, new List<TransferHistory>())
 27         {
 28         }
 29         public BankAccount(Guid customerId, double moneyAmount, IEnumerable<TransferHistory> transferHistories)
 30             : base(Guid.NewGuid())
 31         {
 32             this.CustomerId = customerId;
 33             this.MoneyAmount = moneyAmount;
 34             this.transferHistories = new List<TransferHistory>(transferHistories);
 35         }
 36 
 37         #endregion
 38 
 39         #region Public Properties
 40 
 41         public Guid CustomerId { get; private set; }
 42         [TrackingProperty]
 43         public IEnumerable<TransferHistory> TransferHistories
 44         {
 45             get
 46             {
 47                 return transferHistories.AsReadOnly();
 48             }
 49         }
 50         [TrackingProperty]
 51         public double MoneyAmount { get; private set; }
 52 
 53         #endregion
 54 
 55         #region Event Handlers
 56 
 57         private void TransferTo(TransferEvent evnt)  //源帐号响应转帐消息（做转出钱的操作）
 58         {
 59             if (this.Id == evnt.FromBankAccountId)
 60             {
 61                 DecreaseMoney(evnt.MoneyAmount);
 62                 transferHistories.Add(
 63                     new TransferHistory(
 64                         evnt.FromBankAccountId,
 65                         evnt.ToBankAccountId,
 66                         evnt.MoneyAmount,
 67                         evnt.TransferDate));
 68             }
 69         }
 70         private void TransferFrom(TransferEvent evnt)  //目标帐号响应转帐消息（做转入钱的操作）
 71         {
 72             if (this.Id == evnt.ToBankAccountId)
 73             {
 74                 IncreaseMoney(evnt.MoneyAmount);
 75                 transferHistories.Add(
 76                     new TransferHistory(
 77                         evnt.FromBankAccountId,
 78                         evnt.ToBankAccountId,
 79                         evnt.MoneyAmount,
 80                         evnt.TransferDate));
 81             }
 82         }
 83 
 84         #endregion
 85 
 86         #region Private Methods
 87 
 88         private void DecreaseMoney(double moneyAmount)
 89         {
 90             if (this.MoneyAmount < moneyAmount)
 91             {
 92                 throw new NotSupportedException("账户余额不足。");
 93             }
 94             this.MoneyAmount -= moneyAmount;
 95         }
 96         private void IncreaseMoney(double moneyAmount)
 97         {
 98             this.MoneyAmount += moneyAmount;
 99         }
100 
101         #endregion
102     }
103     public class TransferHistory : ValueObject //转帐记录，是一个值对象
104     {
105         #region Constructors
106 
107         public TransferHistory(Guid fromAccountId,
108                                Guid toAccountId,
109                                double moneyAmount,
110                                DateTime transferDate)
111         {
112             this.FromAccountId = fromAccountId;
113             this.ToAccountId = toAccountId;
114             this.MoneyAmount = moneyAmount;
115             this.TransferDate = transferDate;
116         }
117 
118         #endregion
119 
120         #region Public Properties
121 
122         public Guid FromAccountId { get; private set; }
123         public Guid ToAccountId { get; private set; }
124         public double MoneyAmount { get; private set; }
125         public DateTime TransferDate { get; private set; }
126 
127         #endregion
128 
129         #region Infrastructure
130 
131         protected override IEnumerable<object> GetAtomicValues()
132         {
133             yield return FromAccountId;
134             yield return ToAccountId;
135             yield return MoneyAmount;
136             yield return TransferDate;
137         }
138 
139         #endregion
140     }

//创建消息和发送消息的代码：
EventProcesser.ProcessEvent(new TransferEvent(bankAccount1.Id, bankAccount2.Id, 1000, DateTime.Now));

//创建关系并将关系告诉关系引擎的代码：
RegisterObjectEventMappingItem<TransferEvent, BankAccount>(
 2         new GetDomainObjectIdEventHandlerInfo<TransferEvent>
 3         {
 4             GetDomainObjectId = evnt => evnt.FromBankAccountId, //告诉框架源银行帐号对象是根据消息的FromBankAccountId作为唯一标识来获取的
 5             EventHandlerName = "TransferTo"  //告诉响应的方法
 6         },
 7         new GetDomainObjectIdEventHandlerInfo<TransferEvent>
 8         {
 9             GetDomainObjectId = evnt => evnt.ToBankAccountId, //告诉框架目标银行帐号对象是根据消息的ToBankAccountId作为唯一标识来获取的
10             EventHandlerName = "TransferFrom" //告诉响应的方法
11         }
12     );