Azure Service Fabric の SDK が公開されていた

Visual Studio 2015 RCが必須です。

ちょっとだけ雑感

Choosing a framework

Reliable Actors APIs と Reliable Services APIs のどちらかを選択する。

Azure Service Fabric Actors Overview

Actor の並行性がこんな感じ。

f:id:nnasaki:20150430141336p:plain

Getting Started with Microsoft Azure Service Fabric Reliable Actors

Hello, World サンプルコードがこんな感じ。先ほどの図の通り、だいぶ非同期満載です。

namespace HelloWorld
{
    public class HelloWorld : Actor, IHelloWorld
    {
        public Task<string> SayHello(string greeting)
        {
            return Task.FromResult("You said: '" + greeting + "', I say: Hello Actors!");
        }
    }
}

Overview of the Service Fabric Reliable Service Programming Model

ステートレスかステートフルかを選ぶ

Getting Started with Microsoft Azure Service Fabric Reliable Services
- ステートレスの場合

まぁまぁ、シンプル。ServiceEventSource ってのよくわからないけど、キューみたいなのかな。

protected override async Task RunAsync(CancellationToken cancellationToken)
{
    // TODO: Replace the following with your own logic.

    int iterations = 0;
    while (!cancellationToken.IsCancellationRequested)
    {
        ServiceEventSource.Current.ServiceMessage(this, "Working-{0}", iterations++);
        await Task.Delay(TimeSpan.FromSeconds(1), cancellationToken);
    }
}

− ステートフルの場合

protected override async Task RunAsync(CancellationToken cancellationToken)
{
    // TODO: Replace the following with your own logic.
    IReliableDictionary<string, long>  myDictionary = await this.StateManager.GetOrAddAsync<IReliableDictionary<string, long>>("myDictionary");

    while (!cancellationToken.IsCancellationRequested)
    {
        using (ITransaction tx = this.StateManager.CreateTransaction())
        {
            var result = await myDictionary.TryGetValueAsync(tx, "Counter-1");
            ServiceEventSource.Current.ServiceMessage(
                this,
                "Current Counter Value: {0}",
                result.HasValue ? result.Value.ToString() : "Value does not exist.");

            await myDictionary.AddOrUpdateAsync(tx, "Counter-1", 0, (k, v) => ++v);

            await tx.CommitAsync();
        }

        await Task.Delay(TimeSpan.FromSeconds(1), cancellationToken);
    }
}

IReliableDictionary という Reliable Collections が違うっぽい。ここにステートを保存する。

気になるステートの保存先はService Fabric の local disk？だけど、各ノードを横断的に保存するから信頼性が高いとか。