在ubuntu上部署CouchBase集群，在.Net Core 项目中使用

1.基础操作

下面链接CouchBase服务器：

using Couchbase;
using Couchbase.Authentication;
using Couchbase.Configuration.Client;
using Couchbase.Core;

var cluster = new Cluster(new ClientConfiguration
            {
                Servers = new List<Uri> {  new Uri("http://10.10.10.175:10000"),
            new Uri("http://10.10.10.175:10010"),
            new Uri("http://10.10.10.175:10020"),
            new Uri("http://10.10.10.175:10030"),
            new Uri("http://10.10.10.175:10040")}
            });
            cluster.Authenticate(new PasswordAuthenticator("Administrator", "9op0(OP)"));
            services.AddSingleton<IBucket>(x => cluster.OpenBucket("TestZYY"));

运行时，出现如下错误：

有点懵，查了官方的文档，没找到什么问题！！！！

最后找到一个靠谱的：https://stackoverflow.com/questions/55598077/docker-aspnet-core-couchbase# 我是在另外的机器使用Docker安装的多个CouchBase，Docker内部分配了不同的子ip. 如果直接使用主机安装CouchBase，就没有这个问题了.

新建一个类Profile

public class Profile
{
public string FirstName { get; set; }
public string LastName { get; set; }
public string Type => "Profile";
}

下面我们在ProfileRepository中实现查找、更新、删除等操作

public class ProfileRepository
    {
        private readonly IBucket _bucket;

        public ProfileRepository(IBucket bucket)
        {
            _bucket = bucket;
        }

        public Dictionary<string, Profile> GetAll()
        {
            var request = QueryRequest.Create(@"
                SELECT
                    META().id AS `key`,
                    TOOBJECT(sb) as `value`
                FROM `TestZYY` as sb
                WHERE type='Profile';");
            request.ScanConsistency(ScanConsistency.RequestPlus);
            var response = _bucket.Query<KeyValuePair<string, Profile>>(request);
            return response.Rows.ToDictionary(x => x.Key, x => x.Value);
        }

        public KeyValuePair<string, Profile> GetProfileByKey(string key)
        {
            var profile = _bucket.Get<Profile>(key).Value;
            return new KeyValuePair<string, Profile>(key, profile);
        }

        public void Save(KeyValuePair<string, Profile> model)
        {
            var doc = new Document<Profile>
            {
                Id = model.Key,
                Content = model.Value
            };
            _bucket.Upsert(doc);
        }

        public void Delete(string key)
        {
            _bucket.Remove(key);
        }
    }
    // end::class[]
}

在Couchbase中，使用以下操作之一存储文档：Upsert，Insert和Replace。这些操作都会将具有给定文档ID（键）的JSON文档写入数据库。对于文档的现有状态，更新方法在行为上有所不同：

如果在数据库中找不到给定的ID，Insert只会创建文档。
如果给定的ID已存在于数据库中，则Replace仅将替换文档。
Upsert将始终替换文档，而忽略该ID是否已存在。

可以使用get操作来检索文档，最后使用remove操作将其删除。下面为几种更新操作的解释代码

Dictionary<string,object> kvStore;

void Insert(string docId, object value) {
    if (!kvStore.ContainsKey(docId)) {
        kvStore.Add(docId, value);
    } else
    {
        throw new DocumentAlreadyExistsException();
    }
}

void Replace(string docId, object value) {
    if (kvStore.ContainsKey(docId)) {
        kvStore.Add(docId, value);
    } else {
        throw new DocumentDoesNotExistException();
    }
}

void Upsert(string docId, object value) {
    kvStore.Add(docId, value);
}

object Get(string docId) {
    if (kvStore.ContainsKey(docId)) {
        return kvStore[docId];
    } else {
        throw new DocumentDoesNotExistException();
    }
}

2.并发文档出冲突

Document属性：

名称描述

名称	描述
`Id`	（每个存储桶）文档的唯一标识符。
`Content`	文件的实际内容。
`Cas`	文档的CAS（比较和交换）值。
`Expiry`	文档的到期时间。
`Token`	突变后的可选MutationToken。

Id

（每个存储桶）文档的唯一标识符。

Content

文件的实际内容。

Cas

文档的CAS（比较和交换）值。

Expiry

文档的到期时间。

Token

突变后的可选MutationToken。

Cas（Compare And Swap）值是一个比较关键的值，每一次操作更新文档，CAS值都会发生更改。

服务器端CAS值实现如下：

uint Replace(string docid, object newvalue, uint oldCas=0) {
    object existing = this.kvStore.get(docid);
    if (!existing) {
        throw DocumentDoesNotExist();
    } else if (oldCas != 0 && oldCas != existing.cas) {
        throw CasMismatch();
    }
    uint newCas = ++existing.cas;
    existing.value = newValue;
    return newCas;
}

假设以下两个代码块在不同的应用程序实例中同时执行：

进程1：
var result = bucket.Get<dynamic>("docid");
var new_doc = result.Value;
new_doc.field1 = "value1";
bucket.Replace("docid", new_doc);

进程2：
var result = buckt.Get<dynamic>("docid");
var new_doc = result.Value;
new_doc.field2 = "value2";
bucket.Replace("docid", new_doc);

检索文档：var result = bucket.Get<dynamic>("docid").Value;

将得到如下：

{“ field2”：“ value2”，“ a_field”：“ a_value”}

请注意field1，即使应用程序将其插入到文档中也不存在。原因是因为线程2上的替换碰巧在线程1上的替换之后运行，但是线程1的替换是在线程2的获取之后执行的：由于线程2上文档的本地版本不包含field1（ （因为线程＃1的更新尚未存储在服务器上），因此通过执行替换，它实际上将覆盖线程1执行的替换。
在前面的示例中，我们看到对同一文档的并发更新可能会导致某些更新丢失。这不是因为Couchbase本身丢失了更新，而是因为应用程序没有意识到对该文档进行的更新，并且无意中覆盖了它们。
我们应该使用如下代码

var result = bucket.Get<dynamic>("docid");
var new_doc = result.Value;
var cur_cas = result.Cas;
new_doc.field1 = "value1";
var new_result = bucket.Replace("docid", new_doc, cas);

如果更新时候的文档CAS值与服务器上的CAS值不同，将会提示：服务器上的CAS不同。

参考文档：https://docs.couchbase.com/server/6.5/introduction/intro.html

https://docs.couchbase.com/dotnet-sdk/2.7/start-using-sdk.html