feat: 1.0.0

完成项目迁移

easy-retry-server/pom.xml

@@ -33,11 +33,11 @@
             <artifactId>akka-actor-typed_2.13</artifactId>
             <version>2.8.0</version>
         </dependency>
-        <dependency>
+<!--        <dependency>-->
-            <groupId>ch.qos.logback</groupId>
+<!--            <groupId>ch.qos.logback</groupId>-->
-            <artifactId>logback-classic</artifactId>
+<!--            <artifactId>logback-classic</artifactId>-->
-            <version>1.4.6</version>
+<!--            <version>1.2.3</version>-->
-        </dependency>
+<!--        </dependency>-->
         <dependency>
             <groupId>com.typesafe.akka</groupId>
             <artifactId>akka-actor-testkit-typed_2.13</artifactId>
@@ -109,6 +109,11 @@
             <artifactId>commons-lang</artifactId>
             <version>2.6</version>
         </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.slf4j</groupId>-->
+<!--            <artifactId>slf4j-nop</artifactId>-->
+<!--            <version>1.7.2</version>-->
+<!--        </dependency>-->
     </dependencies>
 
     <build>

easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/scan/ScanGroupActor.java

@@ -2,6 +2,7 @@ package com.aizuda.easy.retry.server.support.dispatch.actor.scan;
 
 import akka.actor.AbstractActor;
 import akka.actor.ActorRef;
+import com.aizuda.easy.retry.server.support.retry.RetryExecutor;
 import com.aizuda.easy.retry.server.support.strategy.FilterStrategies;
 import com.aizuda.easy.retry.server.support.strategy.StopStrategies;
 import com.aizuda.easy.retry.common.core.log.LogUtils;

easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/listener/EndListener.java

@@ -25,7 +25,7 @@ public class EndListener implements ApplicationListener<ContextClosedEvent> {
 
     @Override
     public void onApplicationEvent(ContextClosedEvent event) {
-        LogUtils.info(log, "easy-retry-SERVER 停止");
+        LogUtils.info(log, "EASY-RETRY-SERVER 停止");
         lifecycleList.forEach(Lifecycle::close);
     }
 }

easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/listener/StartListener.java

@@ -25,7 +25,7 @@ public class StartListener implements ApplicationListener<ContextRefreshedEvent>
 
     @Override
     public void onApplicationEvent(ContextRefreshedEvent event) {
-        LogUtils.info(log, "easy-retry-SERVER 启动");
+        LogUtils.info(log, "EASY-RETRY-SERVER 启动");
         lifecycleList.forEach(Lifecycle::start);
     }
 }

easy-retry-server/src/main/resources/application.yml

@@ -7,14 +7,14 @@ spring:
     username: root
     password: root
     type: com.zaxxer.hikari.HikariDataSource
-    driver-class-name: com.mysql.jdbc.Driver
+    driver-class-name: com.mysql.cj.jdbc.Driver
     hikari:
       connection-timeout: 30000
       minimum-idle: 5
       maximum-pool-size: 20
       auto-commit: true
       idle-timeout: 30000
-      pool-name: x_retry
+      pool-name: easy_retry
       max-lifetime: 1800000
       connection-test-query: SELECT 1
   web:
@@ -32,7 +32,8 @@ mybatis-plus:
   configuration:
     map-underscore-to-camel-case: true
     cache-enabled: true
-
+logging:
+  config: classpath:logback-boot.xml
 easy-retry:
   lastDays: 30 # 拉取重试数据的天数
   retryPullPageSize: 100 # 拉取重试数据的每批次的大小

easy-retry-server/src/main/resources/logback-boot.xml

@@ -0,0 +1,50 @@
+<configuration>
+    <!-- %m输出的信息,%p日志级别,%t线程名,%d日期,%c类的全名,%i索引【从数字0开始递增】,,, -->
+    <!-- appender是configuration的子节点，是负责写日志的组件。 -->
+    <!-- ConsoleAppender：把日志输出到控制台 -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d %p (%file:%line\)- %m%n</pattern>
+            <!-- 控制台也要使用UTF-8，不要使用GBK，否则会中文乱码 -->
+            <charset>UTF-8</charset>
+        </encoder>
+    </appender>
+    <!-- RollingFileAppender：滚动记录文件，先将日志记录到指定文件，当符合某个条件时，将日志记录到其他文件 -->
+    <!-- 以下的大概意思是：1.先按日期存日志，日期变了，将前一天的日志文件名重命名为XXX%日期%索引，新的日志仍然是sys.log -->
+    <!--             2.如果日期没有发生变化，但是当前日志的文件大小超过1KB时，对当前日志进行分割 重命名-->
+    <appender name="syslog"
+              class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <File>log/sys.log</File>
+        <!-- rollingPolicy:当发生滚动时，决定 RollingFileAppender 的行为，涉及文件移动和重命名。 -->
+        <!-- TimeBasedRollingPolicy： 最常用的滚动策略，它根据时间来制定滚动策略，既负责滚动也负责出发滚动 -->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!-- 活动文件的名字会根据fileNamePattern的值，每隔一段时间改变一次 -->
+            <!-- 文件名：log/sys.2017-12-05.0.log -->
+            <fileNamePattern>log/sys.%d.%i.log</fileNamePattern>
+            <!-- 每产生一个日志文件，该日志文件的保存期限为30天 -->
+            <maxHistory>30</maxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy  class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <!-- maxFileSize:这是活动文件的大小，默认值是10MB,本篇设置为1KB，只是为了演示 -->
+                <maxFileSize>1KB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <!-- pattern节点，用来设置日志的输入格式 -->
+            <pattern>
+                %d %p (%file:%line\)- %m%n
+            </pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+    <!-- 控制台输出日志级别 -->
+    <root level="info">
+        <appender-ref ref="STDOUT" />
+    </root>
+    <!-- 指定项目中某个包，当有日志操作行为时的日志记录级别 -->
+    <!-- com.appley为根包，也就是只要是发生在这个根包下面的所有日志操作行为的权限都是DEBUG -->
+    <!-- 级别依次为【从高到低】：FATAL > ERROR > WARN > INFO > DEBUG > TRACE  -->
+    <logger name="com" level="INFO">
+        <appender-ref ref="syslog" />
+    </logger>
+</configuration>