Dapr 運用之整合 Asp.Net Core Grpc 呼叫篇

阿新 • • 發佈：2019-12-18

前置條件：《Dapr 運用》

改造 ProductService 以提供 gRPC 服務

從 NuGet 或程式包管理控制檯安裝 gRPC 服務必須的包
- Grpc.AspNetCore

配置 Http/2

gRPC 服務需要 Http/2 協議

public static IHostBuilder CreateHostBuilder(string[] args)
{
    return Host.CreateDefaultBuilder(args)
        .ConfigureWebHostDefaults(webBuilder =>
        {
            webBuilder.ConfigureKestrel(options =>
            {
                options.Listen(IPAddress.Loopback, 50![](https://img2018.cnblogs.com/blog/757544/201912/757544-20191218205830077-211023565.png)
01, listenOptions =>
                {
                    listenOptions.Protocols = HttpProtocols.Http2;
                });
            });
            webBuilder.UseStartup<Startup>();
        });
}

新建了 product.proto 以定義 GRPC 服務，它需要完成的內容是返回所有產品集合，當然目前產品內容只有一個 ID

定義產品 proto
```
syntax = "proto3";

package productlist.v1;

option csharp_namespace = "ProductList.V1";

service ProductRPCService{
    rpc GetAllProducts(ProductListRequest) returns(ProductList);
}

message ProductListRequest{

}

message ProductList {
    repeated Product results = 1;
}

message Product {
    string ID=1;
} 
```
說明
- 定義產品列表 gRPC 服務，得益於宇宙第一 IDE Visual Studio ，只要新增 Grpc.Tools 包就可以自動生成 gRPC 所需的程式碼，這裡不再需要手動去新增 Grpc.Tools ，官方提供的 Grpc.AspNetCore 中已經集成了
- 定義了一個服務 ProductRPCService
- 定義了一個函式 ProductRPCService
- 定義了一個請求構造 ProductListRequest ，內容為空
- 定義了一個請求返回構造 ProductList ，使用 repeated 表明返回資料是集合
- 定義了一個數據集合中的一個物件 Product

新增 ProductListService 檔案，內容如下

    public class ProductListService : ProductRPCService.ProductRPCServiceBase
    {
        private readonly ProductContext _productContext;

        public ProductListService(ProductContext productContext)
        {
            _productContext = productContext;
        }

        public override async Task<ProductList.V1.ProductList> GetAllProducts(ProductListRequest request, ServerCallContext context)
        {
            IList<Product> results = await _productContext.Products.ToListAsync();
            var productList = new ProductList.V1.ProductList();
            foreach (Product item in results)
            {
                productList.Results.Add(new ProductList.V1.Product
                {
                    ID = item.ProductID.ToString()
                });
            }

            return productList;
        }
    }

在 Startup.cs 修改程式碼如下

public void ConfigureServices(IServiceCollection services)
{
    //啟用 gRPC 服務
    services.AddGrpc();
    services.AddTransient<ProductListService>();
    ...
}

這裡的 services.AddTransient

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    if (env.IsDevelopment())
    {
        app.UseDeveloperExceptionPage();
    }

    app.UseRouting();

    app.UseEndpoints(endpoints =>
    {
        ...

        //新增 gRPC 到路由管道中
        endpoints.MapGrpcService<DaprClientService>();
    });
}

這裡新增的程式碼的含義分別是啟用 gRPC 服務和新增 gRPC 路由。得益於 ASP.NET Core 中介軟體的優秀設計，ASP.NET Core 可同時支援 Http 服務。

新增 daprclient.proto 檔案以生成 Dapr Grpc 服務，daprclient.proto 內容如下

syntax = "proto3";

package daprclient;

import "google/protobuf/any.proto";
import "google/protobuf/empty.proto";
import "google/protobuf/duration.proto";

option java_outer_classname = "DaprClientProtos";
option java_package = "io.dapr";

