java - 我可以在同一端口上运行多个 GRPC 服务吗-6ren

java - 我可以在同一端口上运行多个 GRPC 服务吗

转载作者：搜寻专家更新时间：2023-11-01 03:45:51

35

4

<分区>

我正在处理 gRPC，我想在同一个端口上运行多个服务

Server server = ServerBuilder.forPort(8080)
    .addService(new HelloServiceImpl())
    .addService(new ByeServiceImpl())
    .build();

这是在同一端口上运行多个 GRPC 服务的正确方法吗？完整代码如下。

HelloWorld.proto

syntax = "proto3";

option java_multiple_files = true;

package proto3.rpc;

message HelloRequest {
    string firstName = 1;
    string lastName = 2;
}

message HelloResponse {
    string greeting = 1;
}

service HelloService {
    rpc hello(HelloRequest) returns (HelloResponse);
}

ByWorld.proto

syntax = "proto3";

option java_multiple_files = true;

package proto3.rpc;

message ByeRequest {
    string firstName = 1;
    string lastName = 2;
}

message ByeResponse {
    string greeting = 1;
}

service ByeService {
    rpc bye(ByeRequest) returns (ByeResponse);
}

HelloServiceImpl.java

public class HelloServiceImpl extends HelloServiceImplBase{

    @Override
    public void hello(
        HelloRequest request,
        StreamObserver<HelloResponse> responseObserver){

        String greeting = new StringBuilder()
            .append("Hello, ")
            .append(request.getFirstName())
            .append(" ")
            .append(request.getLastName())
            .toString();

        HelloResponse helloResponse = HelloResponse.newBuilder()
            .setGreeting(greeting)
            .build();

        responseObserver.onNext(helloResponse);
        responseObserver.onCompleted();  
    }

}

ByeServiceImpl.java

public class ByeServiceImpl extends ByeServiceImplBase{

    @Override
    public void bye(
        ByeRequest request,
        StreamObserver<ByeResponse> responseObserver){

        String greeting = new StringBuilder()
            .append("Bye, ")
            .append(request.getFirstName())
            .append(" ")
            .append(request.getLastName())
            .toString();

        ByeResponse byeResponse = ByeResponse.newBuilder()
            .setGreeting(greeting)
            .build();

        responseObserver.onNext(byeResponse);
        responseObserver.onCompleted();  
    }

}

GrpcServer.java

public class GrpcServer {

