1

pom.xml

@@ -112,6 +112,11 @@
             <artifactId>4dkankan-utils-dingtalk</artifactId>
             <version>3.0.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.fdkankan</groupId>
+            <artifactId>4dkankan-utils-redis</artifactId>
+            <version>3.0.0-SNAPSHOT</version>
+        </dependency>
 
     </dependencies>
 

src/main/java/com/fdkankan/task/jobhandler/rtk/RtkXxlJob.java

@@ -0,0 +1,50 @@
+package com.fdkankan.task.jobhandler.rtk;
+
+import com.fdkankan.dingtalk.DingTalkSendUtils;
+import com.fdkankan.redis.util.RedisUtil;
+import com.fdkankan.task.entity.Repair;
+import com.fdkankan.task.jobhandler.sale.SaleXxlJobUtil;
+import com.fdkankan.task.mapper.RepairMapper;
+import com.mybatisflex.core.query.QueryWrapper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Set;
+import java.util.UUID;
+
+/**
+ * XxlJob开发示例（Bean模式）
+ *
+ * 开发步骤：
+ *      1、任务开发：在Spring Bean实例中，开发Job方法；
+ *      2、注解配置：为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。
+ *      3、执行日志：需要通过 "XxlJobHelper.log" 打印执行日志；
+ *      4、任务结果：默认任务结果为 "成功" 状态，不需要主动设置；如有诉求，比如设置任务结果为失败，可以通过 "XxlJobHelper.handleFail/handleSuccess" 自主设置任务结果；
+ *
+ * @author xuxueli 2019-12-11 21:52:51
+ */
+@Component
+public class RtkXxlJob {
+    private static Logger logger = LoggerFactory.getLogger(RtkXxlJob.class);
+
+    @Autowired
+    RedisUtil redisUtil;
+
+    /**
+     * 获取同时使用rtk数量
+     */
+    @XxlJob("rtkAccountCount")
+    public void rtkAccountCount(){
+        String redisKey = "4dkankan:rtk:snCode:*";
+        Set<String> keys = redisUtil.keys(redisKey);
+        logger.info("rtk在线数量为4dkankan:rtk:snCode:count{}",keys.size());
+    }
+
+
+
+}

src/main/resources/application.yml

@@ -39,6 +39,25 @@ mybatis-flex:
       username: root
       password: zfb@20210727%
 
+spring:
+  redis:
+    host: r-wz9owsphxqwi4ztqlf.redis.rds.aliyuncs.com
+    port: 6379
+    timeout: 6000ms
+    password: 3oo19bgh0cae2406&
+    # cluster:
+    #   max-redirects: 3  # 获取失败 最大重定向次数
+    #   nodes:
+    #     - 120.25.146.52:6379
+    jedis:
+      pool:
+        max-active: 10  #连接池最大连接数（使用负值表示没有限制）
+        max-idle: 10 # 连接池中的最大空闲连接
+        min-idle: 5 # 连接池中的最小空闲连接
+        max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
+    lettuce:
+      shutdown-timeout: 0ms
+
 logging:
   config: classpath:logback-spring.xml
   path: /home/backend/4dkankan_v4