.Net core使用XRPC建立遠程接口的Actor對象

時間 2019-11-25

標籤 core 使用 xrpc 建立遠程接口 actor 對象简体版

原文原文鏈接

Actor是一種高併發處理模型，每一個Actor都有着本身的狀態有序消息處理機制，因此在業務處理的狀況並不須要制定鎖的機制，從而達到更高效的處理能性。XRPC是一個基於遠程接口調用的RPC組件，它能夠簡單地實現高性能的遠程接口調用；XRPC在建立遠程接口時是支持針對接口建立對應的Actor實例。當建立接口Actor後，全部Client針對這一例實例Actor的全部方法調用都是有序處理。如下介紹如何在XRPC建立並使用Actorgit

什麼場景適用於`Actor`

既然每一個Actor都有着本身的狀態和順序處理機制，那能夠針對這優勢進行相關業務的展開；在棋牌遊戲中的桌子能夠是一個Actor,車票裏的每一輛車能夠是一個Actor,秒殺裏的每一種商品是一個Actor。在這些Actor全部的操做都是有序進行，不存在鎖，也不須要事務（經過EventSourcing來保障）和不會產生死鎖；數據變動全內存操做，經過這樣能夠大提升業務的處理性能。github

引用XRPC

Install-Package BeetleX.XRPC

定義`Actor`的RPC服務

XRPC支持的Actor服務功能是創建在EventNext之上，它的好處是直接接口行爲的Actor建立，而不是傳統的消息加接收方法，這樣在應用設計和調用上也是很是方便靈活。接下來定義一個簡單的Actor服務安全

接口定義

1   public interface IAmountService
2   {
3       Task<int> Income(int amount);
4       Task<int> Payout(int amount);
5       Task<int> Get();
6   }

以上是一個簡單的賬記變動行爲接口

實現接口併發

 1   [Service(typeof(IAmountService))]
 2   public class AmountService : ActorState, IAmountService
 3   {
 4 
 5       private int mAmount;
 6 
 7       public override Task ActorInit(string id)
 8       {
 9           return base.ActorInit(id);
10       }
11 
12       public Task<int> Get()
13       {
14           return mAmount.ToTask();
15       }
16 
17       public Task<int> Income(int amount)
18       {
19           mAmount += amount;
20           return mAmount.ToTask();
21       }
22 
23       public Task<int> Payout(int amount)
24       {
25           mAmount -= amount;
26           return mAmount.ToTask();
27       }
28   }

啓動對應的RPC服務async

      private static XRPCServer mXRPCServer;

      static void Main(string[] args)
      {
          mXRPCServer = new XRPCServer();
          mXRPCServer.ServerOptions.LogLevel = LogType.Error;
          mXRPCServer.Register(typeof(Program).Assembly);
          mXRPCServer.Open();
          Console.Read();
      }

以上代碼是在默認端口9090上綁定RPC服務，能夠經過運行日誌查看服務啓動狀況ide

建立遠程`Actor`調用

建立RPC Client
```
1 client = new XRPCClient("192.168.2.18", 9090);
2 client.Connect();
```
以上代碼是建立一個RPC客戶端，經過它的Create能夠建立接口代理
建立接口Actor實例
```
IAmountService henry = client.Create<IAmountService>("henry");
IAmountService ken = client.Create<IAmountService>("ken");
```
以上是針對IAmountService建立了兩個Actor對象，這兩個對象的操做都是相互隔離互不干擾；每一個Actor對象中的方法在併發下都是有序執行，並不會產生線程安全問題，因此在不一樣方法中操做對像的數據成員都不須要鎖來保證數據安全性。

測試

爲了更好地驗證Actor的隔離和併發安全性，簡單地併發測試一下高併發

 1             for (int i = 0; i < concurrent; i++)
 2             {
 3                 var task = Task.Run(async () =>
 4                 {
 5                     for (int k = 0; k < requests; k++)
 6                     {
 7                         await henry.Income(10);
 8                         System.Threading.Interlocked.Increment(ref mCount);
 9                     }
10                 });
11                 tasks.Add(task);
12                 task = Task.Run(async () =>
13                 {
14                     for (int k = 0; k < requests; k++)
15                     {
16                         await henry.Payout(10);
17                         System.Threading.Interlocked.Increment(ref mCount);
18                     }
19                 });
20                 tasks.Add(task);
21                 task = Task.Run(async () =>
22                 {
23                     for (int k = 0; k < requests; k++)
24                     {
25                         await ken.Income(10);
26                         System.Threading.Interlocked.Increment(ref mCount);
27                     }
28                 });
29                 tasks.Add(task);
30                 task = Task.Run(async () =>
31                 {
32                     for (int k = 0; k < requests; k++)
33                     {
34                         await ken.Payout(10);
35                         System.Threading.Interlocked.Increment(ref mCount);
36                     }
37                 });
38                 tasks.Add(task);
39             }
40             await Task.WhenAll(tasks.ToArray());
41             double useTime = EventCenter.Watch.ElapsedMilliseconds - start;
42             Console.WriteLine($"Completed count:{mCount}|use time:{useTime}|rps:{(mCount / useTime * 1000d):###.00} |henry:{await henry.Get()},ken:{await ken.Get()}");