3. Caller 服務調用 - dapr

来源:https://www.cnblogs.com/MASA/archive/2022/06/28/16419318.html
-Advertisement-
Play Games

前言 上一篇我們講了使用HttpClient的方式調用，那麼如果我們現在需要更換為通過dapr實現服務調用，我們需要做哪些事情呢？ Caller.Dapr 入門 如果我們的項目原本使用的是Caller.HttpClient，現在希望改為使用Caller.Dapr，那麼我們需要做什麼呢？ 改造Call ...


前言

上一篇我們講了使用HttpClient的方式調用，那麼如果我們現在需要更換為通過dapr實現服務調用，我們需要做哪些事情呢？

Caller.Dapr 入門

如果我們的項目原本使用的是Caller.HttpClient，現在希望改為使用Caller.Dapr，那麼我們需要做什麼呢？

  1. 改造Caller 服務調用 - HttpClient的中的服務端，使得服務端支持dapr調用
  2. 調整客戶端代碼，使客戶端支持通過dapr來做到服務調用，並達到與HttpClient調用相同的結果

準備工作

  1. 創建ASP.NET Core 空白解決方案Assignment03

  2. 將Assignment02文件夾下的Assignment.Server複製到Assignment03的文件夾下，然後將項目Assignment.Server添加到解決方案Assignment03中

  3. 選中Assignment.Server並安裝Masa.Utils.Development.Dapr.AspNetCore

    dotnet add package Masa.Utils.Development.Dapr.AspNetCore --version 0.4.0-rc1

  4. 修改Assignment.Server項目下的Program.cs

    //忽略命名空間引用

var builder = WebApplication.CreateBuilder(args);

// 添加DaprStarter，用於服務端啟動dapr sidecar，改造服務端支持dapr調用的重點（建議在開發環境下使用，線上環境使用k8s部署）
builder.Services.AddDaprStarter(option =>
{
    option.AppId = "Assignment-Server";
    option.DaprGrpcPort = 7007;
    option.DaprHttpPort = 7008;
    option.AppIdSuffix = string.Empty;
});

