---

---

項目地址

• 教程作者：
• 教程地址：

• 代碼倉庫地址：

• 所用到的框架和插件：

dbt 
airflow

一、grpc介紹

1.1 項目初始化

1. 創建grpc項目

2. 項目結構

• Protos：用來存放協議文件.proto，協議有三部分組成 1. service 2.rpc 3.message

二、Discount grpc創建

2.1 實體層

1. Coupon實體

namespace Discount.Grpc.Models;
public class Coupon
{public int Id { get; set; }public string ProductName { get; set; } = default!;public string Description { get; set; } = default!;public int Amount { get; set; }
}

2.2 Protos

1. 創建discount.proto

• 創建discount的proto，相當于接口

syntax = "proto3"; //類型
option csharp_namespace = "Discount.Grpc";
package discount; //自定義包名//服務定義
service DiscountProtoService {// Discount CRUD Operationsrpc GetDiscount (GetDiscountRequest) returns (CouponModel); //傳入GetDiscountRequest返回CouponModelrpc CreateDiscount (CreateDiscountRequest) returns (CouponModel); //傳入CreateDiscountRequest返回rpc UpdateDiscount (UpdateDiscountRequest) returns (CouponModel); //傳入UpdateDiscountRequestrpc DeleteDiscount (DeleteDiscountRequest) returns (DeleteDiscountResponse); //傳入DeleteDiscountRequest
}//GetDiscountRequest消息
message GetDiscountRequest {string productName = 1;
}
//定義CouponModel
message CouponModel {int32 id = 1;string productName = 2;string description = 3;int32 amount = 4;
}
//Create需要傳入完整的CouponModel
message CreateDiscountRequest {CouponModel coupon = 1;
}
// UpdateDiscountRequest需要傳入完整的CouponModel
message UpdateDiscountRequest {CouponModel coupon = 1;
}
// DeleteDiscountRequest只需要傳入productName
message DeleteDiscountRequest {string productName = 1;
}
// DeleteDiscountResponse只需要返回一個bool值
message DeleteDiscountResponse {bool success = 1;
}

2. 配置proto

• 配置成功，項目的配置中可以到

  <ItemGroup><Protobuf Include="Protos\discount.proto" GrpcServices="Server" /></ItemGroup>

3. 創建DiscountService

• DiscountService.cs：實現Proto的，使用Mapster

namespace Discount.Grpc.Services;public class DiscountService(DiscountContext dbContext, ILogger<DiscountService> logger): DiscountProtoService.DiscountProtoServiceBase
{    public override async Task<CouponModel> GetDiscount(GetDiscountRequest request, ServerCallContext context){//使用EF Core從數據庫中獲取折扣信息var coupon = await dbContext.Coupons.FirstOrDefaultAsync(x => x.ProductName == request.ProductName);if (coupon is null)coupon = new Coupon { ProductName