бд. Идея - консьюмеры работая в горутинах копят в буфере сообщения, затем вставляют в бд. Лучше использовать и синхронить общий буфер, или каждому консьюмеру свой? Если каждый буфер свой, то использовать отдельный sql insert от каждого буфера, или синхронить один sql?
зависит от функционала больше,если дальше надо будет какие-то общие сортировки или проверки,то проще в общем буфере, если нет,то можно не заморачиватся синхронизацией на уровне буфера
а какого рода сообщения? что будет если ты уже прочитал из очереди, но еще не записал в БД и приложение упало?
jsonы. Думаю что подтверждать сообщения буду после их вставки в базу, так что если приложение упадут - сообщения останутся в очереди неподтверждёнными
Обсуждают сегодня