Буфер данных для подписки и снятия подписки с данными в реальном времени с использованием rabbitmq

Question

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

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

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

Answer 1

Это зависит от того, сколько данных вы говорите. Недостатком вашего метода является то, что очередь может заполнить большой объем данных, если скорость передачи данных высока и TTL установлен в течение длительного времени. Вы также должны сохранить очередь в очереди. И у вас должна быть одна очередь с самого начала для каждого возможного абонента.

Я бы предложил Recent History Exchange, возможно, изменив его, чтобы он содержал больше сообщений.