定时任务增加useProperties属性

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/util/RandImageUtil.java

@@ -1,5 +1,7 @@
 package org.jeecg.modules.system.util;
 
+import lombok.extern.slf4j.Slf4j;
+
 import javax.imageio.ImageIO;
 import javax.servlet.http.HttpServletResponse;
 import java.awt.*;
@@ -13,6 +15,7 @@ import java.util.Random;
  * 登录验证码工具类
  * @author: jeecg-boot
  */
+@Slf4j
 public class RandImageUtil {
 
     public static final String KEY = "JEECG_LOGIN_KEY";
@@ -118,9 +121,11 @@ public class RandImageUtil {
             graphics.setColor(Color.BLACK);
             // 设置字体样式
 //			graphics.setFont(new Font("Arial Black", Font.ITALIC, 18));
+//            k8s下不好用，暂时去掉
             graphics.setFont(new Font("Times New Roman", Font.BOLD, 24));
             // 设置字符，字符间距，上边距
-            graphics.drawString(String.valueOf(resultCode.charAt(i)), (23 * i) + 8, 26);
+//            k8s下不好用，暂时去掉
+//            graphics.drawString(String.valueOf(resultCode.charAt(i)), (23 * i) + 8, 26);
         }
         // 图象生效
         graphics.dispose();

jeecg-module-system/jeecg-system-start/Dockerfile

@@ -15,5 +15,6 @@ EXPOSE 8520
 
 #ADD ./src/main/resources/jeecg ./config/jeecg
 ADD ./jeecg-system-start-3.4.3.jar ./
+ADD ./application-prod.yml ./
 
 CMD sleep 60;java -Djava.security.egd=file:/dev/./urandom -jar jeecg-system-start-3.4.3.jar

jeecg-module-system/jeecg-system-start/src/main/resources/application-dev.yml

@@ -112,6 +112,7 @@ spring:
             tablePrefix: QRTZ_
             isClustered: true
             misfireThreshold: 12000
+            useProperties: true
             clusterCheckinInterval: 15000
           threadPool:
             class: org.quartz.simpl.SimpleThreadPool

jeecg-module-system/jeecg-system-start/src/main/resources/application-docker.yml

@@ -39,45 +39,58 @@ spring:
           starttls:
             enable: true
             required: true
+
+  ##mqtt配置
+  mqtt:
+    username: root
+    password: BBQm9EcZiPg_hXwVxGVX
+    #    mqtt
+    host-url: 172.21.92.202:15672
+    clientId: mqttId555
+    completionTimeout: 3000
+    timeout: 1000
+    keepalive: 20
+    topic: device/#
+
   ## kafka配置
-  kafka:
-    bootstrap-servers: 127.0.0.1:9092
-    producer:
-      # 发生错误后，消息重发的次数。
-      retries: 1
-      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
-      batch-size: 16384
-      # 设置生产者内存缓冲区的大小。
-      buffer-memory: 33554432
-      # 键的序列化方式
-      key-serializer: org.apache.kafka.common.serialization.StringSerializer
-      # 值的序列化方式
-      value-serializer: org.apache.kafka.common.serialization.StringSerializer
-      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
-      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
-      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
-      acks: 0
-    consumer:
-      group-id: thing___property
-      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
-      auto-commit-interval: 1S
-      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
-      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
-      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
-      auto-offset-reset: latest
-      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
-      enable-auto-commit: false
-      # 键的反序列化方式
-      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-      # 值的反序列化方式
-      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-    listener:
-      # 在侦听器容器中运行的线程数。
-      concurrency: 5
-      #listner负责ack，每调用一次，就立即commit
-      ack-mode: manual_immediate
-      missing-topics-fatal: false
-    topic-patterns: ".*."  # 这里使用通配符来匹配多个主题
+#  kafka:
+#    bootstrap-servers: 127.0.0.1:9092
+#    producer:
+#      # 发生错误后，消息重发的次数。
+#      retries: 1
+#      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
+#      batch-size: 16384
+#      # 设置生产者内存缓冲区的大小。
+#      buffer-memory: 33554432
+#      # 键的序列化方式
+#      key-serializer: org.apache.kafka.common.serialization.StringSerializer
+#      # 值的序列化方式
+#      value-serializer: org.apache.kafka.common.serialization.StringSerializer
+#      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
+#      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
+#      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
+#      acks: 0
+#    consumer:
+#      group-id: thing___property
+#      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
+#      auto-commit-interval: 1S
+#      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
+#      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
+#      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
+#      auto-offset-reset: latest
+#      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
+#      enable-auto-commit: false
+#      # 键的反序列化方式
+#      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+#      # 值的反序列化方式
+#      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+#    listener:
+#      # 在侦听器容器中运行的线程数。
+#      concurrency: 5
+#      #listner负责ack，每调用一次，就立即commit
+#      ack-mode: manual_immediate
+#      missing-topics-fatal: false
+#    topic-patterns: ".*."  # 这里使用通配符来匹配多个主题
   ## quartz定时任务,采用数据库方式
   quartz:
     job-store-type: jdbc
@@ -101,6 +114,7 @@ spring:
             tablePrefix: QRTZ_
             isClustered: true
             misfireThreshold: 12000
+            useProperties: true
             clusterCheckinInterval: 15000
           threadPool:
             class: org.quartz.simpl.SimpleThreadPool
@@ -200,7 +214,7 @@ spring:
   redis:
     database: 0
     host: interlock_redis
-    port: 6379
+    port: 6380
     password:
 
 #mybatis plus 设置
@@ -284,7 +298,7 @@ jeecg:
     logRetentionDays: 30
   #分布式锁配置
   redisson:
-    address: http://interlock_redis:6379
+    address: http://interlock_redis:6380
     password:
     type: STANDALONE
     enabled: true

jeecg-module-system/jeecg-system-start/src/main/resources/application-k8s.yml

@@ -40,44 +40,44 @@ spring:
             enable: true
             required: true
   ## kafka配置
-  kafka:
-    bootstrap-servers: 127.0.0.1:9092
-    producer:
-      # 发生错误后，消息重发的次数。
-      retries: 1
-      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
-      batch-size: 16384
-      # 设置生产者内存缓冲区的大小。
-      buffer-memory: 33554432
-      # 键的序列化方式
-      key-serializer: org.apache.kafka.common.serialization.StringSerializer
-      # 值的序列化方式
-      value-serializer: org.apache.kafka.common.serialization.StringSerializer
-      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
-      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
-      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
-      acks: 0
-    consumer:
-      group-id: thing___property
-      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
-      auto-commit-interval: 1S
-      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
-      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
-      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
-      auto-offset-reset: latest
-      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
-      enable-auto-commit: false
-      # 键的反序列化方式
-      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-      # 值的反序列化方式
-      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-    listener:
-      # 在侦听器容器中运行的线程数。
-      concurrency: 5
-      #listner负责ack，每调用一次，就立即commit
-      ack-mode: manual_immediate
-      missing-topics-fatal: false
-    topic-patterns: ".*."  # 这里使用通配符来匹配多个主题
+#  kafka:
+#    bootstrap-servers: 127.0.0.1:9092
+#    producer:
+#      # 发生错误后，消息重发的次数。
+#      retries: 1
+#      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
+#      batch-size: 16384
+#      # 设置生产者内存缓冲区的大小。
+#      buffer-memory: 33554432
+#      # 键的序列化方式
+#      key-serializer: org.apache.kafka.common.serialization.StringSerializer
+#      # 值的序列化方式
+#      value-serializer: org.apache.kafka.common.serialization.StringSerializer
+#      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
+#      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
+#      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
+#      acks: 0
+#    consumer:
+#      group-id: thing___property
+#      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
+#      auto-commit-interval: 1S
+#      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
+#      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
+#      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
+#      auto-offset-reset: latest
+#      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
+#      enable-auto-commit: false
+#      # 键的反序列化方式
+#      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+#      # 值的反序列化方式
+#      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+#    listener:
+#      # 在侦听器容器中运行的线程数。
+#      concurrency: 5
+#      #listner负责ack，每调用一次，就立即commit
+#      ack-mode: manual_immediate
+#      missing-topics-fatal: false
+#    topic-patterns: ".*."  # 这里使用通配符来匹配多个主题
   ## quartz定时任务,采用数据库方式
   quartz:
     job-store-type: jdbc
@@ -101,6 +101,7 @@ spring:
             tablePrefix: QRTZ_
             isClustered: true
             misfireThreshold: 12000
+            useProperties: true
             clusterCheckinInterval: 15000
           threadPool:
             class: org.quartz.simpl.SimpleThreadPool

jeecg-module-system/jeecg-system-start/src/main/resources/application-prod.yml

@@ -39,45 +39,58 @@ spring:
           starttls:
             enable: true
             required: true
+
+  ##mqtt配置
+  mqtt:
+    username: guest
+    password: guest
+    #    mqtt
+    host-url: tcp://127.0.0.1:15672
+    clientId: mqttId555
+    completionTimeout: 3000
+    timeout: 1000
+    keepalive: 20
+    topic: device/#
+
   ## kafka配置
-  kafka:
-    bootstrap-servers: 127.0.0.1:9092
-    producer:
-      # 发生错误后，消息重发的次数。
-      retries: 1
-      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
-      batch-size: 16384
-      # 设置生产者内存缓冲区的大小。
-      buffer-memory: 33554432
-      # 键的序列化方式
-      key-serializer: org.apache.kafka.common.serialization.StringSerializer
-      # 值的序列化方式
-      value-serializer: org.apache.kafka.common.serialization.StringSerializer
-      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
-      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
-      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
-      acks: 0
-    consumer:
-      group-id: thing___property
-      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
-      auto-commit-interval: 1S
-      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
-      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
-      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
-      auto-offset-reset: latest
-      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
-      enable-auto-commit: false
-      # 键的反序列化方式
-      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-      # 值的反序列化方式
-      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-    listener:
-      # 在侦听器容器中运行的线程数。
-      concurrency: 5
-      #listner负责ack，每调用一次，就立即commit
-      ack-mode: manual_immediate
-      missing-topics-fatal: false
-    topic-patterns: ".*."  # 这里使用通配符来匹配多个主题
+#  kafka:
+#    bootstrap-servers: 127.0.0.1:9092
+#    producer:
+#      # 发生错误后，消息重发的次数。
+#      retries: 1
+#      #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。
+#      batch-size: 16384
+#      # 设置生产者内存缓冲区的大小。
+#      buffer-memory: 33554432
+#      # 键的序列化方式
+#      key-serializer: org.apache.kafka.common.serialization.StringSerializer
+#      # 值的序列化方式
+#      value-serializer: org.apache.kafka.common.serialization.StringSerializer
+#      # acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。
+#      # acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。
+#      # acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。
+#      acks: 0
+#    consumer:
+#      group-id: thing___property
+#      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
+#      auto-commit-interval: 1S
+#      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
+#      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
+#      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
+#      auto-offset-reset: latest
+#      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
+#      enable-auto-commit: false
+#      # 键的反序列化方式
+#      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+#      # 值的反序列化方式
+#      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+#    listener:
+#      # 在侦听器容器中运行的线程数。
+#      concurrency: 5
+#      #listner负责ack，每调用一次，就立即commit
+#      ack-mode: manual_immediate
+#      missing-topics-fatal: false
+#    topic-patterns: ".*."  # 这里使用通配符来匹配多个主题
   ## quartz定时任务,采用数据库方式
   quartz:
     job-store-type: jdbc
@@ -101,6 +114,7 @@ spring:
             tablePrefix: QRTZ_
             isClustered: true
             misfireThreshold: 12000
+            useProperties: true
             clusterCheckinInterval: 15000
           threadPool:
             class: org.quartz.simpl.SimpleThreadPool

jeecg-module-system/jeecg-system-start/src/main/resources/application-test.yml

@@ -57,6 +57,7 @@ spring:
             tablePrefix: QRTZ_
             isClustered: true
             misfireThreshold: 12000
+            useProperties: true
             clusterCheckinInterval: 15000
           threadPool:
             class: org.quartz.simpl.SimpleThreadPool
@@ -295,4 +296,4 @@ third-app:
       client-id: ??
       # appSecret
       client-secret: ??
-      agent-id: ??
+      agent-id: ??

jeecg-server-cloud/jeecg-cloud-nacos/docs/config/jeecg.yaml

@@ -56,6 +56,7 @@ spring:
             tablePrefix: QRTZ_
             isClustered: true
             misfireThreshold: 12000
+            useProperties: true
             clusterCheckinInterval: 15000
           threadPool:
             class: org.quartz.simpl.SimpleThreadPool
@@ -97,4 +98,4 @@ mybatis-plus:
       id-type: ASSIGN_ID
       table-underline: true
   configuration:
-    call-setters-on-nulls: true
+    call-setters-on-nulls: true