腾讯云 Job案例

2022-01-06 09:08:57 阅读：184 来源： 互联网

标签：task 案例 Job tencent 腾讯 import com cloud sdk

一在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

例如：

第三步

新建jobService 写对应的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

配置定时任务

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

解释：

完成

执行记录可以之定义

完结

标签：task,案例,Job,tencent,腾讯,import,com,cloud,sdk
来源： https://blog.csdn.net/qq_36907589/article/details/122335999

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

腾讯云 Job案例