[C#/COMMON/GRPC/.NET6] Grpc.Tools 누겟 설치하기
■ Grpc.Tools 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.
[카테고리:] GRPC
[C#/COMMON/GRPC/.NET6] GRPC 스트리밍 사용하기
■ GRPC 스트리밍을 사용하는 방법을 보여준다. [TestServer 프로젝트] ▶ weather.proto
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
syntax = "proto3"; import "google/protobuf/empty.proto"; import "google/protobuf/timestamp.proto"; option csharp_namespace = "TestServer"; package weather; // 일기예보 프로토 service WeatherForecastProto { rpc GetWeatherStream (google.protobuf.Empty) returns (stream WeatherForecastModel); } // 일기예보 모델 message WeatherForecastModel { google.protobuf.Timestamp dateTimeStamp = 1; int32 temperatureC = 2; int32 temperatureF = 3; string summary = 4; } |
▶ WeatherForecastService.cs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 |
using Google.Protobuf.WellKnownTypes; using Grpc.Core; namespace TestServer.Services { /// <summary> /// 일기예보 서비스 /// </summary> public class WeatherForecastService : WeatherForecastProto.WeatherForecastProtoBase { //////////////////////////////////////////////////////////////////////////////////////////////////// Field ////////////////////////////////////////////////////////////////////////////////////////// Private #region Field /// <summary> /// 로거 /// </summary> private readonly ILogger<WeatherForecastService> logger; #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor ////////////////////////////////////////////////////////////////////////////////////////// Public #region 생성자 - WeatherForecastService(logger) /// <summary> /// 생성자 /// </summary> /// <param name="logger">로거</param> public WeatherForecastService(ILogger<WeatherForecastService> logger) => this.logger = logger; #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Method ////////////////////////////////////////////////////////////////////////////////////////// Public #region 기상 스트림 구하기 - GetWeatherStream(_, responseStream, context) /// <summary> /// 기상 스트림 구하기 /// </summary> /// <param name="_">_</param> /// <param name="responseStream">응답 스트림</param> /// <param name="context">컨텍스트</param> /// <returns>태스크</returns> public override async Task GetWeatherStream(Empty _, IServerStreamWriter<WeatherForecastModel> responseStream, ServerCallContext context) { Random random = new Random(); DateTime currentTime = DateTime.UtcNow; int i = 0; while(!context.CancellationToken.IsCancellationRequested && i < 20) { await Task.Delay(500); WeatherForecastModel weatherForecast = new WeatherForecastModel { DateTimeStamp = Timestamp.FromDateTime(currentTime.AddDays(i++)), TemperatureC = random.Next(-20, 55), Summary = string.Empty }; logger.LogInformation("Sending WeatherData response"); await responseStream.WriteAsync(weatherForecast); } } #endregion } } |
▶ Program.cs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
using TestServer.Services; var builder = WebApplication.CreateBuilder(args); builder.Services.AddGrpc(); var app = builder.Build(); app.UseRouting(); app.UseEndpoints ( endpoints => { endpoints.MapGrpcService<WeatherForecastService>(); } ); app.Run(); |
[TestClient 프로젝트] ▶ weather.proto
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
syntax = "proto3"; import "google/protobuf/empty.proto"; import "google/protobuf/timestamp.proto"; option csharp_namespace = "TestClient"; package weather; // 일기예보 프로토 service WeatherForecastProto { rpc GetWeatherStream (google.protobuf.Empty) returns (stream WeatherForecastModel); } // 일기예보 모델 message WeatherForecastModel { google.protobuf.Timestamp dateTimeStamp = 1; int32 temperatureC = 2; int32 temperatureF = 3; string summary = 4; } |
[C#/COMMON/GRPC/.NET6] GRPC 사용하기
■ GRPC를 사용하는 방법을 보여준다. [TestServer 프로젝트] ▶ hello.proto
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
syntax = "proto3"; option csharp_namespace = "TestServer"; package hello; // 헬로우 프로토 service HelloProto { rpc SayHello (HelloRequest) returns (HelloReply); } // 헬로우 요청 message HelloRequest { string name = 1; } // 헬로우 응답 message HelloReply { string message = 1; } |
▶ HelloService.cs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
using Grpc.Core; namespace TestServer.Services; /// <summary> /// 헬로우 서비스 /// </summary> public class HelloService : HelloProto.HelloProtoBase { //////////////////////////////////////////////////////////////////////////////////////////////////// Field ////////////////////////////////////////////////////////////////////////////////////////// Private #region Field /// <summary> /// 로거 /// </summary> private readonly ILogger<HelloService> logger; #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor ////////////////////////////////////////////////////////////////////////////////////////// Public #region 생성자 - HelloService(logger) /// <summary> /// 생성자 /// </summary> /// <param name="logger">로거</param> public HelloService(ILogger<HelloService> logger) { this.logger = logger; } #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Method ////////////////////////////////////////////////////////////////////////////////////////// Public #region 헬로우 말하기 - SayHello(request, context) /// <summary> /// 헬로우 말하기 /// </summary> /// <param name="request">요청</param> /// <param name="context">컨텍스트</param> /// <returns>응답 태스크</returns> public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context) { return Task.FromResult ( new HelloReply { Message = "Hello " + request.Name } ); } #endregion } |
▶ Program.cs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
using TestServer.Services; var builder = WebApplication.CreateBuilder(args); builder.Services.AddGrpc(); var app = builder.Build(); app.MapGrpcService<HelloService>(); app.MapGet ( "/", () => "gRPC 끝점과의 통신은 gRPC 클라이언트를 통해 이루어져야 합니다." ); app.Run(); |
[TestClient 프로젝트] ▶ hello.proto
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
syntax = "proto3"; option csharp_namespace = "TestClient"; package hello; // 헬로우 프로토 service HelloProto { rpc SayHello (HelloRequest) returns (HelloReply); } // 헬로우 요청 message HelloRequest { string name = 1; } // 헬로우 응답 message HelloReply { string message = 1; } |
▶