Я разрабатываю микросервисную среду, в которой большая часть обмена данными между службами должна быть такой, чтобы при запросе службы подписки на данные служба публикации сначала возвращала снимок того, что она содержит. Затем он продолжает публиковать sh новые обновления для подписчика.
Для каждого издателя может быть более 100 подписчиков, и не будет идеальным поддерживать разные соединения для каждого клиента в отдельности. По сути, моментальный снимок основан на запросах и ответах, а обновления передаются в потоковом режиме, но потоковые данные тесно связаны с моментальным снимком (его можно назвать исходным моментальным снимком) и должны следовать за моментальным снимком.
Пример:
Say for an entity A there are version
100
101
102
103
Если клиент получает 101 в качестве ответа, он должен получать обновления для 102 и 103, но не для 100.
Служба издателя также поддерживает операцию CRUD для данных, которые он содержит, что добавляет сложности.
Есть ли какой-либо определенный шаблон проектирования для разработки такой услуги?