package org.dromara.job.snailjob;
|
|
import cn.hutool.core.util.RandomUtil;
|
import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
|
import com.aizuda.snailjob.client.job.core.dto.JobArgs;
|
import com.aizuda.snailjob.common.log.SnailJobLog;
|
import com.aizuda.snailjob.model.dto.ExecuteResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 广播任务
|
* <a href="https://juejin.cn/post/7422948006150438950"></a>
|
*
|
* @author 老马
|
*/
|
@Slf4j
|
@Component
|
@JobExecutor(name = "testBroadcastJob")
|
public class TestBroadcastJob {
|
|
@Value("${snail-job.port}")
|
private int clientPort;
|
|
public ExecuteResult jobExecute(JobArgs jobArgs) {
|
int randomInt = RandomUtil.randomInt(100);
|
log.info("随机数: {}", randomInt);
|
SnailJobLog.REMOTE.info("随机数: {},客户端端口:{}", randomInt, clientPort);
|
if (randomInt < 50) {
|
throw new RuntimeException("随机数小于50，收集日志任务执行失败");
|
}
|
// 获得jobArgs 中传入的相加的两个数
|
return ExecuteResult.success("随机数大于50，收集日志任务执行成功");
|
}
|
|
}
|
