Orleans Szybki Start dotyczący strumieniowania

W tym przewodniku użyjesz strumienia opartego na pamięci, wykorzystującego komunikaty ziarniste do wysyłania danych do subskrybentów. Dostawca pamięci operacyjnej służy do przechowywania list subskrypcji. Korzystanie z mechanizmów opartych na pamięci w celu przesyłania strumieniowego i przechowywania jest przeznaczone tylko do lokalnego rozwoju i testowania, a nie dla środowisk produkcyjnych.

Na silosie, gdzie silo jest ISiloBuilder, wywołaj AddMemoryStreams:

silo.AddMemoryStreams("StreamProvider")
    .AddMemoryGrainStorage("PubSubStore");

Na kliencie klastra, gdzie client jest IClientBuilder, wywołaj AddMemoryStreams.

client.AddMemoryStreams("StreamProvider");

W tym przewodniku używamy prostego strumienia opartego na komunikatach, wykorzystując komunikaty ziarna do przesyłania danych strumienia do subskrybentów. Użyj dostawcy magazynu w pamięci do przechowywania list subskrypcji; nie jest to mądry wybór dla aplikacji produkcyjnych w rzeczywistym środowisku.

Na silosie, gdzie hostBuilder jest ISiloHostBuilder, wywołaj AddSimpleMessageStreamProvider:

hostBuilder.AddSimpleMessageStreamProvider("SMSProvider")
           .AddMemoryGrainStorage("PubSubStore");

Na kliencie klastra, gdzie clientBuilder jest IClientBuilder, wywołaj AddSimpleMessageStreamProvider.

clientBuilder.AddSimpleMessageStreamProvider("SMSProvider");

siloBuilder
    .AddSimpleMessageStreamProvider(
        "SMSProvider",
        options => options.OptimizeForImmutableData = false);

Tworzenie zdarzeń dla strumieni jest stosunkowo łatwe. Najpierw uzyskaj dostęp do dostawcy strumienia zdefiniowanego wcześniej w konfiguracji ("StreamProvider"), a następnie wybierz strumień i wypchnij do niego dane.

// Pick a GUID for a chat room grain and chat room stream
var guid = new Guid("some guid identifying the chat room");
// Get one of the providers which we defined in our config
var streamProvider = GetStreamProvider("StreamProvider");
// Get the reference to a stream
var streamId = StreamId.Create("RANDOMDATA", guid);
var stream = streamProvider.GetStream<int>(streamId);

Tworzenie zdarzeń dla strumieni jest stosunkowo łatwe. Najpierw uzyskaj dostęp do dostawcy strumienia zdefiniowanego wcześniej w konfiguracji ("SMSProvider"), a następnie wybierz strumień i wypchnij do niego dane.

// Pick a GUID for a chat room grain and chat room stream
var guid = new Guid("some guid identifying the chat room");
// Get one of the providers which we defined in our config
var streamProvider = GetStreamProvider("SMSProvider");
// Get the reference to a stream
var stream = streamProvider.GetStream<int>(guid, "RANDOMDATA");

// Create a GUID based on our GUID as a grain
var guid = this.GetPrimaryKey();

// Get one of the providers which we defined in config
var streamProvider = GetStreamProvider("StreamProvider");

// Get the reference to a stream
var streamId = StreamId.Create("RANDOMDATA", guid);
var stream = streamProvider.GetStream<int>(streamId);

// Set our OnNext method to the lambda which simply prints the data.
// This doesn't make new subscriptions, because we are using implicit
// subscriptions via [ImplicitStreamSubscription].
await stream.SubscribeAsync<int>(
    async (data, token) =>
    {
        Console.WriteLine(data);
        await Task.CompletedTask;
    });

// Create a GUID based on our GUID as a grain
var guid = this.GetPrimaryKey();

// Get one of the providers which we defined in config
var streamProvider = GetStreamProvider("SMSProvider");

// Get the reference to a stream
var stream = streamProvider.GetStream<int>(guid, "RANDOMDATA");

// Set our OnNext method to the lambda which simply prints the data.
// This doesn't make new subscriptions, because we are using implicit
// subscriptions via [ImplicitStreamSubscription].
await stream.SubscribeAsync<int>(
    async (data, token) =>
    {
        Console.WriteLine(data);
        await Task.CompletedTask;
    });