backup

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/BarrageCrawlerServerTest.java

 package com.zhiweidata.automatictest.barragecrawlerserver;
 
+import com.zhiweidata.automatictest.barragecrawlerserver.createtasks.BiliBiliCreateTaskJob;
+import com.zhiweidata.automatictest.barragecrawlerserver.createtasks.DouyuCreateTaskJob;
+import com.zhiweidata.automatictest.barragecrawlerserver.createtasks.HuyaCreateTaskJob;
 import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobBuilder;
+import org.quartz.SchedulerException;
+import org.quartz.SimpleScheduleBuilder;
+import org.quartz.Trigger;
+import org.quartz.TriggerBuilder;
+
+import static com.zhiweidata.automatictest.publics.BeanContainer.SCHEDULER;
 
 /**
  * 弹幕采集自动化测试模块
@@ -10,14 +21,32 @@ import lombok.extern.slf4j.Slf4j;
  * @ide IntelliJ IDEA
  */
 @Slf4j
-@SuppressWarnings("JavaDoc")
+@SuppressWarnings({"JavaDoc", "SpellCheckingInspection"})
 public class BarrageCrawlerServerTest implements Runnable {
 
     @Override
     public void run() {
         try {
+            // 虎牙直播
+            this.createJob(HuyaCreateTaskJob.class, "虎牙直播", "huya");
+            this.createJob(BiliBiliCreateTaskJob.class, "BILIBILI直播", "bilibili");
+            this.createJob(DouyuCreateTaskJob.class, "斗鱼直播", "douyu");
         } catch (Exception e) {
             log.error(e.getMessage(), e);
         }
     }
+
+    private <T extends Job> void createJob(Class<T> tClass, String platform, String name) throws SchedulerException {
+        JobBuilder jobBuilder = JobBuilder.newJob(tClass);
+        String description = "定时从" + platform + "首页获得直播间地址，并发送到弹幕采集服务器进行测试。";
+        jobBuilder.withDescription(description);
+        final String group = "create-live-task";
+        jobBuilder.withIdentity(name, group);
+        TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
+        triggerBuilder.withDescription(description);
+        triggerBuilder.withIdentity(name, group);
+        triggerBuilder.withSchedule(SimpleScheduleBuilder.repeatHourlyForever(5));
+        triggerBuilder.startNow();
+        SCHEDULER.scheduleJob(jobBuilder.build(), triggerBuilder.build());
+    }
 }

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/BiliBiliCreateTaskJob.java

+package com.zhiweidata.automatictest.barragecrawlerserver.createtasks;
+
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+
+/**
+ * 从B站直播的首页获得直播间的地址，并发送到弹幕采集服务器进行测试
+ *
+ * @author aszswaz
+ * @createTime 2021-08-23 17:43:24
+ * @ide IntelliJ IDEA
+ */
+@SuppressWarnings("JavaDoc")
+public class BiliBiliCreateTaskJob implements Job {
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) {
+    }
+}

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/DouyuCreateTaskJob.java

+package com.zhiweidata.automatictest.barragecrawlerserver.createtasks;
+
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+
+/**
+ * 从斗鱼直播的首页获得直播间的地址，并发送到弹幕采集服务器进行测试
+ *
+ * @author aszswaz
+ * @createTime 2021-08-23 17:43:24
+ * @ide IntelliJ IDEA
+ */
+@SuppressWarnings({"JavaDoc", "unused", "SpellCheckingInspection"})
+public class DouyuCreateTaskJob implements Job {
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) {
+    }
+}

barrage-crawler-server/src/main/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/HuyaCreateTaskJob.java

+package com.zhiweidata.automatictest.barragecrawlerserver.createtasks;
+
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+
+/**
+ * 从虎牙直播的首页获得直播间的地址，并发送到弹幕采集服务器进行测试
+ *
+ * @author aszswaz
+ * @createTime 2021-08-23 17:43:24
+ * @ide IntelliJ IDEA
+ */
+@Slf4j
+@SuppressWarnings({"JavaDoc", "unused", "SpellCheckingInspection"})
+public class HuyaCreateTaskJob implements Job {
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) {
+        log.info("Hello World");
+    }
+}

public/src/main/java/com/zhiweidata/automatictest/publics/BeanContainer.java

@@ -29,6 +29,7 @@ public class BeanContainer {
         Scheduler scheduler = null;
         try {
             scheduler = StdSchedulerFactory.getDefaultScheduler();
+            scheduler.start();
         } catch (SchedulerException e) {
             log.error(e.getMessage(), e);
         }

public/src/main/resources/log4j2.xml

@@ -5,7 +5,7 @@
         <Console name="console" target="SYSTEM_OUT">
             <!--输出日志的格式，使用SpringBoot配色（仅能在SpringBoot项目中使用） -->
             <PatternLayout
-                    pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} %highlight{%5p} --- [%-20t] %-80c %-40M %-5L: %m%n"/>
+                    pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} %highlight{%5p} --- [%-30t] %-90c %-40M %-5L: %m%n"/>
             <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
         </Console>
     </Appenders>

public/src/main/resources/quartz.properties

@@ -7,6 +7,8 @@ org.quartz.scheduler.instanceIdGenerator.class=org.quartz.simpl.SimpleInstanceId
 # 线程池配置
 org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
 org.quartz.threadPool.threadCount=10
+# 配置定时任务存储方式，RAM、JDBC等
+org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
 # 配置任务运行日志
 # 日志插件
 org.quartz.plugin.triggHistory.class=org.quartz.plugins.history.LoggingTriggerHistoryPlugin