Orleans[NET Core 3.1] 學習筆記（四）（ 2 ）獲取Grain的方式

来源:https://www.cnblogs.com/amber-L/archive/2020/01/16/12193277.html
-Advertisement-
Play Games

簡介 在這一節，我們將介紹如何在 Silo 和 Client 中獲取Grain及調用Grain Grain獲取方式 從Grain內部獲取： 從Client獲取： 應用 我們在項目中新增一個教室的概念，學生入學需要到教室先報個到才能分配到學號 1.修改 ，新增兩個介面 2.修改 3.在 中新增 4.在 ...


簡介

在這一節，我們將介紹如何在Silo和Client中獲取Grain及調用Grain

Grain獲取方式

從Grain內部獲取：

//根據特定的Key值創建或獲取指定的Grain
IStudent student = GrainFactory.GetGrain<IStudent>(studentID);

從Client獲取：

IStudent player = client.GetGrain<IStudent>(studentID);

應用

我們在項目中新增一個教室的概念，學生入學需要到教室先報個到才能分配到學號

1.修改 IStudent ，新增兩個介面

        [...]
        /// <summary>
        /// 設置個人信息
        /// </summary>
        /// <param name="studentId">學號</param>
        /// <param name="studentName">姓名</param>
        /// <returns></returns>
        Task SetStudentInfo(int studentId, string studentName);

        /// <summary>
        /// 接收消息
        /// </summary>
        /// <param name="code">消息code類型</param>
        /// <param name="senderId">消息發送人id</param>
        /// <param name="message">消息內容</param>
        /// <returns></returns>
        Task ReceiveMessages(string code, object senderId, string message);
        [...]

2.修改 Student

        /// <summary> 學號 </summary>
        private int Id;
        /// <summary> 姓名 </summary>
        private string Name;

        [...]

        public Task SetStudentInfo(int studentId, string studentName)
        {
            Id = studentId;
            Name = studentName;
            return Task.CompletedTask;
        }

        public Task ReceiveMessages(string code, object senderId, string message)
        {
            switch (code)
            {
                case "加入新同學":
                    {
                        ConsoleHelper.WriteSuccessLine($"【{Name}】：歡迎新同學");
                        break;
                    }
                case "同學發言":
                    {
                        ConsoleHelper.WriteSuccessLine($"【{Name}】聽到了學號為【{senderId}】的同學說的【{message}】");
                        break;
                    }
                default:
                    {
                        ConsoleHelper.WriteSuccessLine($"【{Name}】：我聽不懂你們在說啥");
                        break;
                    }
            }
            return Task.CompletedTask;
        }
        [...]

3.在 IGrains 中新增 IClassroom

namespace IGrains
{
    /// <summary>
    /// 教室
    /// </summary>
    public interface IClassroom : Orleans.IGrainWithIntegerKey
    {
        /// <summary>
        /// 報名登記並拿到學號
        /// </summary>
        /// <param name="name">姓名</param>
        /// <returns></returns>
        Task<int> Enroll(string name);

        /// <summary>
        /// 學生入座
        /// </summary>
        /// <param name="student"></param>
        /// <returns></returns>
        Task<bool> Seated(IStudent student);

        /// <summary>
        /// 發言
        /// </summary>
        /// <param name="student">當前的學生</param>
        /// <param name="message">發言內容</param>
        /// <returns></returns>
        Task<bool> Speech(IStudent student, string message);
    }
}

4.在 Grains 中新增 Classroom

