Spring Boot 中的 Apache Camel - 根据请求对消费者进行队列轮询

Question

我正在努力寻找一个完整的示例，说明如何在 Spring 引导框架中使用 Apache Camel 以实现轮询消费者的目的。

我看过这个：https://camel.apache.org/manual/latest/polling-consumer.html as well as this: https://camel.apache.org/components/latest/timer-component.html 但是代码示例不够广泛，我无法理解我需要做什么才能完成我在 Java.[=12 中的任务=]

我通常是一名 C# 开发人员，所以很多这些对事物的小引用都没有意义。

我正在 Java 中寻找以下要执行的示例，包括使其正常工作所需的所有导入和其他依赖项。

我正在尝试做的是以下内容

向端点发出 Web 请求，这应触发轮询消费者的开始
轮询消费者需要使用提供的 "ID" 轮询另一个 Web 端点，该端点需要在触发时发送给消费者。
轮询消费者应每 X 秒（假设 5 秒）轮询一次。
从我们正在轮询的端点收到特定的成功响应后，消费者应停止轮询并向另一个 Web 端点发送消息。

我想知道这是否可行，如果可行，您能否提供一个小示例来说明实现此目标所需的一切（因为 Camel 网站上的文档在导入和 class 结构等)?

Answer 1

在与一些 Java 同事讨论后，他们向我保证，这个用例不是 Camel 的设计目标。这就是在我发布这个问题之前很难在互联网上找到任何东西的原因。

对于那些通过 Google 寻求这个答案的人，最好的建议方法是使用不同的工具或只使用标准 java。

在我的例子中，我最终使用普通的旧 Java 线程来实现所需的。收到请求后，我只需启动一个新的 Runnable 线程，该线程处理来自其他服务的结果检查，休眠 X 秒，并在响应成功时终止。

下面是一个简单的例子：

Runnable runner = new Runnable() {
    @Override
    public void run() {
        boolean cont = true;
        while (cont) {
           cont = getResponseFromServer();
           try {
              Thread.sleep(5000);
           } catch (Exception e) {
              // we don't care about this, it just means this time it didn't sleep
           }
        }
    }
}
new Thread(runner).start();

Spring Boot 中的 Apache Camel - 根据请求对消费者进行队列轮询

Apache Camel in Spring Boot - Queue polling consumer on request

java

apache-camel

polling

spring-boot