// User Code definitions
service DaprClient {
rpc OnInvoke (InvokeEnvelope) returns (google.protobuf.Any) {}
rpc GetTopicSubscriptions(google.protobuf.Empty) returns (GetTopicSubscriptionsEnvelope) {}
rpc GetBindingsSubscriptions(google.protobuf.Empty) returns (GetBindingsSubscriptionsEnvelope) {}
rpc OnBindingEvent(BindingEventEnvelope) returns (BindingResponseEnvelope) {}
rpc OnTopicEvent(CloudEventEnvelope) returns (google.protobuf.Empty) {}
}

message CloudEventEnvelope {
string id = 1;
string source = 2;
string type = 3;
string specVersion = 4;
string dataContentType = 5;
string topic = 6;
google.protobuf.Any data = 7;
}

message BindingEventEnvelope {
    string name = 1;
    google.protobuf.Any data = 2;
    map<string,string> metadata = 3;
}

message BindingResponseEnvelope {
google.protobuf.Any data = 1;
repeated string to = 2;
repeated State state = 3;
string concurrency = 4;
}

message InvokeEnvelope {
    string method = 1;
    google.protobuf.Any data = 2;
    map<string,string> metadata = 3;
}

message GetTopicSubscriptionsEnvelope {
repeated string topics = 1;
}

message GetBindingsSubscriptionsEnvelope {
repeated string bindings = 1;
}

message State {
string key = 1;
google.protobuf.Any value = 2;
string etag = 3;
map<string,string> metadata = 4;
StateOptions options = 5;
}

message StateOptions {
string concurrency = 1;
string consistency = 2;
RetryPolicy retryPolicy = 3;
}

message RetryPolicy {
int32 threshold = 1;
string pattern = 2;
google.protobuf.Duration interval = 3;
}

說明

此檔案為官方提供，Dapr 0.3 版本之前提供的已經生成好的程式碼，現在看原始碼可以看出已經改為提供 proto 檔案了，這裡我認為提供 proto 檔案比較合理
此檔案定義了5個函式，此文主要講的就是 OnInvoke() 函式
OnInvoke() 請求構造為 InvokeEnvelope
- method 提供呼叫方法名稱
- data 請求資料
- metadata 額外資料，此處使用鍵值對形式體現

建立 DaprClientService.cs 檔案，此檔案用於終結點路由，內容為

public class DaprClientService : DaprClient.DaprClientBase
{
    private readonly ProductListService _productListService;

    /// <summary>
    /// Initializes a new instance of the <see cref="ProductService" /> class.
    /// </summary>
    /// <param name="productListService"></param>
    public DaprClientService(ProductListService productListService)
    {
        _productListService = productListService;
    }

    public override async Task<Any> OnInvoke(InvokeEnvelope request, ServerCallContext context)
    {
        switch (request.Method)
        {
            case "GetAllProducts":
                ProductListRequest productListRequest = ProductListRequest.Parser.ParseFrom(request.Data.Value);
                ProductList.V1.ProductList productsList = await _productListService.GetAllProducts(productListRequest, context);
                return Any.Pack(productsList);
        }

        return null;
    }
}

說明

使用構造器注入已定義好的 ProductListService
InvokeEnvelope 中的 Method 用於路由資料
使用 ProductListRequest.Parser.ParseFrom 轉換請求構造
使用 Any.Pack() 打包需要返回的資料

執行 productService

dapr run --app-id productService --app-port 5001 --protocol grpc dotnet run

小結
至此，ProductService 服務完成。此時 ProductService.Api.csproj Protobuf 內容為
<ItemGroup>
  <Protobuf Include="Protos\daprclient.proto" GrpcServices="Server" />
 <Protobuf Include="Protos\productList.proto" GrpcServices="Server" />
 </ItemGroup>

改造 StorageService 服務以完成 Dapr GRPC 服務呼叫

新增 productList.proto 檔案，內容同 ProductService 中的 productList.proto

新增 dapr.proto 檔案，此檔案也為官方提供，內容為

syntax = "proto3";

package dapr;

