如何在 C API 中使用“悲观”的 Couchbase 锁定？

Question

这是令人难以置信的沮丧…我正在使用Couchbase v3 C API，我遇到了一个问题，这个问题可以通过使用他们的“悲观”锁定来完美解决。经过一番努力，我相信我终于找到了如何使用它锁定记录（使用lcb_cmdget_locktime（），它大概需要一个以微秒为单位的参数），但是我不知道如何在完成后解锁记录，除了让它超时，这不是一个可以接受的解决方案。

这里的文档提供了一个示例，但出于某种未知的原因，它使用的是Javascript而不是C（！！！），并且这些概念没有映射到C API。

有人知道如何解锁悲观锁吗，或者有使用该API的示例C/C代码吗？除此之外，有人知道在哪里可以找到使用C语言的任何非C API的源代码吗？（我也找不到其中的任何一个，不确定它们是开源的。）

Answer 1

谢谢你的提问

以秒为单位的时间，请注意，如果时间大于最大时间，服务器可能会将时间重置为默认值(两个持续时间都是可配置的)。以下命令将有助于发现特性的有效值。

$ cbstats -u Administrator -p password  localhost all | grep ep_getl
ep_getl_default_timeout:                               15
ep_getl_max_timeout:                                   30

要锁定密钥，必须使用 get 操作并使用 lcb_cmdget_locktime 设置锁定时间，并在成功锁定的情况下捕获 CAS 值，例如这样

struct my_result {
    lcb_STATUS status{LCB_SUCCESS};
    uint64_t cas{0};
};

static void get_callback(lcb_INSTANCE *instance, lcb_CALLBACK_TYPE, const lcb_RESPGET *resp)
{
    my_result *res = nullptr;
    lcb_respget_cookie(resp, (void **)&res);
    res->status = lcb_respget_status(resp);
    if (res->status == LCB_SUCCESS) {
        lcb_respget_cas(resp, &res->cas);
    }
}

将带有锁代码的获取放入循环中是个好主意

uint64_t locked_cas{0};
int retries = 3;
while (retries > 0) {
    std::string document_id{"foo"};
    my_result result{};
    lcb_CMDGET* cmd = nullptr;
    lcb_cmdget_create(&cmd);
    lcb_cmdget_key(cmd, document_id.c_str(), document_id.size());
    lcb_cmdget_locktime(cmd, 5);
    lcb_get(instance, &result, cmd);
    lcb_cmdget_destroy(cmd);
    lcb_wait(instance, LCB_WAIT_DEFAULT);

    if (result.rc == LCB_SUCCESS) {
        locked_cas = result.cas;
        break;
    } else if (result.rc == LCB_ERR_DOCUMENT_LOCKED || result.rc == LCB_ERR_TEMPORARY_FAILURE) {
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
        --retries;
        continue;
    } else {
        std::cerr << "Unexpected issue during get with lock: " << lcb_strerror_short(result.rc) << "\n";
        break;
    }
}

一旦键被锁定，就可以执行更新操作，但请记住，它必须使用locked_cas，否则变异操作将失败。

std::string document_id{"foo"};
std::string new_value{"new value"};
lcb_CMDSTORE* cmd = nullptr;
lcb_cmdstore_create(&cmd, LCB_STORE_REPLACE);
lcb_cmdstore_key(cmd, document_id.c_str(), document_id.size());
lcb_cmdstore_value(cmd, new_value.c_str(), new_value.size());
lcb_cmdstore_cas(cmd, locked_cas);
lcb_store(instance, nullptr, cmd);
lcb_cmdstore_destroy(cmd);
lcb_wait(instance, LCB_WAIT_DEFAULT);

要解锁密钥，您还需要locked_cas，或者等到服务器自动解锁文档。

std::string document_id{"foo"};
lcb_CMDUNLOCK *cmd = nullptr;
lcb_cmdunlock_create(&cmd);
lcb_cmdunlock_key(cmd, document_id.c_str(), document_id.size());
lcb_cmdunlock_cas(cmd, locked_cas);
lcb_unlock(instance, nullptr, cmd);
lcb_cmdunlock_destroy(cmd);
lcb_wait(instance, LCB_WAIT_DEFAULT);