《通過C#學Proto.Actor模型》之Behaviors

来源:https://www.cnblogs.com/axzxs2001/archive/2018/09/01/9569146.html
-Advertisement-
Play Games

Behaviors就是Actor接收到消息後可以改變處理的方法,相同的Actor,每次調用,轉到不同的Actor內方法執行,非常適合按流程進行的場景。Behaviors就通過在Actor內部實例化一個Behavior對象,然後通過這個對象的Become來切換執行的方法的。 ...


Behaviors就是Actor接收到消息後可以改變處理的方法,相同的Actor,每次調用,轉到不同的Actor內方法執行,非常適合按流程進行的場景。Behaviors就通過在Actor內部實例化一個Behavior對象,然後通過這個對象的Become來切換執行的方法的。

 碼友看碼:

 1 using Proto;
 2 using System;
 3 using System.Threading.Tasks;
 4 
 5 namespace P007_Behaviors
 6 {
 7     class Program
 8     {
 9         static void Main(string[] args)
10         {
11             var props = Actor.FromProducer(() => new LightBulb());
12             var pid = Actor.Spawn(props);
13             while (true)
14             {
15                 Console.WriteLine("----------------------------");
16                 Console.WriteLine("按開關");
17                 Console.ReadLine();
18                 var message = pid.RequestAsync<string>(new PressSwitch()).Result;
19                 Console.WriteLine(message);
20 
21                 message = pid.RequestAsync<string>(new Touch()).Result;
22                 Console.WriteLine(message);
23             }
24         }
25     }
26 
27     public class LightBulb : IActor
28     {
29         private readonly Behavior _behavior;
30 
31         public LightBulb()
32         {
33             _behavior = new Behavior();
34             //把Off方法放入棧
35             _behavior.BecomeStacked(Off);
36         }
37         public Task ReceiveAsync(IContext context)
38         {
39             //切換到behavior指定的方法,來充當ReceiveAsync
40             return _behavior.ReceiveAsync(context);
41         }
42         /// <summary>
43         ///44         /// </summary>
45         /// <param name="context"></param>
46         /// <returns></returns>
47         private Task Off(IContext context)
48         {
49             switch (context.Message)
50             {
51                 case PressSwitch _:
52                     context.Respond("打開");
53                     _behavior.Become(On);
54                     break;
55                 case Touch _:
56                     context.Respond("涼的");
57                     break;
58             }
59             return Actor.Done;
60         }
61         /// <summary>
62         ///63         /// </summary>
64         /// <param name="context"></param>
65         /// <returns></returns>
66         private Task On(IContext context)
67         {
68             switch (context.Message)
69             {
70                 case PressSwitch _:
71                     context.Respond("關閉");
72                     _behavior.Become(Off);
73                     break;
74                 case Touch _:
75                     context.Respond("燙手");
76                     break;
77             }
78             return Actor.Done;
79         }
80     }
81     class PressSwitch
82     { }
83     class Touch
84     { }
85 
86 }

幾個要點,在Actor構造中把Off放入方法棧,在Receive中調用Behavior的Receive,同時可以按自己業務邏輯切換方法,這樣在一定程度上增加了Actor的靈活性,讓一個Actor可以按設定流程實現不同行為。

Behavior提供了三個切換方法相關的方法:

  • Become只需將傳遞的Receive方法設置為當前方法,替換預設方法。
  • BecomeStacked將傳遞的Receive方法推送到方法堆棧,但保留以前的方法。
  • UnbecomeStacked 恢復到以前使用的方法。

看結果:


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 題意 $n$個食物,每個食物有一個滿意度,從中選出$m$個,使得滿意度最大 同時有$k$個關係:若$x_i$在$y_i$之前吃,則會獲得$C_i$的代價 Sol 官方題解是$O(2^n n^2)$的,不過我沒發現狀態之間的聯繫,就寫了一個$O(2^n n^3)$的,不過還是水過去了。 $f[i][j ...
  • 每天下班回家有時間就寫個小例子,一個月下來的成果,分享給大家學習~ 第一題 1、2、3、4個數字,能組成多少個互不相同且無重覆數字的三位數?都是多少? 程式分析: 可填在百位、十位、個位的數字都是1、2、3、4。組成所有的排列後再去掉不滿足條件的排列。 代碼: 第二題 企業發放的獎金根據利潤提成。利 ...
  • 不同於傳統集中時Springmvc 全局異常,具體查看前面的章節https://www.cnblogs.com/zwdx/p/8963311.html 對於springboot框架來講,這裡我就介紹一種 1、ExceptionHandlerAdvice 由於是前後端分離,所以使用@ResponseB ...
  • JDK中已經內置了Webservice發佈,不過要用Tomcat等Web伺服器發佈WebService,還需要用第三方Webservice框架。Axis2和CXF是目前最流行的Webservice框架,這兩個框架各有優點,不過都屬於重量級框架。 JAX-WS RI是JAX WebService參考實 ...
  • 題外話 複習多線程的知識,偶然看到一道題:如何正確的停止一個線程?我第一反應是使用stop()方法停止,操作以後發現stop已經被廢棄了。 經過查找資料,發現是使用interrupt()進行中斷標記然後在進行停止,特此寫這篇隨筆記錄一下。 stop()、suspend()的缺點 1.會導致一些清理工 ...
  • 今日內容介紹 1、File 2、遞歸 xmind:下載地址: 鏈接: "https://pan.baidu.com/s/1Eaj9yP5i0x4PiJsZA4StQg" 密碼:845a 01IO技術概述 A:IO技術概述 a: Output 把記憶體中的數據存儲到持久化設備上這個動作稱為輸出(寫)Ou ...
  • pass ...
  • 方式一:from django.views.decorators.csrf import csrf_exemptfrom django.utils.decorators import method_decoratorfrom django.views import Viewclass Goods_v ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...