import "google/protobuf/any.proto";
import "google/protobuf/empty.proto";
import "google/protobuf/duration.proto";

option java_outer_classname = "DaprProtos";
option java_package = "io.dapr";

option csharp_namespace = "Dapr.Client.Grpc";


// Dapr definitions
service Dapr {
rpc PublishEvent(PublishEventEnvelope) returns (google.protobuf.Empty) {}
rpc InvokeService(InvokeServiceEnvelope) returns (InvokeServiceResponseEnvelope) {}
rpc InvokeBinding(InvokeBindingEnvelope) returns (google.protobuf.Empty) {}
rpc GetState(GetStateEnvelope) returns (GetStateResponseEnvelope) {}
rpc SaveState(SaveStateEnvelope) returns (google.protobuf.Empty) {}
rpc DeleteState(DeleteStateEnvelope) returns (google.protobuf.Empty) {}
}

message InvokeServiceResponseEnvelope {
google.protobuf.Any data = 1;
map<string,string> metadata = 2;
}

message DeleteStateEnvelope {
string key = 1;
string etag = 2;
StateOptions options = 3;
}

message SaveStateEnvelope {
repeated StateRequest requests = 1;
}

message GetStateEnvelope {
    string key = 1;
    string consistency = 2;
}

message GetStateResponseEnvelope {
google.protobuf.Any data = 1;
string etag = 2;
}

message InvokeBindingEnvelope {
string name = 1;
google.protobuf.Any data = 2;
map<string,string> metadata = 3;
}

message InvokeServiceEnvelope {
string id = 1;
string method = 2;
google.protobuf.Any data = 3;
map<string,string> metadata = 4;
}

message PublishEventEnvelope {
    string topic = 1;
    google.protobuf.Any data = 2;
}

message State {
string key = 1;
google.protobuf.Any value = 2;
string etag = 3;
map<string,string> metadata = 4;
StateOptions options = 5;
}

message StateOptions {
string concurrency = 1;
string consistency = 2;
RetryPolicy retryPolicy = 3;
}

message RetryPolicy {
int32 threshold = 1;
string pattern = 2;
google.protobuf.Duration interval = 3;
}

message StateRequest {
string key = 1;
google.protobuf.Any value = 2;
string etag = 3;
map<string,string> metadata = 4;
StateRequestOptions options = 5;
}

message StateRequestOptions {
string concurrency = 1;
string consistency = 2;
StateRetryPolicy retryPolicy = 3;
}

message StateRetryPolicy {
int32 threshold = 1;
string pattern = 2;
google.protobuf.Duration interval = 3;
}

說明

此檔案提供6個 GRPC 服務，此文介紹的函式為 InvokeService()
- 請求構造為 InvokeServiceEnvelope
  - id 請求的服務的 --app-id ，比如 productService
  - method 請求的方法
  - data 請求函式的簽名
  - metadata 元資料鍵值對

修改 StorageController 中的 InitialStorage() 函式為

/// <summary>
/// 初始化倉庫.
/// </summary>
/// <returns>是否成功.</returns>
[HttpGet("InitialStorage")]
public async Task<bool> InitialStorage()
{
    string defaultPort = Environment.GetEnvironmentVariable("DAPR_GRPC_PORT") ?? "5001";

    // Set correct switch to make insecure gRPC service calls. This switch must be set before creating the GrpcChannel.
    AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);

    // Create Client
    string daprUri = $"http://127.0.0.1:{defaultPort}";
    GrpcChannel channel = GrpcChannel.ForAddress(daprUri);
    var client = new Dapr.Client.Grpc.Dapr.DaprClient(channel);

    InvokeServiceResponseEnvelope result = await client.InvokeServiceAsync(new InvokeServiceEnvelope
    {
        Method = "GetAllProducts",
        Id = "productService",
        Data = Any.Pack(new ProductListRequest())
    });
    ProductList.V1.ProductList productResult = ProductList.V1.ProductList.Parser.ParseFrom(result.Data.Value);

    var random = new Random();

    foreach (Product item in productResult.Results)
    {
        _storageContext.Storage.Add(new Storage
        {
            ProductID = Guid.Parse(item.ID),
            Amount = random.Next(1, 1000)
        });
    }

    await _storageContext.SaveChangesAsync();
    return true;
}

