Java教程

Java GRPC超时机制

本文主要是介绍Java GRPC超时机制,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

所谓困难,则是激发个人抵制困难的机会,激发新能力的机会;

---

Java的gRPC没有没有Timeout机制,不过在其中增加了Deadline机制;但使用时容易出错,以下为我踩的几个坑;

引入gRPC超时机制的原因是因为其他服务请求gRPC所在服务,若gRPC一直执行不完,会导致任务堆积;

创建后持续报错:

io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: ClientCall started after deadline exceeded: -175.597476157s from now 这种超时时间特别长;观察我的实现是在init时添加了deadline,那么从init时就开始计时了,而当真正开始执行前,就已经超时了,因此导致了超时 于是进行了修改,修改为当开始执行的时候开始设置超时时间;   进行过上述修改后,依然会报错,但超时的时间缩短了,在日志中会出现io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: ClientCall started after deadline exceeded: -0.013832392s from now 但是添加StopWatch,真实操作时间并没有超时,这个问题是比较诡异的,尝试为设置时间和进行请求的过程加了一个锁,发现问题居然解决了;仔细看了代码,发现了问题所在,gRPC提供的deadline机制是非线程安全的;出现超时的原因也就呼之欲出了。、。。   展示代码: 初始化:
@PostConstruct
private void init() {
  tesseractServiceBlockingStub = initAuthGRCTesseractStub(tesseractGrpcUrl,
          tesseractToken);
}

////////
public TesseractServiceGrpc
        .TesseractServiceBlockingStub initAuthGRCTesseractStub(String url, String token) {
  log.info("oAuth GRPC Init url:{},interiorToken:{}", url, token);
  // 构建channel 单例
  ManagedChannel channel = genChannel(url);
  Metadata extraHeaders = genMetadata(token);
  TesseractServiceGrpc.TesseractServiceBlockingStub simpleStub = TesseractServiceGrpc
          .newBlockingStub(channel)
          .withInterceptors();
  TesseractServiceGrpc.TesseractServiceBlockingStub stub = MetadataUtils
          .attachHeaders(simpleStub, extraHeaders);
  log.info("Tesseract oAuth GRPC Init success");
  return stub;
}

注意:在初始化时不要设置超时时间

调用:(在调用时设置超时时间)

UserInfo userInfo;
synchronized(this.class){
   userInfo = stub
        .withDeadlineAfter(AUTH_MAX_TIMEOUT, TimeUnit.MICROSECONDS)
    .getUserInfo(token);
}

当然直接用synchronized不太优雅,同学们可以自行使用自认为更优雅的锁,只要保证在设置超时与进行gRPC在同一个锁内即可;

这篇关于Java GRPC超时机制的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!