GRPC调用失败，错误为“从服务器收到数据帧上的意外EOS”

Question

我正在使用GRPC连接到服务。有时调用成功，有时调用失败，异常情况是从服务器收到数据帧上的意外EOS

我找不到这样做的原因。以下是代码生成通话：

public class LmServiceClientImpl implements LmServiceClient {

    LMAttributeServiceGatewayGrpc.LMAttributeServiceGatewayBlockingStub lmAttributeServiceGatewayBlockingStub;

    @Autowired
    @Qualifier("lmservice")
    private ManagedChannel managedChannel;

    @PostConstruct
    public void init() {
        lmAttributeServiceGatewayBlockingStub = LMAttributeServiceGatewayGrpc.newBlockingStub(managedChannel);
    }

    @Override
    public LMAttributesApiProto.IpAttributeResponse getAttributes(
            final LMServiceProto.IpEntityRequest ipEntityRequest
    ) {
        try {
            log.info("Querying DLM service with payload {}",
                    JsonFormat.printer().print(ipEntityRequest.toBuilder()));
        } catch (final Exception e) {
            // No action required
        }
        final LMAttributesApiProto.IpAttributeResponse ipAttributeResponse =
                lmAttributeServiceGatewayBlockingStub.getAttributes(ipEntityRequest);

        try {
            log.info("Response from DLM service {}", JsonFormat.printer().print(ipAttributeResponse.toBuilder()));
        } catch (final Exception e) {
            // No action required
        }
        return ipAttributeResponse;
    }
}

ManagedChannel正在从以下类自动连接：

public class LmServiceGrpcConfig {

    @Value("${lm.server.host}")
    private String host;

    @Value("${lm.server.port}")
    private int port;

    @Bean("lmservice")
    public ManagedChannel prepareManagedChannel() {
        return NettyChannelBuilder.forAddress(host, port)
                .usePlaintext()
                .build();
    }

}

客户端依赖：

def grpcVersion = '1.26.0'
compile group: 'io.netty', name: 'netty-all', version: '4.1.44.Final'
    compile group: 'io.grpc', name: 'grpc-protobuf', version: "${grpcVersion}"
    compile group: 'io.grpc', name: 'grpc-stub', version: "${grpcVersion}"
    compile group: 'io.grpc', name: 'grpc-services', version: "${grpcVersion}"
    compile group: 'io.grpc', name: 'grpc-okhttp', version: "${grpcVersion}"
    compile 'com.google.protobuf:protobuf-java:3.5.1'
    compile 'com.google.protobuf:protobuf-java-util:3.5.1'

    compile group: "io.github.lognet", name: "grpc-spring-boot-starter", version: "3.4.1"

服务器位于golang，使用google。戈朗。org/grpc v1。25.1

不确定是什么导致了这个问题。请帮忙。我看过一些关于github问题的帖子，但这没有帮助。




Answer 1

匿名用户

我相信这条消息意味着请求超时了。特使通过发送“流结束”（EOS）消息来缩短流。

在服务器上，您可能还会看到如下内容：

akka.http.scaladsl.model.http2.PeerClosedStreamException: Stream with ID [15655] was closed by peer with code NO_ERROR(0x00)

根据请求超时特使文件：

此超时与流请求不兼容。