将gRPC服务绑定到aspnetcore中的特定端口

如何解决将gRPC服务绑定到aspnetcore中的特定端口

使用aspnetcore 3.1Grpc.AspNetCore nuget软件包,我已经成功地使gRPC服务与this tutorial中所述的标准asp.net控制器一起成功运行。

但是我想将gRPC服务绑定到特定端口(例如5001),最好尽可能通过配置而不是代码。这是因为我想限制gRPC服务的公开方式。

映射端点时,我最近使用过RequireHost

// Startup.cs
public void Configure(IApplicationBuilder app)
{
    // ...
    
    app.useEndpoints(endpoints => 
    {
        endpoints.MapGrpcService<MyService>()
            .RequireHost("0.0.0.0:5001");
    }); 
}

这似乎可以满足我的要求,但是我找不到关于它的任何文档,并且它需要在每个服务的代码中进行配置。也许有更好的方法?

解决方法

据我所知,没有其他方法可以为GRPC服务设置特定端口。

grpc服务也在asp.net核心Kestrel服务器上运行,该服务器将侦听端口而不是该服务。

如果您的asp.net核心应用程序仅具有GRPC服务,则可以将Kestrel服务器的侦听端口设置为5001。

如果您具有MVC Web API等多种服务,RequireHost是最好的解决方法,仅允许特定端口访问grpc服务。

如果要提示路由系统输入GRPC服务需要指定的端口,则可以使用以下端口:

 routes.MapGrpcService<MyService>().RequireHost("*:5001");
,

这在Kestrel上(服务器端)有效:

public static IHostBuilder CreateHostBuilder(string[] args) =>
Host.CreateDefaultBuilder(args)
.ConfigureWebHostDefaults(webBuilder =>
{
    webBuilder.ConfigureKestrel(options =>
    {
       options.Listen(IPAddress.Loopback,5000);
       options.Listen(IPAddress.Loopback,5005,configure => configure.UseHttps());
    });
    webBuilder.UseStartup<Startup>();
});

客户端:

 var httpHandler = new HttpClientHandler
 {
     ServerCertificateCustomValidationCallback =
     HttpClientHandler.DangerousAcceptAnyServerCertificateValidator
 };  

AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport",true);
                
using var channel = GrpcChannel.ForAddress("https://localhost:5005",new GrpcChannelOptions { HttpHandler = httpHandler } );
            
var client = new Greeter.GreeterClient(channel);

注意:

 var httpHandler = new HttpClientHandler
 {
     ServerCertificateCustomValidationCallback =
     HttpClientHandler.DangerousAcceptAnyServerCertificateValidator
 };  

拥有没有信任链的自签名证书时(通常是在开发时)。

AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport",true);

是对http的支持。

,

您可以尝试使用 UseWhen 方法,仅当请求使用您定义的端口时才使用 MapGrpcService 端点。

var grpcPort = 5001;
app.UseWhen(context => context.Connection.LocalPort == grpcPort,builder =>
    {
        builder.UseRouting();
        builder.UseEndpoints(endpoints =>
        {
            endpoints.MapGrpcService<MyService>();
        });
    });

这样做的好处是不会对每个服务都重复 .RequireHost("*:5001");,尽管重复 UseRouting 两次可能会导致奇怪的行为:例如,除非您输入 builder.UseAuthentication(),否则身份验证可能无法工作builder.UseRouting() 之后。

但是,如果您希望为 REST 和 gRPC 提供不同的请求管道,则此行为很有用。

,

需要配置中间件

app.UseRouting();
app.MapWhen(context => {
   return context.Connection.LocalPort == 1000
},newApp => {
   newApp.UseRouting();
   newApp.UseEndpoints(endpoints =>
   {
        endpoints.MapGrpcService<Service1>();
   }
});
app.MapWhen(context => {
   return context.Connection.LocalPort == 2000
},newApp => {
   newApp.UseRouting();
   newApp.UseEndpoints(endpoints =>
   {
        endpoints.MapGrpcService<Service2>();
   }
});

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?