spring-scheduled相关内容

将外部化值注入 Spring 注解

我一直在考虑在编译时评估注释值的 Java 特性,它似乎确实很难将注释值外部化. 但是,我不确定这是否真的不可能,所以我很感激任何建议或明确的答案. 更重要的是,我正在尝试外部化一个注释值,该值控制 Spring 中计划的方法调用之间的延迟,例如: 公共类 SomeClass {私有属性道具;私有静态最终长延迟 = 0;@PostConstruct公共无效初始化Bean(){资源资源 ..
发布时间:2022-01-13 10:37:38 Java开发

集群环境下运行的Spring Scheduled Task

我正在编写一个应用程序,它有一个每 60 秒执行一次的 cron 作业.应用程序配置为在需要时扩展到多个实例.我只想每 60 秒(在任何节点上)在 1 个实例上执行任务.开箱即用的我找不到解决方案,我很惊讶之前没有多次询问它.我使用的是 Spring 4.1.6. ..
发布时间:2021-12-03 17:48:54 其他开发

每天 1:01:am 的 Spring cron 表达式

我正在尝试根据 Spring cron 表达式按固定时间表执行我的代码.我希望代码每天在 1:01:am 执行.我尝试了以下表达式,但这并没有让我兴奋.这里的语法有什么问题? @Scheduled(cron = "0 1 1 ? * *")公共无效重置缓存(){//...} 解决方案 尝试: @Scheduled(cron = "0 1 1 * * ?") 您可以在下面找到来自 spri ..
发布时间:2021-12-03 17:41:36 Java开发

在读取所有消息直到某个特定时间后停止 KafkaListener(Spring Kafka Consumer)

我正在尝试从单个分区主题安排我的消费过程.我可以使用 endpointlistenerregistry.start() 启动它,但我想在消耗了当前分区中的所有消息后停止它,即当我到达当前分区中的最后一个偏移量时.在我完成消费并关闭它之后,生产进入主题.我应该如何确保我已经阅读了所有消息,直到我启动调度程序并停止我的消费者?我正在为消费者使用 @Kafkalistener. 解决方案 设置 ..
发布时间:2021-11-12 03:07:58 其他开发

在读取所有消息直到某个特定时间后停止 KafkaListener(Spring Kafka Consumer)

我正在尝试从单个分区主题安排我的消费过程.我可以使用 endpointlistenerregistry.start() 启动它,但我想在消耗了当前分区中的所有消息后停止它,即当我到达当前分区中的最后一个偏移量时.在我完成消费并关闭它之后,生产进入主题.我应该如何确保我已经阅读了所有消息,直到我启动调度程序并停止我的消费者?我正在为消费者使用 @Kafkalistener. 解决方案 设置 ..
发布时间:2021-11-12 03:04:33 其他开发

是否有读取 Kafka 主题的 Spring Schedule 示例?

我们试图在指定的窗口时间从 Kafka 读取数据(所以我们有 Kafka 消费者),这意味着避免在其他时间读取数据.但是,我们不确定如何在时间段到期后关闭消费者.我想知道是否有任何示例可以说明如何做到这一点?非常感谢您帮助我们. 解决方案 您可以禁用 autoStartup,然后使用 KafkaListenerEndpointRegistry start 和 停止方法@KafkaListe ..

将外化值注入 Spring 注解

我一直在考虑在编译时评估注解值的 Java 特性,它似乎很难将注解值外部化. 但是,我不确定这是否真的不可能,所以我很感激对此提出任何建议或明确的答案. 更重要的是,我试图外部化一个注释值,该值控制 Spring 中计划方法调用之间的延迟,例如: public class SomeClass {私有属性道具;私有静态最终长延迟 = 0;@PostConstruct公共无效 initi ..
发布时间:2021-11-10 22:19:40 Java开发

是否有读取 Kafka 主题的 Spring Schedule 示例?

我们试图在指定的窗口时间从 Kafka 读取数据(所以我们有 Kafka 消费者),这意味着避免在其他时间读取数据.但是,我们不确定如何在时间段到期后关闭消费者.我想知道是否有任何示例可以说明如何做到这一点?非常感谢您帮助我们. 解决方案 您可以禁用 autoStartup,然后使用 KafkaListenerEndpointRegistry start 和 停止方法@KafkaListe ..

Spring4 @Scheduled @Transaction 为多个数据源在刷新时抛出没有正在进行的事务

从 spring MVC 控制器调用时,我的服务(使用主数据源的 jobExecutor)工作正常,但是从预定方法调用时,总是抛出“TransactionRequiredException:没有事务正在进行".原因看起来是从 scheduleThreadPool 绑定到线程的 jdbcTransaction 具有 NOT_ACTIVE 作为 localStatus.事务用于主数据源,默认开始为 D ..

如何在计划任务中使用 OAuth2RestTemplate?

我有两台资源服务器:一台具有用于发送电子邮件通知的 API,另一台运行计划任务.当计划任务开始时,我想调用电子邮件服务以通知用户他们的任务正在启动.这两种服务都使用 OAuth2 进行身份验证.计划任务服务设置了客户端凭据,以便它可以通过提供其客户端凭据来获取访问令牌: 为了实现这一点,我将 Spring Boot 与 Spring Security OAuth2 结合使用.任务服务有一个 ..

如何在Spring 4.0.2的@Scheduled方法中获取当前会话(HttpSession)对象?

我的 Web 应用程序使用的是 Spring 4.0.2.我的 Web 应用程序是关于文件处理的.有一些关于文件的状态,例如“进行中"、“暂停"、“已完成".一个用户可以完成多个文件,但一次只能完成一个.因此,对于单个用户,一次只有一个文件必须处于“进行中"状态.现在,我想每 15 分钟检查一次特定文件是否发生了任何事件.如果没有发生任何事件,我想将文件状态从“进行中"更改为“暂停".所以我尝试在 ..
发布时间:2021-07-16 19:23:59 Java开发

多个 Spring 3.2 计划任务不会并行运行

我有两个计划任务要并行运行.这两个任务执行一个 Spring Batch 作业.每 15 秒一次,另一次每 3 秒一次.问题是一个将运行,另一个被阻塞,直到它完成. 我似乎在任何地方都找不到类似的问题或示例.有任何想法吗?谢谢,/w 这是我的一些配置.我在 Spring 3.2 中使用 spring-task-3.2 和 spring-batch-2.2. 此批处理作业由 map ..
发布时间:2021-07-16 19:18:15 Java开发

有没有办法将@Scheduled 与像 15s 和 5m 这样的 Duration 字符串一起使用?

我的代码中有以下注释 @Scheduled(fixedDelayString = "${app.delay}") 在这种情况下,我必须拥有这样的属性 app.delay=10000 #10 秒 属性文件看起来不可读,因为我已经计算了以毫秒为单位的值. 有没有办法在那里传递 5m 或 30s 之类的值? 解决方案 据我所知,你不能直接做.但是,Spring 启动配置属性会 支持 ..
发布时间:2021-07-16 19:16:09 Java开发

春季计划任务未触发

我在自学Spring,目前在计划任务上,下面的代码没有触发计划任务. 我相信这与我设置 Spring 上下文的方式有关,但这只是一个猜测 - 我正在尝试学习 Spring,所以请原谅可笑的 while 循环. Application.java: 包你好;导入 org.springframework.context.annotation.AnnotationConfigApplicat ..
发布时间:2021-07-16 19:14:06 Java开发

在每个 Spring 计划 (@Scheduled) 运行之前重置状态

我有一个需要每天运行的 Spring Boot Batch 应用程序.它读取每日文件,对其数据进行一些处理,并将处理后的数据写入数据库.在此过程中,应用程序持有一些状态,例如要读取的文件(存储在 FlatFileItemReader 和 JobParameters 中)、当前运行的日期和时间、一些文件用于比较读取项目等的数据. 调度的一种选择是使用 Spring 的 @Scheduled 如 ..