Layanan Biji-Bijian

Layanan Biji-Bijian dapat diakses dari jarak jauh, layanan yang dipartisi untuk mendukung butir fungsionalitas. Setiap instans layanan biji-bijian bertanggung jawab atas beberapa set biji-bijian dan biji-bijian tersebut bisa mendapatkan referensi ke layanan biji-bijian yang saat ini bertanggung jawab untuk melayani mereka dengan menggunakan GrainServiceClient.

Grain Services ada untuk mendukung kasus di mana tanggung jawab untuk melayani biji-bijian harus didistribusikan di Orleans sekitar kluster. Misalnya, Orleans Pengingat diimplementasikan menggunakan layanan biji-bijian: setiap silo bertanggung jawab untuk menangani operasi pengingat untuk subset biji-bijian dan memberi tahu biji-bijian tersebut saat pengingat mereka diaktifkan.

Layanan Biji-Bijian dikonfigurasi pada silo dan diinisialisasi ketika silo dimulai, sebelum silo menyelesaikan inisialisasi. Mereka tidak dikumpulkan ketika menganggur dan sebaliknya memiliki masa pakai yang memperpanjang masa pakai silo itu sendiri.

Membuat GrainService

GrainService adalah biji-bijian khusus; yang tidak memiliki identitas stabil, dan berjalan di setiap silo dari startup ke shutdown. Ada beberapa langkah yang terlibat saat mengimplementasikan antarmuka IGrainService.

1. Tentukan antarmuka komunikasi layanan biji-bijian. Antarmuka dibangun GrainService menggunakan prinsip yang sama yang akan Anda gunakan untuk membangun antarmuka biji-bijian.

   public interface IDataService : IGrainService
   {
       Task MyMethod();
   }
   

2. DataService Buat layanan biji-bijian. Ada baiknya untuk mengetahui bahwa Anda juga dapat menginjeksi IGrainFactory, sehingga Anda dapat melakukan panggilan butir dari GrainService Anda.

   [Reentrant]
   public class DataService : GrainService, IDataService
   {
       readonly IGrainFactory _grainFactory;
   
       public DataService(
           IServiceProvider services,
           GrainId id,
           Silo silo,
           ILoggerFactory loggerFactory,
           IGrainFactory grainFactory)
           : base(id, silo, loggerFactory)
       {
           _grainFactory = grainFactory;
       }
   
       public override Task Init(IServiceProvider serviceProvider) =>
           base.Init(serviceProvider);
   
       public override Task Start() => base.Start();
   
       public override Task Stop() => base.Stop();
   
       public Task MyMethod()
       {
           // TODO: custom logic here.
           return Task.CompletedTask;
       }
   }
   

   [Reentrant]
   public class DataService : GrainService, IDataService
   {
       readonly IGrainFactory _grainFactory;
   
       public DataService(
           IServiceProvider services,
           IGrainIdentity id,
           Silo silo,
           ILoggerFactory loggerFactory,
           IGrainFactory grainFactory)
           : base(id, silo, loggerFactory)
       {
           _grainFactory = grainFactory;
       }
   
       public override Task Init(IServiceProvider serviceProvider) =>
           base.Init(serviceProvider);
   
       public override Task Start() => base.Start();
   
       public override Task Stop() => base.Stop();
   
       public Task MyMethod()
       {
           // TODO: custom logic here.
           return Task.CompletedTask;
       }
   }
   

3. Buat antarmuka untuk GrainServiceClient<TGrainService>GrainServiceClient supaya digunakan oleh butir lain untuk terhubung ke GrainService.

   public interface IDataServiceClient : IGrainServiceClient<IDataService>, IDataService
   {
   }
   

1. Injeksi klien layanan butir ke dalam butir lain yang membutuhkannya. GrainServiceClient tidak dijamin untuk mengakses GrainService pada silo lokal. Perintah Anda berpotensi dikirim ke GrainService pada silo apa pun di dalam kluster.

   public class MyNormalGrain: Grain<NormalGrainState>, INormalGrain
   {
       readonly IDataServiceClient _dataServiceClient;
   
       public MyNormalGrain(
           IGrainActivationContext grainActivationContext,
           IDataServiceClient dataServiceClient) =>
               _dataServiceClient = dataServiceClient;
   }
   

2. Konfigurasikan layanan biji-bijian dan klien layanan biji-bijian di silo. Anda perlu melakukan ini, sehingga silo akan memulai GrainService.

   (ISiloHostBuilder builder) =>
       builder.ConfigureServices(
           services => services.AddGrainService<DataService>()
                               .AddSingleton<IDataServiceClient, DataServiceClient>());
   

Catatan tambahan

Ada metode GrainServicesSiloBuilderExtensions.AddGrainService ekstensi yang digunakan untuk mendaftarkan layanan biji-bijian.

services.AddSingleton<IGrainService>(
    serviceProvider => GrainServiceFactory(grainServiceType, serviceProvider));

Silo mengambil IGrainService jenis dari penyedia layanan saat memulai: orleans/src/Orleans. Runtime/Silo/Silo.cs

var grainServices = this.Services.GetServices<IGrainService>();

Agar ini berfungsi, Anda harus mendaftarkan layanan dan juga kliennya. Kode terlihat seperti ini:

var builder = new HostBuilder()
    .UseOrleans(c =>
    {
        c.AddGrainService<DataService>()  // Register GrainService
        .ConfigureServices(services =>
        {
            // Register Client of GrainService
            services.AddSingleton<IDataServiceClient, DataServiceClient>();
        });
    })