如果有多个节点，Couchbase操作已超时。

Question

如果couchbase集群只有一个节点，我将实现一个分布式计数器，但是当我添加一个新的节点时，它将为存储桶上的每种类型的操作返回一个operation has timed out：

type Incrementer struct {
    bucket  *gocb.Bucket
    gap     uint64
    initial int64
    ttl     uint32
}

func New(conn, bucketName, bucketPassword string, gap uint64, initial int64) *Incrementer {
    cluster, err := gocb.Connect(conn)
    if err != nil {
        fmt.Println("ERRROR CONNECTING TO CLUSTER:", err)
        return nil
    }

    // Open Bucket
    bucket, err := cluster.OpenBucket(bucketName, bucketPassword)
    if err != nil {
        fmt.Println("ERRROR OPENING BUCKET:", err)
        return nil
    }

    return &Incrementer{
        bucket:  bucket,
        gap:     gap,
        initial: initial,
    }
}

func (i *Incrementer) Add(key string) error {
    var current interface{}
    cas, err := i.bucket.GetAndLock(key, i.ttl, &current)
    if err == gocb.ErrKeyNotFound {
    _, _, err := i.bucket.Counter(key, 1, i.initial, 0)
    if err != nil {
        return err
    }
    }
    if err != nil {
        return err
    }
    newValue := current.(float64) + 1
    if newValue >= float64(i.gap) {
        newValue = float64(i.initial)
    }
    _, err = i.bucket.Replace(key, newValue, cas, 0)*/

    // https://developer.couchbase.com/documentation/server/3.x/developer/dev-guide-3.0/lock-items.html

    return err
}

大多数情况下，这是整个代码，也有一个码头组成：

version: "3"
services:
  cb1:
    image: arungupta/couchbase
    deploy:
      replicas: 2
    ports:
      - 8091:8091
      - 8092:8092
      - 8093:8093
      - 8094:8094
      - 11210:11210
    links:
      - cb2

  cb2:
    image: arungupta/couchbase
    deploy:
      replicas: 2

场景:当我设置对接架构师时，只有一个节点，因为我必须在Couchbase的UI中手动添加它。这很好，它正常工作，但是当我用Add Server按钮添加第二个服务器并尝试再次使用它时，Add(key)返回一个operation has timed out。我发现这个错误来自于i.bucket.GetAndLock(key, i.ttl, &current)部分。

我真的不明白为什么在只有一个节点的情况下，它的工作方式不一样。

Answer 1

首先，我建议您使用正式的Couchbase映像而不是arungupta/couchbase，因为这是不被维护的。

第二，您的Go代码是否在docker主机中运行？我怀疑不是，这也是你遇到这个问题的原因。Go客户端需要能够到达每个Couchbase节点。在码头主机之外，它只能到达一个。

我的建议是把你的Go客户端移到码头主机内。