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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類