AutoRestart

core/src/main/java/com/tzld/videoVector/job/XxlJobService.java

@@ -0,0 +1,50 @@
+package com.tzld.videoVector.job;
+
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import java.util.concurrent.TimeUnit;
+
+@Service
+@Slf4j
+public class XxlJobService {
+
+    private OkHttpClient client;
+
+    private static final String AUTO_RESTART_URL =
+            "https://cs.console.aliyun.com/hook/trigger?token=eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9"
+                    + ".eyJjbHVzdGVySWQiOiJjZjBhOTQ2MmU2NGVjNDQwYzgxYzM3ODYyZjg5ZGU5NjkiLCJpZCI6IjEzNTg1NjE1NDAzODI0MjMwOSJ9"
+                    + ".LRHnzQeeLmmPWtF5On3YU9VLSiwTR220JVX4-nC82KhL5qPHnDjK6cUIZAmDEsKBQrMnWdAMT2TkTclU3rXgu1z0m11BMHa6nLAOyZFgRDu"
+                    + "_6802RxjMHktuwE3OBR2n302NiGE4ohDhUd7UJOsw4jTVsrAyoUuTU5mBDA7h_mw";
+
+    @PostConstruct
+    public void init() {
+        this.client = new OkHttpClient.Builder()
+                .connectTimeout(10, TimeUnit.SECONDS)
+                .readTimeout(10, TimeUnit.SECONDS)
+                .writeTimeout(10, TimeUnit.SECONDS)
+                .build();
+    }
+
+    @XxlJob("AutoRestart")
+    public ReturnT<String> autoRestart(String param) {
+        Request request = new Request.Builder()
+                .url(AUTO_RESTART_URL)
+                .get()
+                .build();
+
+        try (Response response = client.newCall(request).execute()) {
+            log.info("AutoRestart 调用完成, HTTP {}: {}", response.code(), response.message());
+        } catch (Exception e) {
+            log.error("AutoRestart error", e);
+        }
+        return ReturnT.SUCCESS;
+    }
+
+}