как реализовать поддержку активности в кластере статей

Question

У меня есть несколько вершин, которые принадлежат одному кластеру, и они отправляют приветственное сообщение по шине событий - сообщение, в основном, является именем отправляющей вертикали - вертике получателя, которая сохраняет сообщение на карте.

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

Я посмотрел на веб-сайте hazelcast, но не нашелпростой способ реализовать эту функцию.

ожидаемый результат - удаление записи отправителя с карты получателя при остановке / уничтожении вертикали отправителя.

Answer 1

Для этого может быть несколько способов, и один из них использует Hazelcast. ILock будет более простым подходом, каждый член может получить блокировку (возможно, с именем вертикали), и когда член покидает кластер.все блокировки, полученные этим мертвым участником, будут автоматически удалены, поэтому ваше приложение может в любое время проверить, заблокировано оно или нет.

Answer 2

Вы можете зарегистрировать MembershipListener и прослушать изменения членства.Таким образом, вы можете удалить ранее добавленные сообщения участника, когда он покидает кластер.