SchedulerX怎么我这边有2台机器，设置了广播模式实力并发数是1只看到只有一台机器在执行脚本？

在SchedulerX中，广播模式的任务本应将任务实例广播到分组内的所有Worker机器上执行。然而，您提到设置了广播模式但只有一台机器在执行脚本，这可能与配置或运行环境有关。以下是可能导致该问题的原因及解决方法：

1. 检查任务的执行模式是否正确设置为广播

确保任务的执行模式已明确设置为“广播运行”。如果误设为“单机运行”，则只会随机选择一台机器执行任务。

• 操作步骤：

  1. 登录分布式任务调度平台。
  2. 进入任务管理页面，找到对应任务。
  3. 检查任务的执行模式是否为“广播运行”。

  如果未设置为广播模式，请修改为广播模式并重新触发任务。

2. 确认应用分组中的机器状态

广播模式要求分组内的所有机器都处于健康状态。如果某些机器被标记为“繁忙”或“下线”，这些机器将不会接收任务。

• 排查方法：
  1. 在应用管理页面，查看分组下的机器列表。
  2. 确认两台机器的状态是否均为“健康”。
  3. 如果某台机器状态为“繁忙”，可以在编辑 > 实例繁忙配置中，将是否触发繁忙机器开关设置为开启，以强制向繁忙机器下发任务。

3. 检查任务并发数配置

虽然广播模式会将任务分发到所有机器，但如果任务的实例并发数设置为1，则同一时间只能有一个任务实例运行。这可能导致任务在一台机器上执行完毕后才开始在另一台机器上执行。

• 解决方法：
  1. 在任务的高级配置中，检查实例并发数是否设置为大于1。
  2. 如果需要同时在多台机器上执行任务，请将实例并发数调整为合适的值（例如2或更高）。

4. 验证客户端接入状态

如果某台机器未成功接入SchedulerX客户端，则该机器无法接收任务。

• 排查方法：
  1. 检查未执行任务的机器上是否存在SchedulerX客户端日志文件~/logs/schedulerx/worker.log。
  2. 如果日志文件不存在，说明该机器未成功接入SchedulerX客户端，请参考客户端快速接入文档完成接入。
  3. 如果日志文件存在，查看日志中是否有异常信息，并根据异常信息定位问题。

5. 检查任务优先级和队列限流

SchedulerX支持通过任务优先级队列进行应用级别限流。如果任务优先级较低，可能会导致任务被延迟调度。

• 排查方法：
  1. 检查任务的优先级设置，确保其优先级足够高。
  2. 在执行列表页面，查看任务实例的调度顺序，确认是否存在其他高优先级任务抢占了资源。

6. 广播模式的实现逻辑

广播模式的任务会在所有Worker机器上执行，但如果任务的实现逻辑存在问题（例如未正确继承JavaProcessor类），可能导致任务未能正常广播。

• 注意事项：
  • 广播模式的Java任务需要实现JavaProcessor接口，并重写process(JobContext context)方法。
  • 示例代码如下：

  @Component
  public class TestBroadcastJob extends JavaProcessor {
      @Override
      public ProcessResult process(JobContext context) throws Exception {
          System.out.println("当前机器执行任务，分片号=" + context.getShardingId());
          return new ProcessResult(true, "执行成功");
      }
  }
  

总结

根据上述分析，您可以按照以下步骤逐一排查问题： 1. 确认任务执行模式为“广播运行”。 2. 检查分组内所有机器的状态是否为“健康”。 3. 调整任务的实例并发数以支持多台机器同时执行。 4. 验证未执行任务的机器是否成功接入SchedulerX客户端。 5. 检查任务优先级和队列限流配置。 6. 确保任务实现逻辑符合广播模式的要求。

如果问题仍未解决，建议联系SchedulerX技术支持人员获取进一步帮助。