仅在一个WebLogic集群节点上运行@Scheduled任务？

发布于 2024-12-27 14:26:36 字数 702 浏览 3 评论 0原文

我们正在集群 WebLogic 10.3.4 环境中运行 Spring 3.0.x Web 应用程序 (.war)，其中包含夜间 @Scheduled 作业。但是，当应用程序部署到每个节点时（使用 AdminServer 的 Web 控制台中的部署向导），该作业每天晚上都会在每个节点上启动，从而同时运行多次。

我们如何防止这种情况发生？

我知道像 Quartz 这样的库允许通过数据库锁表来协调集群环境中的作业，或者我什至可以自己实现类似的东西。但由于这似乎是一个相当常见的场景，我想知道 Spring 是否还没有提供一个选项，如何轻松规避这个问题，而无需向我的项目添加新库或手动解决方法。

我们无法使用配置文件升级到 Spring 3.1，此处提到

如果有任何悬而未决的问题，请告诉我。我还在 Spring 社区论坛。非常感谢您的帮助。

原文

分享到QQ

分享到微博

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

发布评论

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

难忘№最初的完美 2025-01-03 14:26:36

我们只有一项任务发送每日摘要电子邮件。为了避免额外的依赖，我们只需检查每个节点的主机名是否与配置的系统属性相对应。

private boolean isTriggerNode() {
   String triggerHostmame = System.getProperty("trigger.hostname");;
   String hostName = InetAddress.getLocalHost().getHostName();
   return hostName.equals(triggerHostmame);
}

public void execute() {
   if (isTriggerNode()) {
      //send email
   }
}

We only have one task that send a daily summary email. To avoid extra dependencies, we simply check whether the hostname of each node corresponds with a configured system property.

private boolean isTriggerNode() {
   String triggerHostmame = System.getProperty("trigger.hostname");;
   String hostName = InetAddress.getLocalHost().getHostName();
   return hostName.equals(triggerHostmame);
}

public void execute() {
   if (isTriggerNode()) {
      //send email
   }
}

回复收藏 0 原文

紫竹語嫣☆ 2025-01-03 14:26:36

我们正在使用应用程序数据库内的共享锁表来实现我们自己的同步逻辑。这允许所有集群节点在实际启动作业之前检查作业是否已经在运行。

回复收藏 0 原文

无声无音无过去 2025-01-03 14:26:36

请小心，因为在使用共享锁表实现自己的同步逻辑的解决方案中，您总是会遇到两个集群节点同时从表中读取/写入的并发问题。

最好是在一个数据库事务中执行以下步骤：
- 读取共享锁表中的值
- 如果没有其他节点拥有锁，则获取锁
- 更新表表明您已锁定

回复收藏 0 原文

世界等同你 2025-01-03 14:26:36

我通过将其中一个盒子作为主盒子解决了这个问题。
基本上在其中一个盒子上设置一个环境变量，例如 master=true。

并通过 system.getenv("master") 在你的java代码中读取它。
如果它存在且属实，则运行您的代码。

基本片段

@schedule()
void process(){
boolean master=Boolean.parseBoolean(system.getenv("master"));
if(master)
{
   //your logic
}

}

I solved this problem by making one of the box as master.
basically set an environment variable on one of the box like master=true.

and read it in your java code through system.getenv("master").
if its present and its true then run your code.

basic snippet

@schedule()
void process(){
boolean master=Boolean.parseBoolean(system.getenv("master"));
if(master)
{
   //your logic
}

}

回复收藏 0 原文

执笏见 2025-01-03 14:26:36

您可以尝试使用WebLogic中的TimerManager（集群环境中的作业调度程序）作为TaskScheduler实现（TimerManagerTaskScheduler）。它应该在集群环境中工作。

安德里亚

回复收藏 0 原文

不离久伴 2025-01-03 14:26:36

您不需要使用数据库来同步作业开始。
在 weblogic 应用程序上，您可以获得应用程序运行的实例名称：

String serverName = System.getProperty("weblogic.Name");

只需添加条件二即可执行作业：

if (serverName.equals(".....")) {
  execute my job;
}

如果您想将作业从一台机器转移到另一台机器，您可以获取一年中的当前日期，并且如果是奇数，则在一台机器上执行；如果是偶数，则在另一台机器上执行作业。
这样您每天都会加载不同的机器。

You don't neeed to synchronize your job start using a DB.
On a weblogic application you can get the instanze name where the application is running:

String serverName = System.getProperty("weblogic.Name");

Simply put a condition two execute the job:

if (serverName.equals(".....")) {
  execute my job;
}

If you want to bounce your job from one machine to the other, you can get the current day in the year, and if it is odd you execute on a machine, if it is even you execute the job on the other one.
This way you load a different machine every day.

回复收藏 0 原文