using IGrains;
using Orleans;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace Grains
{
    /// <summary>
    /// 教室
    /// </summary>
    public class Classroom : Orleans.Grain, IClassroom
    {
        /// <summary> 教室內的學生 </summary>
        private List<IStudent> Students = new List<IStudent>();

        /// <summary>
        /// 報名登記並拿到學號
        /// </summary>
        /// <param name="name">姓名</param>
        /// <returns></returns>
        public async Task<int> Enroll(string name)
        {
            int studentID = Students.Count() + 1;
            var aaa = this.GetPrimaryKeyLong();
            IStudent student = GrainFactory.GetGrain<IStudent>(studentID);
            await student.SetStudentInfo(studentID, name);//等待一下
            Students.Add(student);
            return studentID;
        }

        /// <summary>
        /// 學生入座
        /// </summary>
        /// <param name="student"></param>
        /// <returns></returns>
        public Task<bool> Seated(IStudent student)
        {
            if (!Students.Contains(student))
            {
                return Task.FromResult(false);//沒登記的學生不給坐
            }
            foreach (var item in Students)
            {
                if (item.GetPrimaryKeyLong() != student.GetPrimaryKeyLong())
                {
                    item.ReceiveMessages("加入新同學", this.GetPrimaryKeyLong(), $"學號{student.GetPrimaryKeyLong()}的童靴加入了我們，大家歡迎");//不等待
                }
            }
            return Task.FromResult(true);
        }

        /// <summary>
        /// 發言
        /// </summary>
        /// <param name="student">當前的學生</param>
        /// <param name="message">發言內容</param>
        public Task<bool> Speech(IStudent student, string message)
        {
            if (!Students.Contains(student))
            {
                return Task.FromResult(false);//沒登記的學生閉嘴
            }
            foreach (var item in Students)
            {
                if (item.GetPrimaryKeyLong() != student.GetPrimaryKeyLong())
                {
                    item.ReceiveMessages("同學發言", (int)student.GetPrimaryKeyLong(), message);//不等待
                }
            }
            return Task.FromResult(true);
        }
    }
}

5.新增新的Orleans客戶端項目，創建 asp.net core mvc 項目 Client_WebMVCApp

使用NuGet引用 Microsoft.Orleans.Client（3.0.2）

新增 OrleansService

namespace Client_WebMVCApp.Services
{
    public class OrleansService : IOrleansService
    {
        private readonly IClusterClient clusterClient;

        public OrleansService()
        {
            clusterClient = ConnectClient().Result;
        }

        public T GetGrain<T>(long integerKey) where T : IGrainWithIntegerKey
        {
            return clusterClient.GetGrain<T>(integerKey);
        }

        /// <summary>
        /// 使用本地配置連接服務
        /// </summary>
        /// <returns></returns>
        private async Task<IClusterClient> ConnectClient()
        {
            IClusterClient client;
            client = new ClientBuilder()
                .UseLocalhostClustering()           //配置客戶端以連接到本地主機上的筒倉。
                .Configure<ClusterOptions>(options =>
                {
                    options.ClusterId = "dev";
                    options.ServiceId = "MyHost";
                })
                .Build();
            await client.Connect();
            return client;
        }
    }
}

然後修改 Startup ，把Orleans配置上去

        [...]
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllersWithViews(); 
            services.AddTransient<OrleansService>();//註冊一下Orleans
        }
        [...]

再修改 HomeController ，咱們來把上面註入的 OrleansService 使用起來

        [...]
        private readonly OrleansService _orleansService;
        private readonly IClassroom _classroom;

        public HomeController(ILogger<HomeController> logger, OrleansService orleansService)
        {
            _logger = logger;
            _orleansService = orleansService;
            _classroom = _orleansService.GetGrain<IClassroom>(0);
        }

        /// <summary>
        /// 報名拿學號
        /// </summary>
        /// <param name="name">學生姓名</param>
        /// <returns></returns>
        [HttpGet]
        public async Task<IActionResult> GetStudentId(string name)
        {
            var studentId = await _classroom.Enroll(name);
            IStudent student = _orleansService.GetGrain<IStudent>(studentId);
            _classroom.Seated(student);//落座，不等待它
            //return Json(new { Success = true, Data = studentId, Message = "獲取成功！" });
            return new JsonResult(new { Success = true, Data = studentId, Message = "獲取成功！" });
        }
        [...]

6.運行起來

我們先把 Silo_ConsoleApp 跑起來

