0

私は、さまざまなデータ ソースからさまざまなデータ インポート ロジックを実行し、最終的に単一のターゲットである 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);
        }
    }

}

これはサウンドデザインですか、それとももっと良い方法がありますか?

4

0 に答える 0