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

Question

我会实现一个分布式计数器，如果 couchbase 集群只有一个节点，它会很好地工作，但是当我添加一个新节点时，它是 return 一个 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
}

主要是完整的代码，还有一个 docker 组合：

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

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

我真的不明白为什么只有一个节点时它的工作方式与它的工作方式不同。

Answer 1

首先，我建议您使用官方 Couchbase 图像而不是 arungupta/couchbase，因为它没有得到维护。

其次，你的Go代码运行在docker主机内吗？我怀疑不是，这就是您运行关注此问题的原因。 Go 客户端需要能够访问每个 Couchbase 节点。在 docker 主机之外，它只能访问一个主机。

我的建议是将您的 Go 客户端移动到 docker 主机中。

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

Couchbase operation has timed out if there is more than one node

distributed-computing

go

couchbase