    public static void main(String args[]) {
        Server server = ServerBuilder.forPort(8080)
    .addService(new HelloServiceImpl())
    .addService(new ByeServiceImpl())
    .build();

        try {
            server.start();
            server.awaitTermination();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}

GrpcClient.java

public class GrpcClient {

    public static void main(String args[]){

        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 8080)
            .usePlaintext()
            .build();

        HelloServiceGrpc.HelloServiceBlockingStub stub
            = HelloServiceGrpc.newBlockingStub(channel);    

        HelloResponse helloResponse = stub.hello(HelloRequest.newBuilder()
            .setFirstName("Azeem")
            .setLastName("Haider")
            .build()
        );    

        System.out.println("Hello Service...");
        System.out.println(helloResponse.getGreeting());    

        ByeServiceGrpc.ByeServiceBlockingStub stubBye
            = ByeServiceGrpc.newBlockingStub(channel);    

        ByeResponse byeResponse = stubBye.bye(ByeRequest.newBuilder()
            .setFirstName("Azeem")
            .setLastName("Haider")
            .build()
        );    


        System.out.println("Bye Service...");
        System.out.println(byeResponse.getGreeting());    

        channel.shutdown(); 
    }

}

输出

Hello Service...
Hello Azeem Haider

Bye Service...
Bye Azeem Haider

我知道这两个 Services 文件看起来非常相似，但这只是我们如何在同一个 IP:PORT 上运行多个服务的例子，我正在使用这种方式是吗有什么好的方法或者有更好的方法吗？

35

4

0

文章推荐： java - 不能写字段名，需要一个值

文章推荐： java - 处理:弧码只创建圆。如何正确识别起始值和终止值

文章推荐： java - "String[]::new"是什么意思？

文章推荐： java - JHipster 6.0.1 docker-compose 部署 : Java heap space

grpc - gRPC 健康检查是否应该仅限于 gRPC 服务？
关于 gRPC Health Checking ，如果 gRPC 服务托管在与其他也需要健康检查的 HTTP 服务相同的端口上，则对 grpc.health.v1.Health.Check 的响应应该
grpc - grpc 客户端和服务端的共享内存
我的项目是读取服务器中的图像，进行一些处理，然后将整个图像传递给客户端。客户端占用图像并进行更多处理，并将一些输出值返回给服务器。服务器和客户端之间使用的图像大小为 [640x480x3]。以下是我
grpc - 为什么浏览器不支持 gRPC？
gRPC 基于 HTTP/2，它(假设)被浏览器广泛支持。因此，我觉得从浏览器使用 gRPC 应该没有问题。但是，很明显存在问题。协议(protocol)，grpc web , 是不同的，因为“由于
grpc - gRPC 是否重新发送消息
关于服务器端代码的幂等性的问题，或者说它的必要性。对于一般的 gRPC，或者专门针对 java 实现。当我们从客户端发送消息一次时，是否有可能由我们的服务实现处理两次？也许这与服务似乎不可用时的重试
grpc - grpc 流媒体可以持续多久
假设我想使用 Grpc Server 流式传输或双向流式传输。考虑到它在底层使用 http/2，流可以持续多长时间是否有任何限制？如果是的话，它可以用来代替消息总线，这样流就可以打开并存活多久？
grpc - gRPC 中丰富的错误处理模式
使用 gRPC 向客户端发送有关错误的更多详细信息的模式是什么？例如，假设我有一个用于注册用户的表单，用于发送消息 message RegisterUser { string email = 1
grpc - 一个 GRPC channel 请求是否会在 GRPC 服务器端生成一个新线程？
我是 GRPC 的新手。我想知道当 GRPC 客户端启动一个请求时，服务器是否启动一个新线程来处理。最佳答案最多可能有一个 Runnable加入 Server's executor用于申请处理。每
grpc - 如何使用 Grpc 流式传输数组？
我想传输一个 int64 数组。我查了一下如何使用它。在我的原型(prototype)文件中，我需要一个流: service myService { rpc GetValues(myRequ
grpc - 如何取消 GRPC 流式调用？
通常，客户端可以通过以下方式取消 gRPC 调用: (requestObserver as ClientCallStreamObserver) .cancel("Cancelled", nul
grpc - 如何最大化 grpc 吞吐量？
在 100Gb 网络上，我创建了一个服务器来监听 4 个端口，grpc 客户端可以达到 3GB+/s 的吞吐量。然而，当服务器监听一个端口时，grpc 客户端达到了 1GB/s 的吞吐量，即使我设置了
grpc - 在服务器拦截器中应答 gRPC 调用
我想验证调用并可能在服务器拦截器中回答错误。有没有办法做到这一点？如果是，我该如何实现？最佳答案简单地从拦截器响应 RPC，可能通过调用 close() ，不要调用next .您仍然需要返回一个监
grpc - 一般转发 GRPC 调用
我有一个 GRPC API，经过重构，一些包被重命名。这包括我们定义 API 的原型(prototype)文件之一中的 package 声明。像这样的: package foo; service Ba
grpc - 如何自定义安装从源 grpc 编译的？
我想在 Ubuntu 上使用源代码中的所有子模块编译 grpc，并将其安装到/usr/local 以外的指定位置为提供的 Makefile 指定此位置的方法是什么(类似于配置脚本的 --prefix
javascript - DeprecationWarning : grpc. 改为加载 : Use the @grpc/proto-loader module with grpc. loadPackageDefinition
我不断在控制台中收到此警告: DeprecationWarning: grpc.load: Use the @grpc/proto-loader module with grpc.loadPackag
c# - Grpc.授权 : Could not load type 'Grpc.Core.CallCredentials' from assembly 'Grpc.Core.Api'
上下文我正在尝试使用 Google 的 Cloud Natural Language API。我有我的服务帐户 key JSON 文件，并且正在尝试编写一个简单的 .NET Core 应用程序(更具
ios - 用户遇到与 Firestore Pod 内部 grpc::ClientAsyncReaderWriter::Finish 相关的崩溃
用户在测试中遇到了此崩溃。我的第一个猜测是这与内存有关，但除此之外我没有什么可做的。更深入地研究代码，我认为这可能是主线程问题，但看起来监听器在后台线程上被删除，所以我怀疑这就是原因。我认为在应用程
grpc-java - grpc-health-probe(Kubernetes 上的 gRPC 健康检查)如何区分 liveness 和 readiness 探针
我正在编写一个 grpc 服务并在 Kubernetes (https://github.com/grpc-ecosystem/grpc-health-probe) 上使用 gRPC 健康检查。在我的
grpc - 在 grpc-java 中处理网络错误
如何使用 gRPC-java 实现检测网络错误并尝试从中恢复的策略？我知道 UNAVAILABLE 状态可能意味着网络错误，但这并没有告诉我它是哪种网络错误 - 并且 UNAVAILABLE 也可以从
grpc - 使用 gRPC 服务定义作为多个实例的接口(interface)
假设我们有一个 Search-Service service Search { rpc Search (SearchRequest) returns (SearchReply) {} } mess
grpc - 为什么 grpc-web 需要特使代理？
如果浏览器支持http/2，为什么 grpc-web 需要 envoy 代理？不支持 http/2 的旧浏览器是否只需要它？最佳答案回答于 https://github.com/grpc/grp

首页

博学

6Ren·AI

商城

java - 我可以在同一端口上运行多个 GRPC 服务吗