queue - 如何使用 couchbase 作为 fifo 队列

Question

对于Java客户端，如何使用couchbase实现线程安全的FIFO队列？可以有许多线程从队列中弹出并插入队列。队列中的每个对象都是一个字符串[]。

Answer 1

Couchbase 没有任何用于创建队列的内置功能，但您可以自己创建。

我将在下面的简短示例中解释如何做到这一点。IE。我们有名称为 queue 的队列它将包含名称为 item:<index> 的项目.要实现队列，您需要使用以下键存储您的值:<queue_name>:item:<index> ，其中索引将是单独的键 queue:index ，你需要在推送到队列时递增，并在弹出时递减。

在 couchbase 中，您可以使用递增和递减操作来实现队列，因为该操作是原子的和线程安全的。

所以你的 push 和 pop 函数的代码将是这样的:

void push(string queue, string[] value){
  int index = couchbase.increment(queue + ':index');
  couchbase.set(queue + ':item:' + index, value);
}
string[] pop(string queue){
  int index = couchbase.get(queue + ':index');
  string[] result = couchbase.get(queue + ':item:' + index);
  couchbase.decrement(queue + ':index');
  return result;
}

对不起代码，我很久以前就使用过 java 和 couchbase java 客户端。如果现在 java 客户端有回调，比如 nodejs 客户端，您可以重写该代码以使用回调。我想会更好。

您还可以在集合操作中添加额外的检查 - 使用 add (在 C# 客户端中它称为 StoreMode.Add )如果具有给定键的项目已经存在，将抛出异常的操作。您可以捕获该异常并为相同的参数再次调用 push 函数。

UPD:对不起，早上太早了，所以我想不清楚。对于 fifo，正如@avsej 所说，您需要两个计数器:queue:head和 queue:tail .所以对于 fifo:

void push(string queue, string[] value){
  int index = couchbase.increment(queue + ':tail');
  couchbase.set(queue + ':item:' + index, value);
}
string[] pop(string queue){
  int index = couchbase.increment(queue + ':head') - 1;
  string[] result = couchbase.get(queue + ':item:' + index);
  return result;
}

注意:根据 queue:tail 的起始值，代码可能看起来略有不同。和 queue:head (它是零还是一还是其他)。

你也可以设置一些max计数器的值，达到后，queue:tail和 queue:head将重置为 0(只是为了限制文档数量)。您也可以设置 expire每个文件的值(value)，如果你真的需要这个。