backup

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.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.util.EntityUtils;
 import org.quartz.Job;
 import org.quartz.JobExecutionContext;
 
+import static com.zhiweidata.automatictest.publics.BeanContainer.HTTP_CLIENT;
+
 /**
  * 从虎牙直播的首页获得直播间的地址，并发送到弹幕采集服务器进行测试
  *
@@ -16,6 +21,13 @@ import org.quartz.JobExecutionContext;
 public class HuyaCreateTaskJob implements Job {
     @Override
     public void execute(JobExecutionContext jobExecutionContext) {
-        log.info("Hello World");
+        try {
+            HttpGet get = new HttpGet("https://www.huya.com/");
+            HttpResponse response = HTTP_CLIENT.execute(get);
+            String html = EntityUtils.toString(response.getEntity());
+            System.out.println(html);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
     }
 }

barrage-crawler-server/src/test/java/com/zhiweidata/automatictest/barragecrawlerserver/createtasks/HuyaCreateTaskJobTest.java

+package com.zhiweidata.automatictest.barragecrawlerserver.createtasks;
+
+import org.junit.jupiter.api.Test;
+
+/**
+ * @author aszswaz
+ * @createTime 2021-08-24 11:06:20
+ * @ide IntelliJ IDEA
+ */
+@SuppressWarnings({"JavaDoc", "SpellCheckingInspection"})
+class HuyaCreateTaskJobTest {
+
+    @Test
+    void execute() {
+        HuyaCreateTaskJob taskJob = new HuyaCreateTaskJob();
+        taskJob.execute(null);
+    }
+}
\ No newline at end of file

pom.xml

@@ -21,6 +21,7 @@
         <easyexcel.version>2.2.10</easyexcel.version>
         <commons-lang3.version>3.12.0</commons-lang3.version>
         <projectlombok.version>1.18.20</projectlombok.version>
+        <junit.version>5.8.0-RC1</junit.version>
 
         <!--模块版本-->
         <public.version>1.0-SNAPSHOT</public.version>
@@ -62,6 +63,14 @@
             <version>${projectlombok.version}</version>
             <scope>provided</scope>
         </dependency>
+
+        <!-- https://mvnrepository.com/artifact/org.junit.jupiter/junit-jupiter-api -->
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
 </project>
\ No newline at end of file

public/pom.xml

@@ -15,17 +15,17 @@
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
-        <okhttp.version>5.0.0-alpha.2</okhttp.version>
+        <httpclient.version>4.5.13</httpclient.version>
         <lo4j.version>2.14.1</lo4j.version>
         <quartz.version>2.3.2</quartz.version>
     </properties>
 
     <dependencies>
-        <!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
+        <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
         <dependency>
-            <groupId>com.squareup.okhttp3</groupId>
-            <artifactId>okhttp</artifactId>
-            <version>${okhttp.version}</version>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>${httpclient.version}</version>
         </dependency>
         <!-- https://mvnrepository.com/artifact/org.apache.logging.log4j/log4j-slf4j-impl -->
         <dependency>

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

 package com.zhiweidata.automatictest.publics;
 
 import lombok.extern.slf4j.Slf4j;
-import okhttp3.OkHttpClient;
+import org.apache.http.client.HttpClient;
+import org.apache.http.impl.client.HttpClients;
 import org.quartz.Scheduler;
 import org.quartz.SchedulerException;
 import org.quartz.impl.StdSchedulerFactory;
@@ -19,13 +20,15 @@ public class BeanContainer {
     /**
      * http 客户端
      */
-    public static final OkHttpClient OK_HTTP_CLIENT = new OkHttpClient();
+    public static final HttpClient HTTP_CLIENT;
     /**
      * 全局任务调度器
      */
     public static final Scheduler SCHEDULER;
 
     static {
+        HTTP_CLIENT = HttpClients.createMinimal();
+
         Scheduler scheduler = null;
         try {
             scheduler = StdSchedulerFactory.getDefaultScheduler();