Я хочу, чтобы событие обрабатывалось несколькими типами служб, такими как ServiceTypeA, ServiceTypeB, ServiceTypeC, ... Но эти службы будут иметь несколько запущенных экземпляров и работать в любой момент времени.И каждое событие должно обрабатываться только один раз каждым типом сервиса.Я подумал о двух возможных решениях:
- Использование Kafka в качестве платформы pub-sub и назначение одного прокси-сервиса для каждого типа сервиса в качестве подписчика.После этого прокси-службы будут использовать RabbitMQ для обработки сообщения только одним экземпляром службы.
- Использовать только RabbitMQ и различать такие события, как Event-A, Event-B, Event-C и т. Д. Этот подходкажется проблематичным, когда к миксу будет добавлен новый тип serice.
Какой предпочтительный подход?Может быть третий вариант?