---

---

项目地址

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

• 代码仓库地址：

• 所用到的框架和插件：

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