0

我对生产者消费者食谱将如何与 Zookeeper 一起使用几乎没有疑问。

到目前为止,我看到的所有示例都将生产者和消费者作为单独的线程在同一个 java 进程中。但是分布式的全部意义在于拥有不同的生产者和消费者实例(多个)。

拥有不同的生产者和消费者实例意味着没有本地锁( syntonization )将有任何用处。

此外,由于多个进程正在监视同一个根队列节点,它们都将开始处理特定的传入条目。

我在这里做错了什么???

4

1 回答 1

0

仅供参考 - 要查看 ZooKeeper 中的生产者/消费者示例,请查看 Curator(免责声明:我是 Curator 的作者):http ://curator.incubator.apache.org/curator-recipes/distributed-queue.html

注意:我认为 ZooKeeper 对队列来说是一个糟糕的选择。这是解释原因的帖子:https ://cwiki.apache.org/confluence/display/CURATOR/TN4

于 2013-05-25T14:45:30.937 回答