java - Springboot中无限执行方法

Question

我需要在springboot中无限读取java队列元素（ConcurrentLinkedQueue）（没有jms或任何消息队列）。从 UI 请求，我将根据请求将元素添加到队列中，如果队列包含它应该读取的任何元素并且此过程是无限的（由于许多请求不断命中，我将元素添加到队列中并且必须在弹簧靴）。请建议如何做到这一点。

例子：

Queue = []（最初）第一个请求 => Queue = [“1”]（添加）无限运行的方法应该检查队列元素，当队列中存在元素时打印它们。2nd request => Queue = ["2"] 无限运行的方法应该检查队列元素，当队列中存在元素时打印它们。

等等..

谢谢。

标签： javaspring-bootqueueinfinite-loop

Answer 1

您可以创建一个 Spring Boot Reactive Web 服务，该服务适用于发布订阅模型以进行异步通信。请看Spring Boot Reactive

如果您不想创建 Web 服务，最好不要使用 Spring Boot，而是创建一个普通的 java 应用程序。