啟動 StorageService

dapr run --app-id storageService --app-port 5003 dotnet run

使用 Postman 請求 StorageService 的 InitialStorage
使用 MySql Workbench 檢視結果

小結
至此，以 Dapr 框架使用 GRPC 客戶端在 StorageService 中完成了對 ProductService 服務的呼叫。

原始碼地

Dapr 運用之整合 Asp.Net Core Grpc 呼叫篇

前置條件：《Dapr 運用》改造 ProductService 以提供 gRPC 服務從 NuGet 或程式包管理控制檯安裝 gRPC 服務必須的包 Grpc.AspNetCore 配置 Http/2 gRPC 服務需要 Http/2 協議 public static IHostBuilder

.NET Core實戰專案之CMS 第二章入門篇-快速入門ASP.NET Core看這篇就夠了

作者：依樂祝原文連結：https://www.cnblogs.com/yilezhu/p/9985451.html 本來這篇只是想簡單介紹下ASP.NET Core MVC專案的（畢竟要照顧到很多新手朋友），但是轉念一想不如來點猛的（考慮到急性子的朋友），讓你通過本

ASP.NET Core gRPC 使用 Consul 服務註冊發現

一. 前言 gRPC 在當前最常見的應用就是在微服務場景中，所以不可避免的會有服務註冊與發現問題，我們使用gRPC實現的服務可以使用 Consul 或者 etcd 作為服務註冊與發現中心，本文主要介紹Consul。二. Consul 介紹 Consul是一種服務網路解決方案，可跨任何執行平臺以及公共或私有云

前端 JS/TS 呼叫 ASP.NET Core gRPC-Web

前言在上兩篇文章中，介紹了ASP.NET Core 中的 gRPC-Web 實現和在 Blazor WebAssembly 中使用 gRPC-Web，實現了 Blazor WebAssembly 呼叫 ASP.NET Core gRPC-Web。雖然 ASP.NET Core 中的 gRPC-Web 實

舊 WCF 專案遷移到 asp.net core + gRPC 的嘗試

一個月前，公司的執行WCF的windows伺服器down掉了，由於 AWS 沒有通知，沒有能**第一時間**發現問題。所以，客戶提出將WCF服務由C#改為JAVA，在Linux上面執行；一方面，AWS對Linux有較多的監控措施，另一方面，假如出現問題，可以設定自動重啟等服務。 # 老舊的WCF

從零搭建一個IdentityServer——整合Asp.net core Identity

　　前面的文章使用Asp.net core 5.0以及IdentityServer4搭建了一個基礎的驗證伺服器，並實現了基於客戶端證書的Oauth2.0授權流程，以及通過access token訪問被保護資源，本文將繼續完善IdentityServer實現與Identity元件的整合，可使用Identity的

Asp.Net Core Grpc 入門實踐

# Grpc簡介 gRPC 是一種與語言無關的高效能遠端過程呼叫 (RPC) 框架。在 gRPC 中，客戶端應用程式可以直接呼叫不同計算機上的伺服器應用程式上的方法，就像它是本地物件一樣，從而更輕鬆地建立分散式應用程式和服務。它基於定義服務的想法，指定了引數和返回型別的遠端過程呼叫的方法。伺服器端實現這個介

ASP.NET Core[原始碼分析篇] - 認證

