3

我有一个简单的 proto 文件，用于创建我的 java 类

syntax = "proto3";

option java_package = "some.project.grpc";
option java_multiple_files = true;

message PingRequest { }
message PingResponse { }

service MyServer {
    rpc Ping(PingRequest) returns (PingResponse);
}

使用 gradle 和 google protobuf 插件（https://github.com/google/protobuf-gradle-plugin）我创建我的类

gradle generateProto

生成MyServerGrpc的有一个内部类MyServerBlockingStub，它有两个构造函数：

private MyServerBlockingStub(io.grpc.Channel channel) { ... }
private MyServerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { ... }

该MyServerGrpc课程确实公开了第一个，newBlockingStub(io.grpc.Channel channel)但不是第二个 - 这是我需要的。

像这样，我无法设置任何调用选项，例如超时。我可以轻松地操作生成的文件以允许我访问我需要的构造函数，但是这些更改将在下一代丢失 - 所以它不是一个真正的选择。

因为这看起来很容易解决，所以我在想：

  • 我是否错过了一些将这个构造函数暴露给我的选项？
  • 是否打算将CallOptions对象设置在我尚未找到的其他地方？
4

1 回答 1

6

MyServerGrpc延伸AbstractStub。AbstractStub具有with*反映CallOptions.

所以你想做这样的事情：

newBlockingStub(yourChannel).withDeadlineAfter(1, TimeUnit.MINUTES)
于 2015-11-19T17:53:20.143 回答