У меня есть сценарий, в котором я хочу синхронизировать несколько клиентов (представьте, что они являются объектами-потребителями) с большим количеством строк данных (несколько разрозненных МБ), которые периодически (например, каждые десять минут) передаются из внешнего ресурса.,Если возможно, я бы хотел использовать EventBus (например, Guava) для этой задачи.
Важно передавать потоковые строки данных как своего рода «составное сообщение» (состоящее примерно из 500 000 отдельных сообщений).через шину событий, позволяя потребителям определять начало и конец каждого запуска синхронизации.Как и в случае транзакций базы данных, важно, чтобы клиенты перехватывали начало и конец, чтобы убедиться, что они получили весь элемент от первого до последнего элемента.
Является ли это распространенным случаем использования для шины событий, или я злоупотребляю этиминструмент?Я думал добавить флаг начала / конца к объектам сообщения или перечислить их, но мне было интересно, есть ли более чистый подход.