腾讯云 Job案例

一 在service模块引入

<!--腾讯云分布式任务调度 begin-->
<dependency>
    <groupId>com.tencent.cloud</groupId>
    <artifactId>tct-spring-boot-starter</artifactId>
    <version>1.2.0</version>
</dependency>
<!--腾讯云分布式任务调度 end-->

第二步 配置yml 文件

tct:
  enabled: true

 例如:腾讯云 Job案例

 第三步

新建jobService 写对应的job 返回类型自定义

腾讯云 Job案例

第四步 写定时任务逻辑代码

腾讯云 Job案例

 第五步 一个方法对应一个定时任务方便在腾讯云配置

腾讯云 Job案例

代码:

package com.wl.ltx.dealer.job;

import com.tencent.cloud.task.sdk.client.LogReporter;
import com.tencent.cloud.task.sdk.client.model.ExecutableTaskData;
import com.tencent.cloud.task.sdk.client.model.ProcessResult;
import com.tencent.cloud.task.sdk.client.model.TerminateResult;
import com.tencent.cloud.task.sdk.client.remoting.TaskExecuteFuture;
import com.tencent.cloud.task.sdk.client.spi.ExecutableTask;
import com.tencent.cloud.task.sdk.client.spi.TerminableTask;
import com.wl.ltx.common.component.utils.DateUtils;
import com.wl.ltx.dealer.service.JobService;
import com.wl.ltx.framework.service.util.SpringContextUtil;
import lombok.extern.slf4j.Slf4j;

/**
 * Job
 *http://console.cloud.weilongsys.com/tsf-tct/tct-task?rid=50000001  配置
 * @author CFB Consultant Team
 * @since 2021-12-20
 */
@Slf4j
public class DealerChangePositionJob implements ExecutableTask, TerminableTask {
	@Override
    public ProcessResult execute(ExecutableTaskData executableTaskData) {
        JobService jobService = (JobService) SpringContextUtil.getBean("jobDealerPartnerService");
        //批量处理合伙人变职位
        log.info(">>>>>>>>>>>>>>>>>批量处理合伙人变职位>>>>>更改状态定时任务执行 openPartnerChangePosition 开始:" + DateUtils.getDateTime() + ">>>>>>>>>>>>>>");
        String msg = jobService.openPartnerChangePosition();
        log.info(">>>>>>>>>>>>>>>>>批量处理合伙人变职位>>>>>更改状态定时任务执行 openPartnerChangePosition 完成:" + DateUtils.getDateTime() + ">>>>>>>>>>>>>>");
        return ProcessResult.newSuccessResult(msg);
    }

    @Override
    public TerminateResult cancel(TaskExecuteFuture taskExecuteFuture, ExecutableTaskData taskData) {
        LogReporter.log(taskData, "task start to cancel");
        taskExecuteFuture.cancel(true);
        LogReporter.log(taskData, "task cancel success");
        return TerminateResult.newTerminateSuccessResult();
    }
}

 第六步登录腾讯云找到TSF

腾讯云 Job案例

 配置定时任务

腾讯云 Job案例

 选择对应执行的环境:以dev为案例

腾讯云 Job案例

 腾讯云 Job案例

 解释:

腾讯云 Job案例

 完成

执行记录可以之定义

腾讯云 Job案例

 完结

上一篇:不使用xftp上传/下载文件到linux


下一篇:Android SDK 开发应该注意哪些?,android程序开发