ET介紹——Actor Location

来源:https://www.cnblogs.com/flamesky/archive/2023/05/19/17414892.html
-Advertisement-
Play Games

Actor Location Actor模型只需要知道對方的InstanceId就能發送消息,十分方便,但是有時候我們可能無法知道對方的InstanceId,或者是一個Actor的InstanceId會發生變化。這種場景很常見,比如:很多游戲是分線的,一個玩家可能從1線換到2線,還有的游戲是分場景的 ...


Actor Location

Actor模型只需要知道對方的InstanceId就能發送消息,十分方便,但是有時候我們可能無法知道對方的InstanceId,或者是一個Actor的InstanceId會發生變化。這種場景很常見,比如:很多游戲是分線的,一個玩家可能從1線換到2線,還有的游戲是分場景的,一個場景一個進程,玩家從場景1進入到場景2。因為做了進程遷移,玩家對象的InstanceId也就變化了。ET提供了給這類對象發送消息的機制,叫做Actor Location機制。其原理比較簡單:

  1. 因為InstanceId是變化的,對象的Entity.Id是不變的,所以我們首先可以想到使用Entity.Id來發送actor消息
  2. 提供一個位置進程(Location Server),Actor對象可以將自己的Entity.Id跟InstanceId作為kv存到位置進程中。發送Actor消息前先去位置進程查詢到Actor對象的InstanceId再發送actor消息。
  3. Actor對象在一個進程創建時或者遷移到一個新的進程時,都需要把自己的Id跟InstanceId註冊到Location Server上去
  4. 因為Actor對象是可以遷移的,消息發過去有可能Actor已經遷移到其它進程上去了,所以發送Actor Location消息需要提供一種可靠機制
  5. ActorLocationSender提供兩種方法,Send跟Call,Send一個消息也需要接受者返回一個消息,只有收到返回消息才會發送下一個消息。
  6. Actor對象如果遷移走了,這時會返回Actor不存在的錯誤,發送者收到這個錯誤會等待1秒,然後重新去獲取Actor的InstanceId,然後重新發送,目前會嘗試5次,5次過後,拋出異常,報告錯誤
  7. ActorLocationSender發送消息不會每次都去查詢Location Server,因為對象遷移畢竟比較少見,只有第一次去查詢,之後緩存InstanceId,以後發送失敗再重新查詢。
  8. Actor對象在遷移過程中,有可能其它進程發送過來消息,這時會發生錯誤,所以location server提供了一種Lock的機制。對象在傳送前,刪掉在本進程的信息,然後在location server上加上鎖,一旦鎖上後,其它的對該key的請求會進行隊列。
  9. 傳送前因為對方刪除了本進程的actor,所以其它進程會發送失敗,這時候他們會進行重試。重試的時候會重新請求location server,這時候會發現被鎖了,於是一直等待
  10. 傳送完成後,要unlock location server上的鎖,並且更新新的地址,然後響應其它的location請求。其它發給這個actor的請求繼續進行下去。

註意,Actor模型是純粹的服務端消息通信機制,跟客戶端是沒什麼關係的,很多用ET的新人看到ET客戶端消息也有Actor介面,以為這是客戶端跟服務端通信的機制,其實不是的。ET客戶端使用這個Actor完全是因為Gate需要對客戶端消息進行轉發,我們可以正好利用服務端actor模型來進行轉發,所以客戶端有些消息也是繼承了actor的介面。假如我們客戶端不使用actor介面會怎麼樣呢?比如,Frame_ClickMap這個消息

message Frame_ClickMap // IActorLocationMessage
{
    int64 ActorId = 93;
    int64 Id = 94;
    
    float X = 1;
    float Y = 2;
    float Z = 3;
}

 

我們可能就不需要ActorId這個欄位,消息發送到Gate,gate看到是Frame_ClickMap消息,它需要轉發給Map上的Unit,轉發還好辦,gate可以從session中獲取對應的map的unit的位置,然後轉發,問題來了,Frame_ClickMap消息到了map,map怎麼知道消息需要給哪個對象呢?這時候有幾種設計:

  1. 在轉發的底層協議中帶上unit的Id,需要比較複雜的底層協議支持。
  2. 用一個消息對Frame_ClickMap消息包裝一下,包裝的消息帶上Unit的Id,用消息包裝意味著更大的消耗,增加GC。 個人感覺這兩種都很差,不好用,而且就算分發給unit對象處理了,怎麼解決消息重入的問題呢?unit對象仍然需要掛上一個消息處理隊列,然後收到消息扔到隊列裡面。這不跟actor模型重覆了嗎?目前ET在客戶端發給unit的消息做了個設計,消息做成actor消息,gate收到發現是actor消息,直接發到對應的actor上,解決的可以說很漂亮。其實客戶端仍然是使用session.send跟call發送消息,發送的時候也不知道消息是actor消息,只有到了gate,gate才進行了判斷,參考OuterMessageDispatcher.cs

