我的 gRPC Java 客户端使用套接字连接到服务器 Java NIO,并且 NIO 将请求的客户端传输到服务器 gRPC 但服务器没有响应。
我的客户端 gRPC 代码:
private final ManagedChannel channel;
private final MyServiceProviderGrpc.MyServiceProviderBlockingStub blockingStub;
private final MyServiceProviderGrpc.MyServiceProviderStub asyncStub;
public ClientGrpc(String host, int port)
{
this(ManagedChannelBuilder.forAddress(host, port).usePlaintext(true));
}
ClientGrpc(ManagedChannelBuilder<?> channelBuilder)
{
channel = channelBuilder.build();
blockingStub = MyServiceProviderGrpc.newBlockingStub(channel);
asyncStub = MyServiceProviderGrpc.newStub(channel); }
public void greet(String name) {
logger.info("Will try to greet " + name + " ...");
TemperatureRequest request = TemperatureRequest.newBuilder().setQuestion(name).build();
TemperatureResponse response;
try
{
response = blockingStub.getTemperature(request);
} catch (StatusRuntimeException e)
{
logger.info("RPC failed: {0}"+ e.getStatus());
return;
}
logger.info("Greeting: " + response.getAnswer()); }
ClientGrpc clients = new ClientGrpc("localhost",4321);
clients.greet("bap");
我在 NIO 中收到一条消息:
优先级 * HTTP/2.0
SM