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