Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
B
basic-api-boot
概览
概览
详情
活动
周期分析
版本库
存储库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
问题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程表
图表
维基
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
Basic
basic-api-boot
Commits
68d0cb45
提交
68d0cb45
authored
5月 13, 2024
作者:
方治民
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
chore: 调整 TestJob 示例
上级
045a5761
隐藏空白字符变更
内嵌
并排
正在显示
2 个修改的文件
包含
9 行增加
和
8 行删除
+9
-8
TestJob.java
app/src/main/java/com/yiring/app/job/TestJob.java
+7
-7
application-conf-xxl-job.yml
app/src/main/resources/application-conf-xxl-job.yml
+2
-1
没有找到文件。
app/src/main/java/com/yiring/app/job/TestJob.java
浏览文件 @
68d0cb45
...
@@ -8,8 +8,8 @@ import com.yiring.common.constant.DateFormatter;
...
@@ -8,8 +8,8 @@ import com.yiring.common.constant.DateFormatter;
import
com.yiring.common.core.Retriever
;
import
com.yiring.common.core.Retriever
;
import
com.yiring.common.core.UptimeNotice
;
import
com.yiring.common.core.UptimeNotice
;
import
com.yiring.common.exception.UptimeException
;
import
com.yiring.common.exception.UptimeException
;
import
com.yiring.common.util.Uptime
;
import
com.yiring.common.util.XxlJobUtil
;
import
com.yiring.common.util.XxlJobUtil
;
import
com.yiring.common.utils.Uptime
;
import
java.time.LocalDateTime
;
import
java.time.LocalDateTime
;
import
java.util.Random
;
import
java.util.Random
;
import
java.util.concurrent.TimeUnit
;
import
java.util.concurrent.TimeUnit
;
...
@@ -40,10 +40,10 @@ public class TestJob {
...
@@ -40,10 +40,10 @@ public class TestJob {
retryCount
=
3
,
retryCount
=
3
,
retryStatus
=
Uptime
.
Status
.
UP
retryStatus
=
Uptime
.
Status
.
UP
)
)
@Scheduled
(
fixedDelay
=
5
,
timeUnit
=
TimeUnit
.
SECONDS
)
@Scheduled
(
fixedDelay
=
5
,
timeUnit
=
TimeUnit
.
SECONDS
,
initialDelay
=
5000
)
public
void
testScheduled
()
{
public
void
testScheduled
()
{
String
time
=
LocalDateTime
.
now
().
format
(
DateFormatter
.
DATE_TIME
);
String
time
=
LocalDateTime
.
now
().
format
(
DateFormatter
.
DATE_TIME
);
log
.
info
(
"Test
JobHandler
: {}"
,
time
);
log
.
info
(
"Test
Scheduled
: {}"
,
time
);
Random
random
=
new
Random
();
Random
random
=
new
Random
();
int
randomCount
=
random
.
nextInt
(
10
);
int
randomCount
=
random
.
nextInt
(
10
);
...
@@ -53,12 +53,12 @@ public class TestJob {
...
@@ -53,12 +53,12 @@ public class TestJob {
return
"OK"
;
return
"OK"
;
}
}
throw
new
UptimeException
(
"[Test
JobHandler
] test err: "
+
time
);
throw
new
UptimeException
(
"[Test
Scheduled
] test err: "
+
time
);
},
},
Retriever:
:
defaultPolicy
Retriever:
:
defaultPolicy
);
);
log
.
info
(
"[Test] result: {}"
,
result
);
log
.
info
(
"[Test
Scheduled
] result: {}"
,
result
);
}
}
@SuppressWarnings
(
"unused"
)
@SuppressWarnings
(
"unused"
)
...
@@ -68,9 +68,9 @@ public class TestJob {
...
@@ -68,9 +68,9 @@ public class TestJob {
Random
random
=
new
Random
();
Random
random
=
new
Random
();
int
randomCount
=
random
.
nextInt
(
10
);
int
randomCount
=
random
.
nextInt
(
10
);
if
(
randomCount
<
5
)
{
if
(
randomCount
<
5
)
{
return
XxlJobUtil
.
fail
(
"
TestNoticeHandler
fail"
);
return
XxlJobUtil
.
fail
(
"fail"
);
}
}
return
XxlJobUtil
.
success
(
"
TestNoticeHandler
success"
);
return
XxlJobUtil
.
success
(
"success"
);
}
}
}
}
app/src/main/resources/application-conf-xxl-job.yml
浏览文件 @
68d0cb45
...
@@ -4,4 +4,5 @@ xxl:
...
@@ -4,4 +4,5 @@ xxl:
enabled
:
true
enabled
:
true
admin-addresses
:
http://192.168.0.156:8080/xxl-job-admin
admin-addresses
:
http://192.168.0.156:8080/xxl-job-admin
access-token
:
local
access-token
:
local
executor-app-name
:
xyh-app-preview
executor-app-name
:
basic
executor-ip
:
192.168.0.110
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论