var app = builder.Build();
/// 忽略路由等

    Q: 什麼是DaprStarter？為什麼要使用DaprStarter？
    A: DaprStarter是Masa團隊開發出來用於管理Dapr sidecar的包，可以幫助我們在開發環境下很簡單的使用dapr sidecar

    Q: 為什麼要指定AppId、DaprGrpcPort、DaprHttpPort等信息？
    A: 客戶端調用需要得到Dapr的AppId、設置DaprGrpcPort、DaprHttpPort是因為客戶端演示項目沒有使用dapr sidecar，如果客戶端項目也使用dapr sidecar，此處可以不指定DaprGrpcPort、DaprHttpPort，更多信息請參考[文章](https://www.cnblogs. com/zhenlei520/p/16157625.html)

  5. 創建ASP.NET Core 空項目Assignment.Client.DaprClientWeb作為客戶端並安裝Masa.Utils.Caller.DaprClient

    dotnet add package Masa.Utils.Caller.DaprClient --version 0.4.0-rc1

  6. 修改Assignment.Client.DaprClientWeb項目下的Program.cs

    using Masa.Utils.Caller.Core;
using Masa.Utils.Caller.DaprClient;
using Microsoft.AspNetCore.Mvc;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddCaller(option =>
{
    // 註意: 與Caller.HttpClient相比，需要修改的地方
    options.UseDapr(masaDaprClientBuilder =>
    {
        masaDaprClientBuilder.Name = "userCaller"; // 當前Caller的別名(僅有一個Caller時可以不填)，Name不能重覆
        masaDaprClientBuilder.IsDefault = true; // 預設的Caller支持註入ICallerProvider獲取（僅有一個Caller時可不賦值）
        masaDaprClientBuilder.AppId = "Assignment-Server";//設置當前caller下Dapr的AppId
    });
});
var app = builder.Build();

app.MapGet("/", () => "Hello HttpClientWeb.V1!");

app.MapGet("/Test/User/Get", async ([FromServices] ICallerProvider callerProvider) =>
{
    var user = await callerProvider.GetAsync<object, UserDto>("User", new { id = new Random().Next(1, 10) });
    return $"獲取用戶信息成功：用戶名稱為：{user!.Name}";
});

app.MapGet("/Test/User/Add", async ([FromServices] ICallerProvider callerProvider) =>
{
    var dateTimeOffset = new DateTimeOffset(DateTime.UtcNow);
    string timeSpan = dateTimeOffset.ToUnixTimeSeconds().ToString();
    var userName = "ss_" + timeSpan; //模擬一個用戶名
    string? response = await callerProvider.PostAsync<object, string>("User", new { Name = userName });
    return $"創建用戶成功了，用戶名稱為：{response}";
});

app.Run();

public class UserDto
{
    public int Id { get; set; }

    public string Name { get; set; } = default!;
}

    相較於Assignment.Client.HttpClientWeb，Assignment.Client.DaprClientWeb僅僅是更改了Program.cs，將UseHttpClient改為UseDapr，其餘代碼無需修改

  7. 添加環境變數DAPR_GRPC_PORT，值為7007、DAPR_HTTP_PORT，值為7008

    Q: 為什麼要添加環境變數？
    A: 由於當前客戶端並未使用dapr sidecar，若當前客戶端也使用dapr sidecar，此處可以不添加環境變數

現在Caller的HttpClient版本就可以使用了，分別啟動Assignment.Server、Assignment.Client.DaprClientWeb服務，瀏覽器訪問http://localhost:5042/Test/User/Get、http://localhost:5042/Test/User/Add，分別輸出對應的獲取用戶信息成功以及創建用戶成功的提示，則證明調用成功了/Test/User/Get/Test/User/Add

DaprClient 最佳實踐

Assignment.Client.DaprClientWeb的寫法比較簡單，其用法與Assignment.Client.HttpClientWeb基本一致，與Caller.HttpClient類似，DaprClient我們推薦使用下麵的寫法:

  1. 創建ASP.NET Core 空項目Assignment.Client.DaprClientWeb.V2作為調用方V2版本

  2. 選中Assignment.Client.DaprClientWeb.V2並安裝Masa.Utils.Caller.DaprClient

    dotnet add package Masa.Utils.Caller.DaprClient --version 0.4.0-rc1

  3. 添加類ServerCallerBase (對應服務端服務)

    using Masa.Utils.Caller.DaprClient;

namespace Assignment.Client.DaprClientWeb.V2;

/// <summary>
/// 註意：ServerCallerBase是抽象類喲（抽象類不會被DI註冊）, 與使用Caller.HttpClient相比，需要修改的是繼承的基類改為DaprCallerBase
/// </summary>
public abstract class ServerCallerBase : DaprCallerBase
{
    protected override string AppId { get; set; } = "Assignment-Server";//設置當前Caller需要請求的服務端項目Dapr的AppId

    public ServerCallerBase(IServiceProvider serviceProvider) : base(serviceProvider)
    {
    }
}

  4. 添加類UserCaller.cs

    namespace Assignment.Client.DaprClientWeb.V2;

public class UserCaller : ServerCallerBase
{
    public UserCaller(IServiceProvider serviceProvider) : base(serviceProvider)
    {
    }

    /// <summary>
    /// 調用服務獲取用戶信息
    /// </summary>
    /// <param name="id">用戶id</param>
    /// <returns></returns>
    public Task<UserDto?> GetUserAsync(int id)
        => CallerProvider.GetAsync<object, UserDto>("User", new { id = id });

    /// <summary>
    /// 調用服務添加用戶
    /// </summary>
    /// <param name="userName"></param>
    /// <returns></returns>
    public Task<string?> AddUserAsync(string userName)
        => CallerProvider.PostAsync<object, string>("User", new { Name = userName });
}

public class UserDto
{
    public int Id { get; set; }

    public string Name { get; set; } = default!;
}

  5. 添加環境變數DAPR_GRPC_PORT，值為7007、DAPR_HTTP_PORT，值為7008

最後，分別啟動Assignment.Server、Assignment.Client.DaprClientWeb.V2服務，瀏覽器訪問http://localhost:5102/Test/User/Get、http://localhost:5102/Test/User/Add，分別輸出對應的獲取用戶信息成功以及創建用戶成功的提示，則證明調用成功了/Test/User/Get/Test/User/Add

常見問題

在開發中我們會遇到各種各樣的問題，下麵就來列舉幾個我們項目中遇到的問題：

  • 一個項目在同一個k8s集群部署了兩套環境，為什麼會出現代碼調用混亂（開發環境調用線上環境）？

    在於同一個K8s集群下，dapr會將服務組網，並將它們認為是同一個服務(AppId一致的服務)。

  • 如何解決同一個k8s集群中調用混亂的問題？

    解決方案有兩種：
1. 將不同環境下的服務分別部署在不同的K8s集群
2. 根據環境調整相對應服務的dapr sidecar的配置，其`AppId`的命名規則：`AppId`-`環境名`。修改自定義Caller的規則：

public abstract class CustomizeDaprCallerBase : DaprCallerBase
{
    protected CustomizeDaprCallerBase(IServiceProvider serviceProvider) : base(serviceProvider)
    {
        var hostEnvironment = serviceProvider.GetRequiredService<IWebHostEnvironment>();
        if (!hostEnvironment.IsDevelopment() || hostEnvironment.IsStaging())
            AppId = AppId + "-" + hostEnvironment.EnvironmentName;
    }
}

  • 如何修改支持自定義Header？

    目前Caller.Dapr不支持自定義Header，目前只能使用`SendAsync`才能自定義Header，不過此功能已經在0.5.0的開發計劃中，在0.5.0中會支持

總結

使用Masa提供的Caller服務，有助於我們的項目在前期沒有使用Dapr的情況下先利用Caller.HttpClient做緩衝，等後期時機成熟，只需要更改相對應的CallerBase即可，其他代碼基本不需要調整，減輕了我們的開發成本，並且不同的Caller仍然可以很靈活的調整超時時間、Header等信息，並且Caller預設提供了處理異常的功能，當調用出錯後，會自動拋出異常，讓我們可以更專心的處理業務。

但目前Caller還有不足之處，目前Caller.Dapr版針對請求頭處理的並不完善，除此之外，目前不支持Content-Type為非Json類型，這塊功能會在0.5.0版本中加以支持完善

本章源碼

Assignment03

https://github.com/zhenlei520/MasaFramework.Practice

開源地址

MASA.BuildingBlocks：https://github.com/masastack/MASA.BuildingBlocks

MASA.Contrib：https://github.com/masastack/MASA.Contrib

MASA.Utils：https://github.com/masastack/MASA.Utils

MASA.EShop：https://github.com/masalabs/MASA.EShop

MASA.Blazor：https://github.com/BlazorComponent/MASA.Blazor

如果你對我們的 MASA Framework 感興趣，無論是代碼貢獻、使用、提 Issue，歡迎聯繫我們

16373211753064.png


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

-Advertisement-
Play Games
更多相關文章
  • IOS OpenGL ES 圖像擴展邊緣彩色模糊 GPUImageRGBDilationFilter
    目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
  • java8中Predicate<T> function函數方法的示例分享
    spring框架應用的是ioc模式，ioc模式是指控制反轉模式，本質是你不去創建對象讓spring框架給你創建對象你去使用對象。多種開發模式通過配置文件和註解的方式去開發的都很值得去學習 ...
  • 關於不完全類型的認識
    前言 嗨嘍，大家好呀！這裡是魔王吶~ 環境使用: Python 3.8 Pycharm 模塊使用: requests >>> pip install requests 數據請求模塊 parsel >>> pip install parsel 數據解析模塊 csv 內置模塊 如果安裝python第三方 ...
  • java中同步和非同步簡介及應用場景
    正所謂“工欲善其事、必先利其器”，面對一個優秀的框架，如果再結合一些外部的工具，其實可以讓我們的開發效率與程式員開發過程的體驗更上一層樓的。 ...
  • Redis 原理 - Set
    Set數據結構 使用 intset 當同時滿足下麵兩個條件時,使用 intset 存儲數據 元素個數少於512個 (set-max-intset-entries: 512) 所有元素都是整數值 不滿足上面的條件, 使用 hashtable intset 圖解 //intset 的編碼方式 #defi ...
  • 用WindowsAppSDK（WASDK）優雅的開發上位機應用
    C#開發上位機應用的一些選擇 如果你不想看介紹，可以直接跳到優雅開發示例那裡。 1. WASDK（WinUI 3） Windows 應用 SDK 是一組新的開發人員組件和工具，它們代表著 Windows 應用開發平臺的下一步發展。 Windows 應用 SDK 提供一組統一的 API 和工具，可供從 ...
  • Redis 原理 - Hash
    Hash 數據結構 使用 ziplist 當同時滿足下麵兩個條件時,使用 ziplist 存儲數據 元素個數少於512個 (hash-max-ziplist-entries: 512) 每個元素長度小於64位元組 (hash-max-ziplist-value: 64) 不滿足上面的條件, 使用 ha ...
  • WPF 視頻硬解碼渲染播放（無空域）（支持4K、8K、高幀率視頻）
    MediaWPF 基於 .NET 6 實現視頻硬解碼渲染Demo（無空域問題） 代碼實現僅供學習參考 本項目視頻渲染通過顯卡進行視頻解碼，CPU幾乎不參與工作，並且不存在令人煩躁的空域問題。 在播放攝像頭多路視頻或高解析度、高幀率視頻時可以極大發揮顯卡性能（我認為該項目做到了這一點）。 播放4k、8 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類