Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
automatic-test
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
钟涨钱
automatic-test
Commits
cea1a58b
Commit
cea1a58b
authored
Sep 09, 2021
by
朽木不可雕也
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改时间随机方式
parent
19d376c3
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
10 additions
and
4 deletions
+10
-4
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/BiliBiliCreateTaskJob.java
+1
-1
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/CreateTaskJob.java
+7
-1
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/DouyuCreateTaskJob.java
+1
-1
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/HuyaCreateTaskJob.java
+1
-1
No files found.
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/BiliBiliCreateTaskJob.java
View file @
cea1a58b
...
@@ -28,7 +28,7 @@ public class BiliBiliCreateTaskJob extends CreateTaskJob {
...
@@ -28,7 +28,7 @@ public class BiliBiliCreateTaskJob extends CreateTaskJob {
public
void
execute
(
JobExecutionContext
jobExecutionContext
)
{
public
void
execute
(
JobExecutionContext
jobExecutionContext
)
{
try
{
try
{
// 创建下一个随机测试作业
// 创建下一个随机测试作业
createJob
(
BiliBiliCreateTaskJob
.
class
,
Long
.
toString
(
System
.
currentTimeMillis
()),
"bilibili"
);
createJob
(
BiliBiliCreateTaskJob
.
class
,
"BILIBILI直播"
,
Long
.
toString
(
System
.
currentTimeMillis
())
);
Map
<?,
?>
liveJson
=
new
ObjectMapper
().
readValue
(
new
URL
(
"https://api.live.bilibili.com/xlive/web-interface/v1/index/getList?platform=web"
),
Map
.
class
);
Map
<?,
?>
liveJson
=
new
ObjectMapper
().
readValue
(
new
URL
(
"https://api.live.bilibili.com/xlive/web-interface/v1/index/getList?platform=web"
),
Map
.
class
);
liveJson
=
(
Map
<?,
?>)
requireNonNull
(
liveJson
.
get
(
"data"
));
liveJson
=
(
Map
<?,
?>)
requireNonNull
(
liveJson
.
get
(
"data"
));
...
...
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/CreateTaskJob.java
View file @
cea1a58b
...
@@ -8,6 +8,7 @@ import com.zhiweidata.automatictest.barragecrawlerserver.mapper.BarrageCollectio
...
@@ -8,6 +8,7 @@ import com.zhiweidata.automatictest.barragecrawlerserver.mapper.BarrageCollectio
import
com.zhiweidata.automatictest.barragecrawlerserver.mapper.ServerResponseMessageMapper
;
import
com.zhiweidata.automatictest.barragecrawlerserver.mapper.ServerResponseMessageMapper
;
import
com.zhiweidata.automatictest.barragecrawlerserver.util.TimeUtil
;
import
com.zhiweidata.automatictest.barragecrawlerserver.util.TimeUtil
;
import
java.io.IOException
;
import
java.io.IOException
;
import
java.util.Date
;
import
java.util.Set
;
import
java.util.Set
;
import
java.util.UUID
;
import
java.util.UUID
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
...
@@ -54,7 +55,12 @@ public abstract class CreateTaskJob implements Job {
...
@@ -54,7 +55,12 @@ public abstract class CreateTaskJob implements Job {
TriggerBuilder
<
Trigger
>
triggerBuilder
=
TriggerBuilder
.
newTrigger
();
TriggerBuilder
<
Trigger
>
triggerBuilder
=
TriggerBuilder
.
newTrigger
();
triggerBuilder
.
withDescription
(
description
);
triggerBuilder
.
withDescription
(
description
);
triggerBuilder
.
withIdentity
(
name
,
group
);
triggerBuilder
.
withIdentity
(
name
,
group
);
triggerBuilder
.
startAt
(
TimeUtil
.
randmoDate
(
1
));
long
openInterval
=
System
.
currentTimeMillis
()
+
3600000L
;
long
closedInterval
=
openInterval
+
6
*
3600000L
;
long
time
=
(
long
)
(
openInterval
+
((
closedInterval
-
openInterval
)
*
Math
.
random
()));
triggerBuilder
.
startAt
(
new
Date
(
time
));
triggerBuilder
.
startNow
();
triggerBuilder
.
startNow
();
SCHEDULER
.
scheduleJob
(
jobBuilder
.
build
(),
triggerBuilder
.
build
());
SCHEDULER
.
scheduleJob
(
jobBuilder
.
build
(),
triggerBuilder
.
build
());
}
}
...
...
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/DouyuCreateTaskJob.java
View file @
cea1a58b
...
@@ -39,7 +39,7 @@ public class DouyuCreateTaskJob extends CreateTaskJob {
...
@@ -39,7 +39,7 @@ public class DouyuCreateTaskJob extends CreateTaskJob {
public
void
execute
(
JobExecutionContext
jobExecutionContext
)
{
public
void
execute
(
JobExecutionContext
jobExecutionContext
)
{
try
{
try
{
// 下一个随机测试作业
// 下一个随机测试作业
createJob
(
DouyuCreateTaskJob
.
class
,
Long
.
toString
(
System
.
currentTimeMillis
()),
"douyu"
);
createJob
(
DouyuCreateTaskJob
.
class
,
"斗鱼直播"
,
Long
.
toString
(
System
.
currentTimeMillis
())
);
HttpResponse
response
=
HTTP_CLIENT
.
execute
(
new
HttpGet
(
"https://www.douyu.com/"
));
HttpResponse
response
=
HTTP_CLIENT
.
execute
(
new
HttpGet
(
"https://www.douyu.com/"
));
String
html
=
EntityUtils
.
toString
(
response
.
getEntity
());
String
html
=
EntityUtils
.
toString
(
response
.
getEntity
());
...
...
barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/HuyaCreateTaskJob.java
View file @
cea1a58b
...
@@ -45,7 +45,7 @@ public class HuyaCreateTaskJob extends CreateTaskJob {
...
@@ -45,7 +45,7 @@ public class HuyaCreateTaskJob extends CreateTaskJob {
public
void
execute
(
JobExecutionContext
jobExecutionContext
)
{
public
void
execute
(
JobExecutionContext
jobExecutionContext
)
{
try
{
try
{
// 创建下一个随机测试作业
// 创建下一个随机测试作业
createJob
(
BiliBiliCreateTaskJob
.
class
,
Long
.
toString
(
System
.
currentTimeMillis
()),
"bilibili"
);
createJob
(
BiliBiliCreateTaskJob
.
class
,
"虎牙直播"
,
Long
.
toString
(
System
.
currentTimeMillis
())
);
HttpGet
get
=
new
HttpGet
(
"https://www.huya.com/"
);
HttpGet
get
=
new
HttpGet
(
"https://www.huya.com/"
);
HttpResponse
response
=
HTTP_CLIENT
.
execute
(
get
);
HttpResponse
response
=
HTTP_CLIENT
.
execute
(
get
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment