.Net6 WebAPI 手动开启gRPC服务

引用包

开启服务

  // Add services to the container.
            builder.Services.AddGrpc();

配置gRPC通道

 // Configure the HTTP request pipeline.
            app.MapGrpcService<DataReceiver>();

完整代码

 public class Program
    {
        public static void Main(string[] args)
        {
            var builder = WebApplication.CreateBuilder(args);
        

            // Add services to the container. 
            builder.Services.AddControllers();

            // Add services to the container.
            builder.Services.AddGrpc();

    


            builder.Services.AddSignalR();

            // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
            builder.Services.AddEndpointsApiExplorer();
            builder.Services.AddSwaggerGen();

 

            var app = builder.Build();

            // Configure the HTTP request pipeline.
            //if (app.Environment.IsDevelopment())
            //{
            app.UseSwagger();
            app.UseSwaggerUI();
            //}

            app.UseStaticFiles();

            app.UseHttpsRedirection();

            app.UseAuthorization();


            app.MapControllers();

          

            // Configure the HTTP request pipeline.
            app.MapGrpcService<DataReceiver>();
           

            app.Run();
        }
    }

以上内容完成以后，按照上一篇文章http://t.csdn.cn/M6nZV进行配置协议和服务类就可以用了。

总结

新建一个Service.cs类，继承自生成的类后，重写处理方法（如果没有生成就先编译一下工程文件）

  public class GreeterService : Greeter.GreeterBase
    {
        private readonly ILogger<GreeterService> _logger;
        public GreeterService(ILogger<GreeterService> logger)
        {
            _logger = logger;
        }

        public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
        {
            Console.WriteLine($"接收到请求！{request.Name}");

            return Task.FromResult(new HelloReply
            {
                Message = "Hello " + request.Name
            });
        }

        public override Task<Empty> SayBye(Empty request, ServerCallContext context)
        {
            return base.SayBye(request, context);
        }
    }

注意命名空间