fdkankan-mq-controller/src/main/java/com/fdkankan/mqcontroller/task/TaskController.java

package com.fdkankan.mqcontroller.task;

import cn.hutool.log.Log;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class TaskController {


    @Autowired
    TaskService taskService;

    /**
     * 每1分钟执行一次，将数据库中待计算的mq消息推送，rabbitmq
     */
    @Scheduled(initialDelay = 2000,fixedDelay = 1000 * 60 )
    public void taskSendMq(){
        try {
            taskService.sendMq();
        }catch (Exception e){
            log.info("taskSendMq执行失败：",e);
        }
    }


    /**
     * 每2分钟执行一次，判断是否关闭弹性伸缩
     */
    @Scheduled(initialDelay = 3000,fixedDelay = 1000 * 60 * 2)
    public void checkDelEcs(){
        try {
            taskService.checkDelEcs();
        }catch (Exception e){
            log.info("checkDelEcs执行失败：",e);
        }
    }


    /**
     * 每10秒执行一次，开启缓存弹性伸缩
     */
    @Scheduled(initialDelay = 1000,fixedDelay = 1000 * 10 )
    public void openEcsList(){
        try {
            taskService.openEcsList();
        }catch (Exception e){
            log.info("openEcsList执行失败：",e);
        }
    }

    /**
     * 每10秒执行一次，关闭缓存弹性伸缩
     */
    @Scheduled(initialDelay = 1000,fixedDelay = 1000 * 10 )
    public void delEcsList(){
        try {
            taskService.delEcsList();
        }catch (Exception e){
            log.info("delEcsList执行失败：",e);
        }
    }




}