然後把 Client_WebMVCApp 跑起來，註意，這裡我的埠用的是 4003,按照順序請求如下介面：

http://localhost:4003/home/getstudentid?name=張三

http://localhost:4003/home/getstudentid?name=李四

http://localhost:4003/home/getstudentid?name=王二麻

我們能看到 Silo_ConsoleApp.exe 列印如下日誌：

好了，大功告成。

張三、李四、王二麻三個人排著隊報名入座，李四坐下的時候張三歡迎他，王二麻坐下的時候張三李四一起歡迎他，ojbk，完美

本文代碼範例

GitHub倉庫

便捷路由

目錄 ： Orleans[NET Core 3.1] 學習筆記（一）.NET環境下的分散式應用程式

上一節 ： Orleans[NET Core 3.1] 學習筆記（四）（ 1 ）創建項目

下一節 ： Orleans[NET Core 3.1] 學習筆記（四）（ 3 ）監控Orleans Silo的方式 OrleansDashboard


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

-Advertisement-
Play Games
更多相關文章
  • 想玩轉JAVA高併發，這些概念你必須懂！
    我們在找工作時，經常在招聘信息上看到有這麼一條:有構建大型互聯網服務及高併發等經驗，你第一時間想到的是媒體常說的雙十一嗎？帶著問題，我們一起思考技術…. 高併發高併發 它是互聯網分散式系統架構設計中必須考慮的因素之一，通常是指，保證系統能夠同時並行化處理海量請求 同步和非同步 同步：發送一個請求，等待 ...
  • python 正則表達式參數替換
    使用正則表達式替換字典數據 ${memberID} 對應的正則表達式 '\$\{.*\}'解釋：\$ 轉義替換字元串中 $ \{ 轉義替換字元串中 { . 除了\n中的任意單個自符 * 匹配*前面的字元零次或者多次 \} 轉義替換字元串中 } dict = {"memberId":"${member ...
  • .NET CORE(C#) WPF亞克力窗體
    微信公眾號： "Dotnet9" ，網站： "Dotnet9" ，問題或建議： "請網站留言" ， 如果對您有所幫助： "歡迎贊賞" 。 .NET CORE(C ) WPF亞克力窗體 閱讀導航 1. 本文背景 2. 代碼實現 3. 本文參考 4. 源碼 1. 本文背景 本文介紹使用FluentWPF ...
  • ASP.NET Core DI概述
    眾所周知，ASP.NET Core有一個DI框架，應用程式啟動時初始化。 預定義依賴 1： IApplicationBuilder:提供了配置應用程式的請求管道機制 2：ILoggerFactory：次類型提供了創建記錄器組件的模式 3：LHostinEnvironment：此類型提供管理應用程式運 ...
  • .net core 實現基於 JSON 的多語言
    上次我們提到了，微軟預設提供基於資源文件的多語言本地化，個人感覺使用起來不是太方便，沒有 json 看起來直觀，於是動手造了一個輪子， dotnet core 基於 json 的本地化組件 ...
  • C#上位機之—WinForm實現Socket非同步通訊示例
    工作中常用到的一些知識點，總是用完就忘，第一次嘗試用博客記錄下來，以備後用； Socket通訊，Socket（套接字）是基於TCP/IP通訊方式的封裝好的類，調用時需要添加下麵的服務引用： .......10 using System.Net; 11 using System.Net.Sockets ...
  • 重構與動態為angularjs欄位賦值或獲取值
    先來看下麵一段html： 這個ng-model名稱帶有一定的規律帶有序號。 先來實現數據綁定，從數據取到數據後，為ng-model綁定相對應的值： var c = response.data $scope.Start1 = $filter("jsonDateFormat")(c.Start1, "y ...
  • Github上優秀的.NET Core項目
    Github上優秀的.NET Core開源項目的集合。內容包括：庫、工具、框架、模板引擎、身份認證、資料庫、ORM框架、圖片處理、文本處理、機器學習、日誌、代碼分析、教程等。 Github地址：https://github.com/jasonhua95/awesome-dotnet-core ，【a ...
一周排行
    -Advertisement-
    Play Games
  • 如何基於surging跨網關跨語言進行緩存降級
    基於.NET Framework 4.8 開發的深度學習模型部署測試平臺，提供了YOLO框架的主流系列模型，包括YOLOv8~v9，以及其系列下的Det、Seg、Pose、Obb、Cls等應用場景，同時支持圖像與視頻檢測。模型部署引擎使用的是OpenVINO™、TensorRT、ONNX runti... ...
  • 十年沉澱，重啟開發之路
    十年沉澱，重啟開發之路 十年前，我沉浸在開發的海洋中，每日與代碼為伍，與演算法共舞。那時的我，滿懷激情，對技術的追求近乎狂熱。然而，隨著歲月的流逝，生活的忙碌逐漸占據了我的大部分時間，讓我無暇顧及技術的沉澱與積累。 十年間，我經歷了職業生涯的起伏和變遷。從初出茅廬的菜鳥到逐漸嶄露頭角的開發者，我見證了 ...
  • C#.NET體系圖文概述—2024最全總結
    C# 是一種簡單、現代、面向對象和類型安全的編程語言。.NET 是由 Microsoft 創建的開發平臺，平臺包含了語言規範、工具、運行，支持開發各種應用，如Web、移動、桌面等。.NET框架有多個實現，如.NET Framework、.NET Core（及後續的.NET 5+版本），以及社區版本M... ...
  • 班級擂臺（光榮）榜 - 極簡教育小工具
    前言 本文介紹瞭如何使用三菱提供的MX Component插件實現對三菱PLC軟元件數據的讀寫，記錄了使用電腦模擬，模擬PLC，直至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1. PLC開發編程環境GX Works2，GX Works2下載鏈接 https:// ...
  • web server apache tomcat11-31-websocket
    前言 整理這個官方翻譯的系列，原因是網上大部分的 tomcat 版本比較舊，此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎，輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • day31-jQuery
    1、jQuery介紹 jQuery是什麼 jQuery是一個快速、簡潔的JavaScript框架，是繼Prototype之後又一個優秀的JavaScript代碼庫（或JavaScript框架）。jQuery設計的宗旨是“write Less，Do More”，即倡導寫更少的代碼，做更多的事情。它封裝 ...
  • aardio爬蟲) 實戰篇：逆向有道翻譯web介面
    前言 之前的文章把js引擎(aardio封裝庫) 微軟開源的js引擎(ChakraCore))寫好了，這篇文章整點js代碼來測一下bug。測試網站：https://fanyi.youdao.com/index.html#/ 逆向思路 逆向思路可以看有道翻譯js逆向（MD5加密，AES加密）附完整源碼 ...
  • 面試官：這就是你理解的Java多線程基礎？
    引言 現代的操作系統（Windows，Linux，Mac OS）等都可以同時打開多個軟體（任務），這些軟體在我們的感知上是同時運行的，例如我們可以一邊瀏覽網頁，一邊聽音樂。而CPU執行代碼同一時間只能執行一條，但即使我們的電腦是單核CPU也可以同時運行多個任務，如下圖所示，這是因為我們的 CPU 的 ...
  • Python文本統計與分析從基礎到進階
    掌握使用Python進行文本英文統計的基本方法，並瞭解如何進一步優化和擴展這些方法，以應對更複雜的文本分析任務。 ...
  • Redis多數據源，看這篇就夠了
    背景 Redis多數據源常見的場景： 分區數據處理：當數據量增長時，單個Redis實例可能無法處理所有的數據。通過使用多個Redis數據源，可以將數據分區存儲在不同的實例中，使得數據處理更加高效。 多租戶應用程式：對於多租戶應用程式，每個租戶可以擁有自己的Redis數據源，以確保數據隔離和安全性。 ...
所有分類