Zookeeper Производитель Потребитель

У меня мало сомнений в том, как продюсер потребительских рецептов будет работать с Zookeeper.

Все примеры, которые я видел до сих пор, содержат производителей и потребителей в одних и тех же процессах Java как отдельный поток. Но весь смысл в распределении состоит в том, чтобы иметь разные экземпляры (множественные) производителя и потребителя.

наличие разных экземпляров производителей и потребителей означает, что никакие локальные блокировки (синтонизация) не будут полезны.

Кроме того, поскольку несколько процессов наблюдают за одним корневым узлом очереди, все они начнут обрабатывать определенную входящую запись.

Что я тут не так делаю???

Источник

1 ответ

Решение

К вашему сведению - чтобы увидеть пример производителя / потребителя в ZooKeeper, взгляните на куратора (отказ от ответственности: я автор куратора): http://curator.incubator.apache.org/curator-recipes/distributed-queue.html

ПРИМЕЧАНИЕ. По моему мнению, ZooKeeper - плохой выбор для очередей. Вот пост, который объясняет почему: https://cwiki.apache.org/confluence/display/CURATOR/TN4

Источник
Другие вопросы по тегам