　　追本溯源，從使用開始　　　　首先看一下我們的通常是如何使用微軟自帶的認證，一般在Startup裡面配置我們所需的依賴認證服務，這裡通過JWT的認證方式講解 public void ConfigureServices(IServiceCollection services) { ser

ASP.NET Core[原始碼分析篇] - Startup

　應用啟動的重要類 - Startup 　　在ASP.NET Core - 從Program和Startup開始這篇文章裡面，我們知道了Startup這個類的重要性，它主要負責了：配置應用需要的服務（服務註冊，ConfigureServices方法）。建立應用的請求處理處理

ASP.NET Core[原始碼分析篇] - WebHost

　_configureServicesDelegates的承接　　在【ASP.NET Core[原始碼分析篇] - Startup】這篇文章中，我們得知了目前為止（UseStartup），所有的動作都是在_configureServicesDelegates裡面添加了註冊的委託，那麼系統是什麼時候執行這些

Captcha服務（後續2）— 改造Captcha服務之Asp.Net Core專案中如何整合TypeScript

環境準備 .Net Core 版本：下載安裝.Net Core SDK，安裝完成之後檢視sdk版本，檢視命令dotnet --version，我的版本是2.2.101 IDE： Visual Studio 2017 目標：將我的GitHub專案 Captcha.WebApi 改造，在專案中使用TypeS

asp.net core mcroservices 架構之分散式日誌（三）：整合kafka

一 kafka介紹

ASP.NET Core WebAPI圖片上傳介面之整合IdentityServer4授權訪問（附原始碼）

點選上方“程式設計師大咖”，選擇“置頂公眾號”關鍵時刻，第一時間送達！來源：依樂祝cnblogs

ASP.NET Core之跨平臺的實時性能監控

js應用程序的8個關鍵性能指標以及測量方法最後賣了個小關子,是關於如何監控ASP.NET Core的.今天我們就來講講如何監控它,下面上效果圖: 閱讀本文需要了解的相關技術與內容:InfluxDb(分布式時序數據庫,開源)(註:分布式部分已商業化最新的分布式版本已不在開源,單例的繼續開源)Grafana(開源

ASP.NET Core學習之三 NLog日誌

width itl .com 添加引用 manage skip mono cas ans 上一篇簡單介紹了日誌的使用方法，也僅僅是用來做下學習，更何況只能在console輸出。 NLog已是日誌庫的一員大佬，使用也簡單方便，本文介紹的環境是居於.NET CORE 2.0

ASP.NET CORE系列【六】Entity Framework Core 之數據庫遷移

snapshot 文章 src AD data 上下 ont pre 發生前言最近打算用.NET Core寫一份簡單的後臺系統,來練練手然後又用到了Entity Framework Core 發現園子裏有些文章講得不是那麽細節，對於新手小白來說，可能會有點懵。特意

asp.net core 微信支付工具類（H5支付，掃碼支付，公眾號支付，app支付）之2-H5支付

IV app支付 tno 方式 quest ces sys net ota 　　上一篇說到微信掃碼支付，今天來分享下微信H5支付，適用場景為手機端非微信瀏覽器調用微信H5支付驚醒網站支付業務處理。申請開通微信H5支付工作不多做介紹，直接上代碼。　　首先是微信支付業務類（W

Asp.Net Core 之 @Html.Action 遷移

ML csdn core catch true ESS 方法 actor AS 想必只要接觸了 net core的小夥伴們已經發現 @html.Action()方法官方已經不提供支持了，轉而使用 ViewComponents替代了，同時也增加了TagHelper。但是

微服務介紹及Asp.net Core實戰項目系列之微服務介紹

管理 col 數據強一致性 pan 基於數據存儲 tlab fdm 人的 0、目錄整體架構目錄：ASP.NET Core分布式項目實戰-目錄一、微服務選型在做微服務架構的技術選型的時候，以“無侵入”和“社區活躍”為主要的考量點，將來升級為原子服務架構、量子

asp.net core驗證碼(非原創，整合網上例子)

返回 cati view 例子 ica ace mem 一個 span 轉載原創）驗證碼參考網址： https://blog.csdn.net/ChaITSimpleLove/article/details/80531791 首先通過Nuget： Install-P

Dapr 運用之整合 Asp.Net Core Grpc 呼叫篇

改造 ProductService 以提供 gRPC 服務

改造 StorageService 服務以完成 Dapr GRPC 服務呼叫

相關推薦