Spring Boot实现分布式任务调度的步骤

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.3.2</version>
</dependency>

server.port=8761
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
spring.application.name=eureka-server

server.port=8081
spring.application.name=task-scheduler-provider
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

server.port=8082
spring.application.name=task-scheduler-consumer
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

spring.redis.host=localhost
spring.redis.port=6379

@Component
public class SampleJob implements Job {
    private final Logger logger = LoggerFactory.getLogger(SampleJob.class);
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        logger.info("SampleJob executed at {}", new Date());
        // TODO: 实现定时任务的具体逻辑
    }
}

@Configuration
public class QuartzConfig {
    @Autowired
    private SampleJob sampleJob;
    @Bean
    public JobDetail sampleJobDetail() {
        return JobBuilder.newJob().ofType(sampleJob.getClass())
                .storeDurably()
                .withIdentity("SampleJob")
                .withDescription("Invoke Sample Job service...")
                .build();
    }
    @Bean
    public Trigger sampleJobTrigger() {
        SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
                .withIntervalInSeconds(10) // 每隔10秒执行一次
                .repeatForever();
        return TriggerBuilder.newTrigger()
                .forJob(sampleJobDetail())
                .withIdentity("SampleJobTrigger")
                .withDescription("Sample Job Trigger")
                .withSchedule(scheduleBuilder)
                .build();
    }
}

@Component
public class TaskScheduler {
    private final Logger logger = LoggerFactory.getLogger(TaskScheduler.class);
    private final RedisTemplate<String, Object> redisTemplate;
    @Autowired
    public TaskScheduler(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }
    @Scheduled(fixedRate = 5000) // 每隔5秒执行一次
    public void scheduleTasks() {
        String task = (String) redisTemplate.opsForList().rightPop("task_queue");
        if (task != null) {
            logger.info("Task {} scheduled at {}", task, new Date());
            // TODO: 将任务分配给多个节点执行
        }
    }
}