私は、さまざまなデータ ソースからさまざまなデータ インポート ロジックを実行し、最終的に単一のターゲットである MS CRM インスタンスに書き込む Windows サービスを作成しています。現時点で唯一問題があると思うのは、CRM への書き込み部分です。異なる(場合によっては同じ)データソースからのデータの同時読み取りは、実際には問題になるべきではありません(これについては間違っているかもしれません...)そこで、同時書き込み(作成または更新)がないことを確認する方法を思いつきました) CRM に。
現時点での一般的な設計は次のとおりです。
サービスの開始時に何が起こるか:
Timers = new List<System.Timers.Timer>();
CrmTransactionQueue.Lock = new object { }; //Static class. The object for locking purposes...
System.Threading.Thread.Sleep(20000); //for debugging purpose so I can attach to process before everything kicks in...
//retrieve all types that are extending BaseSyncStrategy..
var strategyTypes = Assembly.GetExecutingAssembly().GetTypes().Where(x => x.BaseType == typeof(BaseSyncStrategy));
foreach (Type strategyType in strategyTypes)
{
//create a instance of that type....
var strategy = (BaseSyncStrategy)Activator.CreateInstance(strategyType);
//create a timer for each of these, they will have different intervals...
System.Timers.Timer t = new System.Timers.Timer
{
Interval = strategy.Interval * 1000,
AutoReset = false,
Enabled = true
};
Timers.Add(t);
t.Elapsed += (sender, e) => TimerElapsed(sender, e, strategy);
t.Start();
}
タイマーの間隔が切れるとどうなるか:
private void TimerElapsed(object sender, ElapsedEventArgs e, BaseSyncStrategy strategy)
{
//get timer back
var timer = (Timer)sender;
try
{
strategy.Execute();
}
catch (Exception ex)
{
Logger.WriteEntry(EventLogEntryType.Error, $"Error executing strategy {strategy.GetType().Name}: ", ex);
}
timer.Start();
}
そしてExecute
、オブジェクトを拡張するすべてのメソッド内BaseSyncStrategy
で、対象の CRM インスタンスで何かを更新または作成するたびに、次のようにします。
XrmServiceContext XrmCtx = new XrmServiceContext();
//....
//code that fetches data from foreign sources and creates CRM entities...
//....
Action<XrmServiceContext> action = (XrmServiceContext ctx) =>
{
//write those created/updated objects
//ctx lets me query entities and write back to CRM...
};
CrmTransactionQueue.Execute(action, XrmCtx);
そして、CRMへの同時書き込みが発生しないようにするための簡単なコード(と思います):
public static class CrmTransactionQueue
{
public static object Lock { get; set; }
public static void Execute(Action<XrmServiceContext> transaction, XrmServiceContext Ctx)
{
lock (Lock)
{
transaction.Invoke(Ctx);
}
}
}
これはサウンドデザインですか、それとももっと良い方法がありますか?