Я очень новичок в архитектуре на основе очереди сообщений.
Я планирую создать микро-сервис, который будет принимать входные данные из очереди сообщений и публиковать sh результат в другой очереди. Это будет развернуто в докеризованном контейнере.
Итак, насколько я понимаю, мне нужно написать программу, в которой внутри бесконечного l oop Мне нужно постоянно проверять новый запрос в очереди. Вероятно, мне нужен счетный семафор, чтобы убедиться, что потребление не превышает емкость. И нужно иметь скрипт, который запускает бесконечный l oop при запуске контейнера.
Пожалуйста, помогите мне узнать лучшие практики. Поправь меня там, где когда-либо мое понимание неверно.