我对生产者消费者食谱将如何与 Zookeeper 一起使用几乎没有疑问。
到目前为止,我看到的所有示例都将生产者和消费者作为单独的线程在同一个 java 进程中。但是分布式的全部意义在于拥有不同的生产者和消费者实例(多个)。
拥有不同的生产者和消费者实例意味着没有本地锁( syntonization )将有任何用处。
此外,由于多个进程正在监视同一个根队列节点,它们都将开始处理特定的传入条目。
我在这里做错了什么???
我对生产者消费者食谱将如何与 Zookeeper 一起使用几乎没有疑问。
到目前为止,我看到的所有示例都将生产者和消费者作为单独的线程在同一个 java 进程中。但是分布式的全部意义在于拥有不同的生产者和消费者实例(多个)。
拥有不同的生产者和消费者实例意味着没有本地锁( syntonization )将有任何用处。
此外,由于多个进程正在监视同一个根队列节点,它们都将开始处理特定的传入条目。
我在这里做错了什么???
仅供参考 - 要查看 ZooKeeper 中的生产者/消费者示例,请查看 Curator(免责声明:我是 Curator 的作者):http ://curator.incubator.apache.org/curator-recipes/distributed-queue.html
注意:我认为 ZooKeeper 对队列来说是一个糟糕的选择。这是解释原因的帖子:https ://cwiki.apache.org/confluence/display/CURATOR/TN4