Java中GRPC的NewBlockingStub中的异常线程

Question

我是GRPC的新手。使用原始文件创建Java存根后，我在发送new Blocking生成的Java存根文件的loginapi从客户端发送存根。服务器正在启动，但客户端获得了例外。

客户端代码：

userBlockingStub userStub = userGrpc.newBlockingStub(channel);

生成的Java存根文件：

public static userBlockingStub newBlockingStub(io.grpc.Channel channel) {
    return new userBlockingStub(channel);
}

获取此例外：

Exception in thread "main" java.lang.Error: Unresolved compilation problem: 

at com.grpc.userGrpc.newBlockingStub(userGrpc.java:106)
at grpcClient.grpcClient.main(grpcClient.java:19)

有任何解决方案吗？

Answer 1

首先，当您尝试实现grpc通信时，因此您可能拥有多个服务（项目），您希望将它们传达给它们。

我本人实现了一个单独的项目grpc-interface并将其添加到git存储库中，然后我可以使用git-submodule subpodule代码>我需要传达的服务（项目）的功能。

我实现了我的grpc-interface如下：

这是我的build.gradle文件，您可以找到带有小R＆amp; d的maven版本也很容易：

buildscript {
    ext {
        protobufVersion = '3.19.1'
        protobufPluginVersion = '0.8.18'
        grpcVersion = '1.44.0'
        protobufJava = '3.19.4'
    }
}

plugins {
    id 'java'
    id 'com.google.protobuf' version "${protobufPluginVersion}"
}

group = 'com.ada.bourse.grpc-interface'
version = '0.0.1-SNAPSHOT'

dependencies {
    implementation "io.grpc:grpc-protobuf:${grpcVersion}"
    implementation "io.grpc:grpc-stub:${grpcVersion}"
    implementation "com.google.protobuf:protobuf-java:${protobufJava}"
    compileOnly 'jakarta.annotation:jakarta.annotation-api:1.3.5' // Java 9+ compatibility - Do NOT update to 2.0.0
}

protobuf {
    protoc {
        artifact = "com.google.protobuf:protoc:${protobufVersion}"
    }
    generatedFilesBaseDir = "$projectDir/src/generated"
    clean {
        delete generatedFilesBaseDir
    }
    plugins {
        grpc {
            artifact = "io.grpc:protoc-gen-grpc-java:${grpcVersion}"
        }
    }
    generateProtoTasks {
        all()*.plugins {
            grpc {}
        }
    }
}

repositories {
    mavenCentral()
}

然后我创建了一个.proto文件来介绍我的服务及其请求和响应模型：

syntax = "proto3";

package com.ada.bourse.grpc.accounting;

option java_multiple_files = true;
option java_package = "com.ada.bourse.grpc.accounting";

service AccountingService {
  rpc userBalance(UserBalanceRequest) returns (UserBalanceResponse) {
  }
}

message UserBalanceRequest {
  string username = 1;
}

message UserBalanceResponse {
  double balance = 1;
}

在此步骤之后，您需要编译该项目，并且将导致使用生成的在您的main软件包旁边的名称。

然后，正如我说的那样，如果您将该项目放入诸如git之类的存储库中，则需要使用git-submodule功能将其添加到您的项目中，当然，还有其他方法可以将其添加到您的项目中项目和git-submodule不是必须的！

只需考虑一下，将此模块添加到项目之后，在运行和编译主项目之前，您需要编译grpc-interface，以便您的项目可以使用生成的文件喜欢：

现在我有两个服务，名为withs-manager和会计>会计我想传达，正如您在我的.proto文件中看到的那样，我希望我的财富服务来请求并从我的Accounting服务中检查用户余额。

在我的财富服务中，我在服务层中所做的服务：

@Service
public class RestrictionServiceImpl implements IRestrictionService {

    @GrpcClient("accounting-service")
    private AccountingServiceGrpc.AccountingServiceBlockingStub accountingServiceStub;

private void checkUserBalanceForBuyOrder(RestrictionFilterCriteria filterCriteria) {
        Double userBalance = getUserBalanceFromAccountingServiceGrpc(filterCriteria.getUsername());
        if (userBalance < filterCriteria.getAmount() * filterCriteria.getPrice())
            throw new RestrictionException(new BaseException.ErrorDetail()
                    .setLoc("balance")
                    .setType(Constant.INSUFFICIENT_BALANCE));
    }

    private Double getUserBalanceFromAccountingServiceGrpc(String username) throws GrpcConnectionException {
        UserBalanceRequest request = UserBalanceRequest.newBuilder()
                .setUsername(username)
                .build();
        return accountingServiceStub.userBalance(request).getBalance();
    }

}

以及在我的Accounting服务中，我为grpc服务创建了类：

@GrpcService
public class AccountingServiceGRPC extends AccountingServiceGrpc.AccountingServiceImplBase {

    private final IUserAccountService userAccountService;

    public AccountingServiceGRPC(IUserAccountService userAccountService) {
        this.userAccountService = userAccountService;
    }

    @Override
    public void userBalance(UserBalanceRequest request, StreamObserver<UserBalanceResponse> responseObserver) {
        UserBalanceResponse balanceResponse = UserBalanceResponse.newBuilder()
                .setBalance(userAccountService.getUserBalance(request.getUsername()))
                .build();
        responseObserver.onNext(balanceResponse);
        responseObserver.onCompleted();
    }
}

我本人曾与grpc争论很多，直到我可以解决它，希望我的经验也可以帮助您解决自己的能力。