gtsoft/gtsoft-snail-job-demo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'dev_2.4.0'

Browse Source
This commit is contained in:
byteblogs168 2023-12-11 22:41:49 +08:00
commit 0e2f463ee2
7 changed files with 166 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pom.xml
View File

@ -38,7 +38,22 @@
<dependency>
<groupId>com.aizuda</groupId>
<artifactId>easy-retry-client-starter</artifactId>
<version>2.3.0-SNAPSHOT</version>
<version>2.4.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.aizuda</groupId>
<artifactId>easy-retry-client-core</artifactId>
<version>2.4.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.aizuda</groupId>
<artifactId>easy-retry-client-job-core</artifactId>
<version>2.4.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.28</version>
</dependency>
<dependency>
<groupId>com.googlecode.aviator</groupId>

22
src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java Normal file
View File

@ -0,0 +1,22 @@
package com.example.easy.retry.job;
import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.job.core.dto.JobContext;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import org.springframework.stereotype.Component;
/**
* @author www.byteblogs.com
* @date 2023-09-28 22:54:07
* @since 2.4.0
*/
@Component
@JobExecutor(name = "testJobExecutor")
public class TestAnnoJobExecutor {
public ExecuteResult jobExecute(JobArgs jobArgs) {
return ExecuteResult.success("测试成功");
}
}

27
src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep10s.java Normal file
View File

@ -0,0 +1,27 @@
package com.example.easy.retry.job;
import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import org.springframework.stereotype.Component;
/**
* @author www.byteblogs.com
* @date 2023-09-28 22:54:07
* @since 2.4.0
*/
@Component
@JobExecutor(name = "testAnnoJobExecutorSleep10s")
public class TestAnnoJobExecutorSleep10s {
public ExecuteResult jobExecute(JobArgs jobArgs) {
System.out.println(JsonUtil.toJsonString(jobArgs));
try {
Thread.sleep(10 * 1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return ExecuteResult.success("测试成功");
}
}

27
src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep1s.java Normal file
View File

@ -0,0 +1,27 @@
package com.example.easy.retry.job;
import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import org.springframework.stereotype.Component;
/**
* @author www.byteblogs.com
* @date 2023-09-28 22:54:07
* @since 2.4.0
*/
@Component
@JobExecutor(name = "testAnnoJobExecutorSleep1s")
public class TestAnnoJobExecutorSleep1s {
public ExecuteResult jobExecute(JobArgs jobArgs) {
System.out.println(JsonUtil.toJsonString(jobArgs));
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return ExecuteResult.success("测试成功");
}
}

27
src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep30s.java Normal file
View File

@ -0,0 +1,27 @@
package com.example.easy.retry.job;
import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import org.springframework.stereotype.Component;
/**
* @author www.byteblogs.com
* @date 2023-09-28 22:54:07
* @since 2.4.0
*/
@Component
@JobExecutor(name = "testAnnoJobExecutorSleep30s")
public class TestAnnoJobExecutorSleep30s {
public ExecuteResult jobExecute(JobArgs jobArgs) {
System.out.println(JsonUtil.toJsonString(jobArgs));
try {
Thread.sleep(30 * 1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return ExecuteResult.success("测试成功");
}
}

27
src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep5s.java Normal file
View File

@ -0,0 +1,27 @@
package com.example.easy.retry.job;
import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import org.springframework.stereotype.Component;
/**
* @author www.byteblogs.com
* @date 2023-09-28 22:54:07
* @since 2.4.0
*/
@Component
@JobExecutor(name = "testAnnoJobExecutorSleep5s")
public class TestAnnoJobExecutorSleep5s {
public ExecuteResult jobExecute(JobArgs jobArgs) {
System.out.println(JsonUtil.toJsonString(jobArgs));
try {
Thread.sleep(5 * 1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return ExecuteResult.success("测试成功");
}
}

20
src/main/java/com/example/easy/retry/job/TestClassJobExecutor.java Normal file
View File

@ -0,0 +1,20 @@
package com.example.easy.retry.job;
import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.job.core.executor.AbstractJobExecutor;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import org.springframework.stereotype.Component;
/**
* @author www.byteblogs.com
* @date 2023-09-28 22:54:07
* @since 2.4.0
*/
@Component
public class TestClassJobExecutor extends AbstractJobExecutor {
@Override
protected ExecuteResult doJobExecute(JobArgs jobArgs) {
return ExecuteResult.success("TestJobExecutor测试成功");
}
}