Explorar o código

qr_platform配置xxljob,编写demo

v_HuilingDeng %!s(int64=3) %!d(string=hai) anos
pai
achega
7ce24d2e28

+ 55 - 0
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/config/XxlJobConfig.java

@@ -0,0 +1,55 @@
+package com.abi.qms.platform.infrastructure.config;
+
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author eurus
+ */
+@Slf4j
+@Configuration
+public class XxlJobConfig {
+    @Value("${xxl.job.admin.addresses}")
+    private String adminAddresses;
+
+    @Value("${xxl.job.accessToken}")
+    private String accessToken;
+
+    @Value("${xxl.job.executor.appname}")
+    private String appname;
+
+    @Value("${xxl.job.executor.address}")
+    private String address;
+
+    @Value("${xxl.job.executor.ip}")
+    private String ip;
+
+    @Value("${xxl.job.executor.port}")
+    private int port;
+
+    @Value("${xxl.job.executor.logpath}")
+    private String logPath;
+
+    @Value("${xxl.job.executor.logretentiondays}")
+    private int logRetentionDays;
+
+    @Bean
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        log.info(">>>>>>>>>>> xxl-job config init.");
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppname(appname);
+        xxlJobSpringExecutor.setAddress(address);
+        xxlJobSpringExecutor.setIp(ip);
+        xxlJobSpringExecutor.setPort(port);
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogPath(logPath);
+        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+
+        return xxlJobSpringExecutor;
+    }
+
+}

+ 29 - 0
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/task/XxlDemo.java

@@ -0,0 +1,29 @@
+package com.abi.qms.platform.infrastructure.task;
+
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author Eurus
+ * @date 2021/5/8 17:48
+ * @Description:
+ */
+@Slf4j
+@Component
+public class XxlDemo {
+
+    @XxlJob(value = "xxlJobDemo")
+    public ReturnT<String> xxlJobDemo(){
+        try {
+            //商品定时上架
+            log.info("====xxljob测试====" + LocalDateTime.now());
+        } catch (Exception e) {
+            log.error("tipRecordExpire execute error:", e);
+        }
+        return ReturnT.SUCCESS;
+    }
+}

+ 1 - 1
abi-cloud-qr-platform-server/src/main/resources/application.yml

@@ -81,7 +81,7 @@ xxl:
     admin:
       addresses: ${XXL_JOB_ADMIN_ADDRESSES}
     executor:
-      appname: xxl-job-executor-task-cirle
+      appname: xxl-job-executor-qr-platform
       ip:
       port: ${XXL_JOB_EXECUTOR_PORT}
       logpath: D:/xxlJob/