From 4f7387acdce01089ff60130946f79e6e2ba9a8fa Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Mon, 05 Aug 2024 10:20:07 +0800
Subject: [PATCH] 1
---
geteClient/src/main/java/org/example/geteclient/task/RunTask.java | 40 +++++++++++++
kucoinClient/src/main/java/org/example/kucoinclient/KucoinClientApplication.java | 2
mexcClient/src/main/java/org/example/mexcclient/MexcClientApplication.java | 2
bitgetsClient/src/main/java/org/example/bitgetsclient/BitgetsClientApplication.java | 2
kucoinClient/src/main/java/org/example/kucoinclient/task/RunTask.java | 40 +++++++++++++
mexcClient/src/main/java/org/example/mexcclient/task/RunTask.java | 40 +++++++++++++
geteClient/src/main/java/org/example/geteclient/GeteClientApplication.java | 2
bitgetsClient/src/main/java/org/example/bitgetsclient/task/RunTask.java | 43 ++++++++++++++
8 files changed, 171 insertions(+), 0 deletions(-)
diff --git a/bitgetsClient/src/main/java/org/example/bitgetsclient/BitgetsClientApplication.java b/bitgetsClient/src/main/java/org/example/bitgetsclient/BitgetsClientApplication.java
index edb9428..a6f7221 100644
--- a/bitgetsClient/src/main/java/org/example/bitgetsclient/BitgetsClientApplication.java
+++ b/bitgetsClient/src/main/java/org/example/bitgetsclient/BitgetsClientApplication.java
@@ -2,7 +2,9 @@
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+@EnableScheduling
@SpringBootApplication
public class BitgetsClientApplication {
diff --git a/bitgetsClient/src/main/java/org/example/bitgetsclient/task/RunTask.java b/bitgetsClient/src/main/java/org/example/bitgetsclient/task/RunTask.java
new file mode 100644
index 0000000..4b5fe7a
--- /dev/null
+++ b/bitgetsClient/src/main/java/org/example/bitgetsclient/task/RunTask.java
@@ -0,0 +1,43 @@
+package org.example.bitgetsclient.task;
+
+import lombok.extern.slf4j.Slf4j;
+import org.example.bitgetsclient.BitgetsClientApplication;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.web.servlet.function.ServerResponse;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * @program: demo
+ * @description:
+ * @create: 2024-08-05 10:04
+ **/
+@Component
+@Slf4j
+public class RunTask {
+
+ @Autowired
+ private ConfigurableApplicationContext context;
+
+ @Scheduled(cron = "0 0 */3 * * ?")
+ public void restart() {
+ Thread restartThread = new Thread(() -> {
+ try {
+ SpringApplication.exit(context, () -> 0);
+ SpringApplication.run(BitgetsClientApplication.class);
+ log.info("bitgets ws 重启成功");
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.error("bitgets ws 重启失败");
+ }
+ });
+ restartThread.setDaemon(false);
+ restartThread.start();
+ log.info("bitgets ws 重启失败");
+ }
+
+}
diff --git a/geteClient/src/main/java/org/example/geteclient/GeteClientApplication.java b/geteClient/src/main/java/org/example/geteclient/GeteClientApplication.java
index e055916..f0e13cc 100644
--- a/geteClient/src/main/java/org/example/geteclient/GeteClientApplication.java
+++ b/geteClient/src/main/java/org/example/geteclient/GeteClientApplication.java
@@ -2,7 +2,9 @@
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+@EnableScheduling
@SpringBootApplication
public class GeteClientApplication {
diff --git a/geteClient/src/main/java/org/example/geteclient/task/RunTask.java b/geteClient/src/main/java/org/example/geteclient/task/RunTask.java
new file mode 100644
index 0000000..dc4e948
--- /dev/null
+++ b/geteClient/src/main/java/org/example/geteclient/task/RunTask.java
@@ -0,0 +1,40 @@
+package org.example.geteclient.task;
+
+import lombok.extern.slf4j.Slf4j;
+import org.example.geteclient.GeteClientApplication;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @program: demo
+ * @description:
+ * @create: 2024-08-05 10:04
+ **/
+@Component
+@Slf4j
+public class RunTask {
+
+ @Autowired
+ private ConfigurableApplicationContext context;
+
+ @Scheduled(cron = "0 0 */3 * * ?")
+ public void restart() {
+ Thread restartThread = new Thread(() -> {
+ try {
+ SpringApplication.exit(context, () -> 0);
+ SpringApplication.run(GeteClientApplication.class);
+ log.info("bitgets ws 重启成功");
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.error("bitgets ws 重启失败");
+ }
+ });
+ restartThread.setDaemon(false);
+ restartThread.start();
+ log.info("bitgets ws 重启失败");
+ }
+
+}
diff --git a/kucoinClient/src/main/java/org/example/kucoinclient/KucoinClientApplication.java b/kucoinClient/src/main/java/org/example/kucoinclient/KucoinClientApplication.java
index 6485959..c6f9e3f 100644
--- a/kucoinClient/src/main/java/org/example/kucoinclient/KucoinClientApplication.java
+++ b/kucoinClient/src/main/java/org/example/kucoinclient/KucoinClientApplication.java
@@ -2,7 +2,9 @@
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+@EnableScheduling
@SpringBootApplication
public class KucoinClientApplication {
diff --git a/kucoinClient/src/main/java/org/example/kucoinclient/task/RunTask.java b/kucoinClient/src/main/java/org/example/kucoinclient/task/RunTask.java
new file mode 100644
index 0000000..da81afa
--- /dev/null
+++ b/kucoinClient/src/main/java/org/example/kucoinclient/task/RunTask.java
@@ -0,0 +1,40 @@
+package org.example.kucoinclient.task;
+
+import lombok.extern.slf4j.Slf4j;
+import org.example.kucoinclient.KucoinClientApplication;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @program: demo
+ * @description:
+ * @create: 2024-08-05 10:04
+ **/
+@Component
+@Slf4j
+public class RunTask {
+
+ @Autowired
+ private ConfigurableApplicationContext context;
+
+ @Scheduled(cron = "0 0 */3 * * ?")
+ public void restart() {
+ Thread restartThread = new Thread(() -> {
+ try {
+ SpringApplication.exit(context, () -> 0);
+ SpringApplication.run(KucoinClientApplication.class);
+ log.info("bitgets ws 重启成功");
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.error("bitgets ws 重启失败");
+ }
+ });
+ restartThread.setDaemon(false);
+ restartThread.start();
+ log.info("bitgets ws 重启失败");
+ }
+
+}
diff --git a/mexcClient/src/main/java/org/example/mexcclient/MexcClientApplication.java b/mexcClient/src/main/java/org/example/mexcclient/MexcClientApplication.java
index c83ac19..942eb3b 100644
--- a/mexcClient/src/main/java/org/example/mexcclient/MexcClientApplication.java
+++ b/mexcClient/src/main/java/org/example/mexcclient/MexcClientApplication.java
@@ -2,7 +2,9 @@
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+@EnableScheduling
@SpringBootApplication
public class MexcClientApplication {
diff --git a/mexcClient/src/main/java/org/example/mexcclient/task/RunTask.java b/mexcClient/src/main/java/org/example/mexcclient/task/RunTask.java
new file mode 100644
index 0000000..0152071
--- /dev/null
+++ b/mexcClient/src/main/java/org/example/mexcclient/task/RunTask.java
@@ -0,0 +1,40 @@
+package org.example.mexcclient.task;
+
+import lombok.extern.slf4j.Slf4j;
+import org.example.mexcclient.MexcClientApplication;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @program: demo
+ * @description:
+ * @create: 2024-08-05 10:04
+ **/
+@Component
+@Slf4j
+public class RunTask {
+
+ @Autowired
+ private ConfigurableApplicationContext context;
+
+ @Scheduled(cron = "0 0 */3 * * ?")
+ public void restart() {
+ Thread restartThread = new Thread(() -> {
+ try {
+ SpringApplication.exit(context, () -> 0);
+ SpringApplication.run(MexcClientApplication.class);
+ log.info("bitgets ws 重启成功");
+ } catch (Exception e) {
+ e.printStackTrace();
+ log.error("bitgets ws 重启失败");
+ }
+ });
+ restartThread.setDaemon(false);
+ restartThread.start();
+ log.info("bitgets ws 重启失败");
+ }
+
+}
--
Gitblit v1.9.3