[关闭]
@aqa510415008 2019-03-27T11:43:57.000000Z 字数 2596 阅读 1125

Orleans MultiClient 多个Silo复合客户端

Orleans


介绍

Orleans.MultiClient 是一个 Orleans 复合客户端,只需要简单配置就可以简单高效连接和请求 Orleans 服务。
Orleans.MultiClient 可以轻松连接多个不同服务的 Orleans 服务,在请求 Orleans 时会根据请求的接口自动寻找 Orleans 客户端,使用者无需关心底层的实现。

Orleans.MultiClient 的开源地址和 Demo 可以在 GitHub 源代码下载查看。

https://github.com/AClumsy/Orleans.MultiClient/

使用

NuGet 下载 Orleans.MultiClient 包。

  1. dotnet add package Orleans.MultiClient

简单例子

如果有一个服务需要同时调用 AB 两个 Orleans 服务,看一看 Orleans.MultiClient 是怎么更简单的调用 Orleans 服务的。
第一步:先引用 Orleans.MultiClient 包和 AB 的接口,分别为 IHelloAIHelloB
第二步:需要把 Orleans.MultiClient 注入到 DI 容器 中,并且配置添加两个 Orleans Client。

提示:Orleans.MultiClient 暂时只支持 .NET Core 平台上面使用。

  1. services.AddOrleansMultiClient(build =>
  2. {
  3. build.AddClient(opt =>
  4. {
  5. opt.ServiceId = "A";
  6. opt.ClusterId = "AApp";
  7. opt.SetServiceAssembly(typeof(IHelloA).Assembly);
  8. opt.Configure = (b =>
  9. {
  10. b.UseLocalhostClustering();
  11. });
  12. });
  13. build.AddClient(opt =>
  14. {
  15. opt.ServiceId = "B";
  16. opt.ClusterId = "BApp";
  17. opt.SetServiceAssembly(typeof(IHelloB).Assembly);
  18. opt.Configure = (b =>
  19. {
  20. b.UseLocalhostClustering(gatewayPort: 30001);
  21. });
  22. });
  23. });

第二步:开始调用对应的 Orleans 服务。
IOrleansClient 是 Orleans.MultiClient 的复合客户端,通过 IOrleansClient 调用 Orleans 服务。

  1. // 调用 A 服务。
  2. var serviceA = _serviceProvider.GetRequiredService<IOrleansClient>().GetGrain<IHelloA>(1);
  3. var resultA = serviceA.SayHello("Hello World Success GrainA").GetAwaiter().GetResult();
  4. // 调用 B 服务。
  5. var serviceB = _serviceProvider.GetRequiredService<IOrleansClient>().GetGrain<IHelloB>(1);
  6. var resultB = serviceB.SayHello("Hello World Success GrainB").GetAwaiter().GetResult();

简单吧,只要配置好客户端之后,在使用的过程中,无需管怎么连接 Orleans ,只要通过依赖注入得到 IOrleansClient 就可以轻松的请求 Orleans 服务。

配置

注入到 DI 容器

AddOrleansMultiClient :把 Orleans.MultiClient 注入到 DI 容器 中,使用时需要通过依赖注入得到 IOrleansClient

添加多个 Client

AddClient: 添加多个 Orleans 客户客户端,添加客户端时需要配置 Orleans 相关选项。 Orleans.MultiClient 提供了函数和 IConfiguration 两种方式进行配置。
使用 IConfiguration 进行配置时需要注意配置文件的内容必须是 IList<OrleansClientOptions> 类型的。

  1. services.AddOrleansMultiClient(build =>
  2. {
  3. build.AddClient((OrleansClientOptions opt) =>{
  4. ...// OrleansClientOptions 配置
  5. }
  6. });

全局 Orleans 服务配置

Configure:如果所有的 Orleans 的连接配置是一样的情况下,可以配置全局的 Orleans 服务配置。
比如:如果所有的 Orleans Silo 都是通过 Consul 进行服务发现的,就可以配置一个全局配置。

  1. services.AddOrleansMultiClient(build =>{
  2. build.Configure(b =>{
  3. b.UseConsulClustering(o =>{
  4. o.Address = new Uri("https://127.0.0.1:8500");
  5. });
  6. });
  7. }

OrleansClientOptions 配置

添加新批注
在作者公开此批注前,只有你和作者可见。
回复批注