Actor Location消息的處理

ActorLocation消息發送

// 從Game.Scene上獲取ActorLocationSenderComponent,然後通過Entity.Id獲取ActorLocationSender
ActorLocationSender actorLocationSender = Game.Scene.GetComponent<ActorLocationSenderComponent>().Get(unitId);
// 通過ActorLocationSender來發送消息
actorLocationSender.Send(actorLocationMessage);
// 發送Rpc消息
IResponse response = await actorLocationSender.Call(actorLocationRequest);

 

ActorLocation消息的處理跟Actor消息幾乎一樣,不同的是繼承的兩個抽象類不同,註意actorlocation的抽象類多了個Location

    // 處理send過來的消息, 需要繼承AMActorLocationHandler抽象類,抽象類第一個泛型參數是Actor的類型,第二個參數是消息的類型
    [ActorMessageHandler(AppType.Map)]
    public class Frame_ClickMapHandler : AMActorLocationHandler<Unit, Frame_ClickMap>
    {
        protected override ETTask Run(Unit unit, Frame_ClickMap message)
        {
            Vector3 target = new Vector3(message.X, message.Y, message.Z);
            unit.GetComponent<UnitPathComponent>().MoveTo(target).Coroutine();
            
        }
    }

    // 處理Rpc消息, 需要繼承AMActorRpcHandler抽象類,抽象類第一個泛型參數是Actor的類型,第二個參數是消息的類型,第三個參數是返回消息的類型
    [ActorMessageHandler(AppType.Map)]
    public class C2M_TestActorRequestHandler : AMActorLocationRpcHandler<Unit, C2M_TestActorRequest, M2C_TestActorResponse>
    {
        protected override async ETTask Run(Unit unit, C2M_TestActorRequest message, Action<M2C_TestActorResponse> reply)
        {
            reply(new M2C_TestActorResponse(){Info = "actor rpc response"});
            await ETTask.CompletedTask;
        }
    }

 

ET的actor跟actor location的比喻

中國有很多城市(進程),城市中有很多人(entity對象)居住,每個人都有身份證號碼(Entity.Id)。一個人每到一個市都需要辦理居住證,分配到唯一的居住證號碼(InstanceId),居住證號碼的格式是2個位元組市編號+4個位元組時間+2個位元組遞增。身份證號碼是永遠不會變化的,但是居住證號碼每到一個城市都變化的。 現在有個中國郵政(actor)。假設小明要發信給女朋友小紅

  1. 小紅為了收信,自己必須掛載一個郵箱(MailboxComponent),小紅收到消息就會處理。註意這裡處理是一個個進行處理的。有可能小紅會同時收到很多人的信。但是她必須一封一封的信看,比方說小明跟小寶都發了信給小紅,小紅先收到小明的信,再收到了小寶的信。小紅先讀小明的信,小明信中讓小紅給外婆打個電話(產生協程)再給自己回信,註意這期間小紅也不能讀下一封信,必須打完電話後才能讀小寶的信。當然小紅自己可以選擇不處理完成就開始讀小寶的信,做法是小紅開一個新的協程來處理小明的信。
  2. 假設小明知道小紅的居住證號碼,那麼郵政(actor)可以根據居住證號碼頭兩位找到小紅居住的城市(進程),然後再根據小紅的居住證編號,找到小紅,把消息投遞到小紅的郵箱(MailboxComponent)中。這種是最簡單的原生的actor模型
  3. ET還支持了一套actor location機制。假設小明不知道小紅的居住證號碼,但是他知道小紅的身份證號碼,怎麼辦呢?郵政開發了一套高級郵政(actor location)想了一個辦法,如果一個人經常搬家,它還想收到信,那他到一個新的城市都必須把自己的居住證跟身份證上報到中央政府(location server),這樣高級郵政能夠通過身份證號碼來發送郵件。方法就是去中央政府拿到小紅的居住證號碼,再利用actor機制發送。
  4. 假設小紅之前在廣州市,小明用小紅的身份證給小紅髮信件了。 高級郵政獲取了小紅的居住證號碼,給小紅髮信。發信的這個過程中,小紅搬家了,從廣州搬到了深圳,這時小紅在中央政府上報了自己新的居住證。 高級郵政的信送到到廣州的時候發現,小紅不在廣州。那麼高級郵政會再次去中央政府獲取小紅的居住證,重新發送,有可能成功有可能再次失敗,這個過程會重覆幾次,如果一直不成功則告訴小明,信件發送失敗了。
  5. 高級郵政發信比較貴,而且人搬家的次數並不多,一般小明用高級郵政發信後會記住小紅的居住證,下次再發的時候直接用居住證發信,發送失敗了再使用高級郵政發信。
  6. 高級郵政的信都是有回執的,有兩種回執,一種回執沒有內容,只表示小紅收到了信,一種回執帶了小紅的回信。小明在發信的時候可以選擇使用哪種回執形式。小明給小紅不能同時發送兩封信,必須等小紅的回執到了,小明才能繼續發信。

    ET開源地址地址:egametang/ET: Unity3D Client And C# Server Framework (github.com)   qq群:474643097

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

