Couchbase并发超时异常：Java SDK

1 回答

• 5

  我在寻找答案 . 我得到了很多解决方案都在讨论异常 . 我还检查了jar代码，它被称为超时异常 .

  根本原因分析

  从couchbase的以下部分发生错误：https://github.com/couchbase/couchbase-java-client/blob/master/src/main/java/com/couchbase/client/java/util/Blocking.java#L71

  public static <T> T blockForSingle(final Observable<? extends T> observable, final long timeout,
      final TimeUnit tu) {
      final CountDownLatch latch = new CountDownLatch(1);
      TrackingSubscriber<T> subscriber = new TrackingSubscriber<T>(latch);
  
      observable.subscribe(subscriber);
  
      try {
          if (!latch.await(timeout, tu)) { // From here, this error occurs.
              throw new RuntimeException(new TimeoutException());
          }
  }
  

  如果超时启动，则抛出嵌套在RuntimeException中的TimeoutException，以与Observable.timeout（long，TimeUnit）行为完全兼容 .

  资源链接：

  http://docs.couchbase.com/sdk-api/couchbase-java-client-2.2.0/com/couchbase/client/java/util/Blocking.html

  您的配置分析和解决方案：

  您的couchbase环境connectionTimeout是 5000ms 或5sec，这是连接超时的默认值 .

  您需要将此值增加到 10000ms or greater . 你的问题将得到解决 .

  //this tunes the SDK (to customize connection timeout)
  CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder()
          .connectTimeout(10000) //10000ms = 10s, default is 5s
          .build();
  

  完整的解决方案

  Simonbasle在本教程中提供了完整的解决方案：

  从短日志中，看起来SDK能够连接到节点，但需要花费一些时间来打开存储桶 . 两台机器之间的网络连接有多好？这是VM / Cloud 计算机吗？您可以尝试做的是增加连接超时：

  public class NoSQLTest {
  public static void main(String[] args) {
          try {
              //this tunes the SDK (to customize connection timeout)
              CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder()
                      .connectTimeout(10000) //10000ms = 10s, default is 5s
                      .build();
              System.out.println("Create connection");
              //use the env during cluster creation to apply
              Cluster cluster = CouchbaseCluster.create(env, "10.115.224.94");
              System.out.println("Try to openBucket");
              Bucket bucket = cluster.openBucket("beer-sample"); //you can also force a greater timeout here (cluster.openBucket("beer-sample", 10, TimeUnit.SECONDS))
              System.out.println("disconnect");
              cluster.disconnect();
          }
          catch (Exception e) {
              e.printStackTrace();
          }
      }
  }
  

  作为旁注，你应该总是在创建后重复使用CouchbaseEnvironment，CouchbaseCluster和Bucket实例（通常是将它们设置为某个地方的公共静态，或者是Spring单例等等） . 这些是线程安全的，应该共享（并且无论如何它们都很昂贵） .

  资源链接：

  • Couchbase connection timeout with Java SDK

  回复于 2024-04-18T17:45:26+08:00