Я пытаюсь понять, как я могу прослушивать события в очереди (особенно событие постановки в очередь).
Скажем, у меня есть консольное приложение и очередь/тема служебной шины, как я могу подключиться к очереди и дождаться нового сообщения?
Я пытаюсь добиться этого без While(true)
и постоянного опроса, я пытаюсь сделать это в большей степени слушателем, что-то вроде сокета, который остается подключенным к очереди.
Причина, по которой я не хочу использовать опрос, заключается в том, что я понимаю, что он заваливает сервер запросами, мне нужно решение, которое будет работать при больших нагрузках.
Спасибо.
Я привел очень простой пример для простоты вопроса, но моя реальная ситуация немного сложнее:
У меня есть веб-API, который отправляет сообщения, необходимые для обработки рабочей роли, с использованием очереди служебной шины.
Мне нужно как-то узнать, когда Worker обработал сообщение. Я хочу, чтобы рабочий отправил сообщение в очередь, предупреждая, что веб-API обработал сообщение, но теперь мне нужно заставить веб-API «сидеть» и дождаться ответа рабочего назад, что привело меня к моему вопросу :
Как я могу слушать очередь постоянно и без опроса (потому что есть много экземпляров, которые будут объединяться, и это создаст много запросов, которых, возможно, лучше избегать.