-Advertisement-
Play Games
更多相關文章
  • 一、問題引入 Linux網路編程:socket & fork()多進程 實現clients/server通信 隨筆介紹了通過fork()多進程實現了伺服器與多客戶端通信。但除了多進程能實現之外,多線程也是一種實現方式。 重要的是,多進程和多線程是涉及操作系統層次。隨筆不僅要利用pthread_cre ...
  • Apache JMeter是Apache組織開發的基於Java的壓力測試工具。用於對軟體做壓力測試,它最初被設計用於Web應用測試,但後來擴展到其他測試領域。 它可以用於測試靜態和動態資源,例如靜態文件、Java 小服務程式、CGI 腳本、Java 對象、資料庫、FTP 伺服器, 等等。JMeter ...
  • 基於java的職工管理系統設計與實現,員工管理系統,企業員工管理系統,公司員工管理系統,企業人事管理系統,基於java職工管理系統,前後端分離,員工考勤管理系統,職工獎懲管理系統,職員合同管理,HR管理系統,人事HR管理系統。 ...
  • Author Alex Zhang Category SpreadJS Tags SpreadJS,前端電子錶格,實時數據,RealTime Data 前言 數據(包括股票、天氣和體育比分)在不斷更新為新信息時最為有用。SpreadJS是一個非常通用的 JavaScript 電子錶格組件,它還可以輕 ...
  • C語言教程——翁凱老師、赫斌 翁愷老師是土生土長的浙大碼農,從本科到博士都畢業於浙大電腦系,後來留校教書,一教就是20多年。 翁愷老師的c語言課程非常好,講解特別有趣,很適合初學者學習。 郝斌老師的思路是以初學者的思路來思考的,非常適合小白,你不理解的問題,基本上他都會詳細說一下。 C++——侯捷 ...
  • 前言: 自從使用了 AsyncLocal 後,就發現 AsyncLocal 變數像個臭蟲一樣,在有 AsyncLocal 變數的線程中啟動的 Task 、或者 Thread 都會附帶 AsyncLocal 變數。 在項目使用 AsyncLocal 實現了全局、局部 工作單元 ,但是就無法在後續作業中 ...
  • # 前言 SQLite是一種輕量級的關係型資料庫管理系統,支持跨平臺操作。它可以嵌入到程式中,無需單獨的伺服器進程或者配置文件,減少了資料庫維護的負擔和運行的複雜性。SQLite的數據存儲在單個文件中,方便備份、傳輸和分享,也容易進行版本管理。SQLite擁有良好的性能、可靠的穩定性和豐富的功能,成 ...
  • 類似魔獸世界,moba這種技能極其複雜,靈活性要求極高的技能系統,必須需要一套及其靈活的數值結構來搭配。數值結構設計好了,實現技能系統就會非常簡單,否則就是一場災難。比如魔獸世界,一個人物的數值屬性非常之多,移動速度,力量,怒氣,能量,集中值,魔法值,血量,最大血量,物理攻擊,物理防禦,法術攻擊,法 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...