go - 如果有多个节点，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
}

主要是完整的代码，还有一个 docker compose:

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 architect 时只有一个节点，因为我必须在 Couchbase 的 UI 中手动添加它。很好，它工作正常，但是当我使用 Add Server 按钮添加第二个服务器并尝试再次使用它时，Add(key) 返回一个 操作超时。我发现这个错误来自 i.bucket.GetAndLock(key, i.ttl, ¤t) 部分。

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

Answer 1

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

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

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