【问题标题】:Java-grpc and tikv-java: NoSuchFieldError: CONTEXT_SPAN_KEYJava-grpc 和 tikv-java: NoSuchFieldError: CONTEXT_SPAN_KEY
【发布时间】:2019-12-24 12:07:08
【问题描述】:

我将 java-grpc 与 tikv-java 一起使用(它们分别工作正常)。但我一起努力解决以下错误:

Exception in thread "main" java.lang.NoSuchFieldError: CONTEXT_SPAN_KEY
        at io.grpc.internal.CensusTracingModule$TracingClientInterceptor.interceptCall(CensusTracingModule.java:327)
        at io.grpc.ClientInterceptors$InterceptorChannel.newCall(ClientInterceptors.java:104)
        at io.grpc.internal.ManagedChannelImpl.newCall(ManagedChannelImpl.java:551)
        at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:113)
        at com.pv.app.GetInsertServiceGrpc$GetInsertServiceBlockingStub.insert(GetInsertServiceGrpc.java:195)
        at com.pv.app.Client.main(Client.java:55)

我的代码客户端:

package com.pv.app;

import io.grpc.*;

public class Client {
  public static void main(String[] args) throws Exception {
    // Channel is the abstraction to connect to a service endpoint
    // Let's use plaintext communication because we don't have certs
    final ManagedChannel channel =
        ManagedChannelBuilder.forTarget("0.0.0.0:8080").usePlaintext().build();


    GetInsertServiceGrpc.GetInsertServiceBlockingStub stub =
        GetInsertServiceGrpc.newBlockingStub(channel);
    GetInsertServiceOuterClass.HelloMessage request =
        GetInsertServiceOuterClass.HelloMessage.newBuilder().setName("hello").build();

    System.out.println(request);

    System.out.println("b4 req");

    // Finally, make the call using the stub
    stub.insert(request);

    channel.shutdownNow();
  }
}


我的代码服务器:

package com.pv.app;

import io.grpc.Server;
import io.grpc.ServerBuilder;



/** Hello world! */
public class App {
  public static void main(String[] args) throws Exception {

    System.out.println("Hello-start");
    Server server = ServerBuilder.forPort(8080).addService(new GetInsertServiceImpl()).build();

    // Start the server
    server.start();

    // Server threads are running in the background.
    System.out.println("Server started");
    // Don't exit the main thread. Wait until server is terminated.
    server.awaitTermination();

  }
}

我的代码实现:

package com.pv.app;


import org.tikv.common.TiConfiguration;
import org.tikv.common.TiSession;
import org.tikv.raw.RawKVClient;

public class GetInsertServiceImpl
    extends GetInsertServiceGrpc.GetInsertServiceImplBase {

  @Override
  public void insert(
      GetInsertServiceOuterClass.HelloMessage request,
      io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
    // HelloRequest has toString auto-generated.
    System.out.println("insert");
    System.out.println(request);
    TiConfiguration conf = TiConfiguration.createRawDefault("pd0:2379");
    System.out.println(1);
    System.out.println("2");
    System.out.println(conf);
    TiSession session = TiSession.create(conf);
    System.out.println("3");
    RawKVClient client = session.createRawClient();
    System.out.println("4");



    // When you are done, you must call onCompleted.
    responseObserver.onCompleted();
  }
}

我的原型:

syntax = "proto3";
import "google/protobuf/empty.proto";


option java_package = "com.pv.app";
// Request payload


message HelloMessage {

    string name = 1;

}

// Defining a Service, a Service can have multiple RPC operations
service GetInsertService {
    // Define a RPC operation
    rpc insert (HelloMessage) returns (google.protobuf.Empty) {
    };

}

我如何部署:

  • 在下载的回购client-java我做mvn clean install -Dmaven.test.skip=true
  • 在我的项目文件夹中
mvn install:install-file \
-Dfile=../client-java/target/tikv-client-java-2.0-SNAPSHOT.jar  \
-DgroupId=org.tikv \
-DartifactId=tikv-client-java \
-Dversion=2.0-SNAPSHOT \
-Dpackaging=jar
  • 在我的项目 pom.xml 中
<dependency>
  <groupId>org.tikv</groupId>
  <artifactId>tikv-client-java</artifactId>
  <version>2.0-SNAPSHOT</version>
</dependency>
  • 运行 java 8:
mvn -DskipTests package exec:java -Dexec.mainClass=com.pv.app.App  
mvn -DskipTests package exec:java -Dexec.mainClass=com.pv.app.Client 

有没有人建议如何解决?

完整代码可用here

我进行了搜索,尝试排除 grpc 和 opencensus,切换版本 - 没有帮助。

【问题讨论】:

  • 这看起来像一个依赖问题。您能否启用 Maven Enforcer 的 requireUpperBoundDeps 并查看它发现了什么问题?以github.com/grpc/grpc-java/blob/v1.26.0/examples/… 为例
  • @EricAnderson [INFO] --- maven-enforcer-plugin:1.4.1:enforce (enforce) @ tikv-connector --- [INFO] 。没有输出...
  • @EricAnderson 这里是项目的链接github.com/trthhrtz/grpc-tikv
  • 我猜与 grpc 和 tikv-java 库的依赖关系存在一些冲突。我试图从另一个中排除一个(阴影插件对某些重复项发出警告)但没有帮助
  • tikv-client-java 是标准库吗?因为我无法为其获取 maven 存储库,所以可用的 maven 存储库是: com.pingcap.tikvtikv-client2.0

标签: java maven grpc grpc-java tikv


【解决方案1】:

问题是由 io.opencensus 版本冲突引起的。我能够通过在 tikv/client-java 项目中对其进行着色来修复它。

在tikv/client-java、pom.xml、maven-shade-plugin配置中:

<relocations>
    ...
    <relocation>
        <pattern>io.opencensus</pattern>
        <shadedPattern>shade.io.opencensus</shadedPattern>
    </relocation>
<relocations>

更新

我刚刚意识到昨天合并到 master 的 pom.xml 发生了变化,所以如果你还没有更新它,你可能想更新它。

更新 2

我刚刚使用最新版本的 tikv/client-java 检查了您的项目。 NoSuchFieldError: CONTEXT_SPAN_KEY 不见了。还有其他错误(java.net.UnknownHostException),但它们并不相关。

【讨论】:

  • 正如@Mafor 所说,io.opencensus 冲突导致了问题。 tikv-java-client 将其 grpc 版本提升到 1.17.0 并带来了这个问题,因为它没有被遮蔽。有一个 PR 修复它并合并到 master。 @techkuz 你可以在这里查看:github.com/tikv/client-java/pull/75
猜你喜欢
  • 2022-01-22
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2018-08-20
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多