当前位置：文江博客话题详情

Apache Camel - 在启动时触发任务仅运行一次

发布于 2024-12-08 22:53:48 字数 250 浏览 0 评论 0原文

我正在使用 Camel & 开发一个 Java 项目。春天。我们希望在 Spring 完成其工作并且 Camel 完成构建所有路由后触发单例 bean 上的初始化方法。

我们无法在类创建时调用该方法，因为它具有到从 @Component spring 注释中获取的其他类的动态链接，并且我们不知道这些类何时/是否已加载，以实际运行 init 方法作为构造函数。

如何在 Camel 启动完成后调用一个或多个方法仅运行一次？

谢谢！

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

单挑你×的.吻 2024-12-15 22:53:48

另一个为您提供更多灵活性的简单选项是使用 camel-timer 和 RepeatCount=1和一个足够长的延迟值，让一切都初始化。您还可以添加基本的异常处理来延迟/重试等...

from("timer://runOnce?repeatCount=1&delay=5000").to("bean:runOnceBean");

another simple option which gives you a little more flexibility is to use camel-timer with a repeatCount=1 and a delay value long enough to let everything initialize. you can also add basic exception handling to delay/retry, etc...

from("timer://runOnce?repeatCount=1&delay=5000").to("bean:runOnceBean");

回复收藏 0 原文

绾颜 2024-12-15 22:53:48

如果 bean 必须在 CamelContext 启动所有路由等之后调用，那么您可以按照 Ben 的建议使用带有计时器的路由。

一个可能更好的替代方案是使用 Camel 的 EventNotifier API。然后调用正在触发的 CamelContextStartedEvent 上的逻辑。
有关 EventNotifier API 的一些详细信息，请参见：http:// /camel.apache.org/eventnotifier-to-log-details-about-all-sent-exchanges.html

回复收藏 0 原文

月下凄凉 2024-12-15 22:53:48

在 bean 的方法中添加逻辑并使用 @PostConstruct 对其进行注释 - 一旦该 bean 完全初始化并设置了其所有依赖项，spring 将调用此方法。

@Component
class SomeClass {

 @PostConstruct
 void init() {
 }

}

如果在整个 Spring 应用程序上下文完全初始化后需要调用逻辑，您可以通过实现 LifeCycle 接口。

Add the logic in a method of your bean and annotate it with @PostConstruct - spring will invoke this method once this bean is fully initialized and all its dependencies are set.

@Component
class SomeClass {

 @PostConstruct
 void init() {
 }

}

If the logic needs to be invoked once the whole spring application context is fully initialized you can do that by implementing the LifeCycle interface.

回复收藏 0 原文

初雪 2024-12-15 22:53:48

一种解决方案是修补几个文件（请参阅 PR https://github.com/apache/ Camel/pull/684)：CamelContextConfiguration.java 和 RoutesCollector.java。

在 CamelContextConfiguration 中，添加方法：

void afterApplicationStart(CamelContext camelContext);

在 RoutesCollector 的 onApplicationEvent 中添加如下内容：

        if (camelContextConfigurations != null) {
            for (CamelContextConfiguration camelContextConfiguration : camelContextConfigurations) {
                camelContextConfiguration.afterApplicationStart(camelContext);
            }
        }

如果使用，则可以省略 if (camelContextConfigurations != null)截至目前的最新版本。

然后按如下方式创建一个 Spring bean 以添加您的代码：

@Bean
CamelContextConfiguration contextConfiguration() {
    return new CamelContextConfiguration() {

        @Override
        public void beforeApplicationStart(CamelContext camelContext) {
        }

        @Override
        public void afterApplicationStart(CamelContext camelContext) {
            // Put your code here
        }
    };
}

更新：此拉取请求已合并。

One solution would be to patch a couple of files (see PR https://github.com/apache/camel/pull/684): CamelContextConfiguration.java and RoutesCollector.java.

In CamelContextConfiguration, add the method:

void afterApplicationStart(CamelContext camelContext);

And in onApplicationEvent of RoutesCollector add something like:

        if (camelContextConfigurations != null) {
            for (CamelContextConfiguration camelContextConfiguration : camelContextConfigurations) {
                camelContextConfiguration.afterApplicationStart(camelContext);
            }
        }

You may omit the if (camelContextConfigurations != null) if using the latest version as of this date.

Then create a Spring bean as follows to add your code:

@Bean
CamelContextConfiguration contextConfiguration() {
    return new CamelContextConfiguration() {

        @Override
        public void beforeApplicationStart(CamelContext camelContext) {
        }

        @Override
        public void afterApplicationStart(CamelContext camelContext) {
            // Put your code here
        }
    };
}

UPDATE: This pull request has been merged.

回复收藏 0 原文

盗梦空间 2024-12-15 22:53:48

您可以使用 Camel 中的启动顺序功能，该功能记录在 http:// camel.apache.org/configuring-route-startup-ordering-and-autostartup.html ：-

<route startupOrder="1" id="thisOneGoesFirst">    
  <from uri="seda:foo"/>
  <to uri="mock:result"/>
</route>
<route startupOrder="2" id="thisOneGoesSecond">
  <from uri="direct:start"/>
  <to uri="seda:foo"/>
</route> 
<route id="thisOneGoesLast">
  <from uri="direct:bar"/>
  <to uri="seda:bar"/>
</route>

具有startupOrder属性的路由将按顺序执行，并且在所有没有startupOrder的路由之前执行。因此，您可以在路线开始之前或之后的任何时间点使用计时器消费者来制定路线。

You could use the startup order functionality in Camel documented at http://camel.apache.org/configuring-route-startup-ordering-and-autostartup.html :-

<route startupOrder="1" id="thisOneGoesFirst">    
  <from uri="seda:foo"/>
  <to uri="mock:result"/>
</route>
<route startupOrder="2" id="thisOneGoesSecond">
  <from uri="direct:start"/>
  <to uri="seda:foo"/>
</route> 
<route id="thisOneGoesLast">
  <from uri="direct:bar"/>
  <to uri="seda:bar"/>
</route>

where the routes with a startupOrder attribute will be executed in order and BEFORE all routes which have no startupOrder. So you can have your route with a timer consumer at which ever point you like, before or after your routes have been started.

回复收藏 0 原文

删除→记忆 2024-12-15 22:53:48

您可以尝试将骆驼上下文注入到您的单例 bean 中。在上下文完全初始化之前，注入不会发生......包括所有路由的构建。缺点是您可能实际上不需要 bean 中的上下文。我在脑子里琢磨着将单例 bean 依赖项链接到 spring 配置文件中的camelContext 初始化的想法，但不确定这是否真的有效。

回复收藏 0 原文