Выполнить метод бесконечно в Springboot

Question

У меня есть требование чтения элементов очереди Java (ConcurrentLinkedQueue) в Springboot бесконечно (без jms или каких-либо очередей сообщений). Из запроса пользовательского интерфейса я добавлю элемент в очередь для каждого запроса, если очередь содержит какой-либо элемент, который должен быть прочитан, и эта процедура выполняется бесконечно (так как многие запросы продолжают попадать, я добавлю элемент в очередь, и это должно быть выполнено в springboot). Подскажите пожалуйста как это сделать.

Пример:

Queue = [] (изначально) 1-й запрос => Queue = ["1"] (добавлено) Метод бесконечный запуск должен проверять элементы очереди, когда элементы присутствующие в очереди распечатать их. 2-й запрос => очередь = ["2"] метод бесконечный запуск должен проверять элементы очереди, когда элементы присутствующие в очереди распечатать их.

и т. Д.

Спасибо.

Answer 1

Вы можете создать веб-службу Spring Boot Reactive, которая работает в модели публикации подписки для асинхронной связи. Пожалуйста, посмотрите на Spring Boot Reactive

Если вы не хотите создавать веб-сервис, лучше не использовать Spring Boot и вместо этого создавать простое Java-приложение.