Bladeren bron

新增Jboot执行器Sample示例项目

xuxueli 6 jaren geleden
bovenliggende
commit
f1a6f8120c

+ 1 - 1
xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/xxl-job-executor.properties Bestand weergeven

@@ -4,7 +4,7 @@ xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
4 4
 ### xxl-job executor address
5 5
 xxl.job.executor.appname=xxl-job-executor-sample
6 6
 xxl.job.executor.ip=
7
-xxl.job.executor.port=9995
7
+xxl.job.executor.port=9994
8 8
 
9 9
 ### xxl-job, access token
10 10
 xxl.job.accessToken=

+ 14 - 88
xxl-job-executor-samples/xxl-job-executor-sample-jboot/pom.xml Bestand weergeven

@@ -1,33 +1,27 @@
1 1
 <?xml version="1.0" encoding="UTF-8"?>
2
-
3
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
2
+<project xmlns="http://maven.apache.org/POM/4.0.0"
3
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4 4
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5 5
     <parent>
6
-        <artifactId>xxl-job-executor-samples</artifactId>
7 6
         <groupId>com.xuxueli</groupId>
7
+        <artifactId>xxl-job-executor-samples</artifactId>
8 8
         <version>2.1.0-SNAPSHOT</version>
9 9
     </parent>
10 10
     <modelVersion>4.0.0</modelVersion>
11
-
12 11
     <artifactId>xxl-job-executor-sample-jboot</artifactId>
13
-
14
-    <name>${project.artifactId}</name>
15
-    <description>Example executor project for spring boot.</description>
16
-    <url>http://www.xuxueli.com/</url>
12
+    <packaging>jar</packaging>
17 13
 
18 14
     <properties>
19
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
20
-        <maven.compiler.source>1.7</maven.compiler.source>
21
-        <maven.compiler.target>1.7</maven.compiler.target>
15
+        <maven.compiler.source>1.8</maven.compiler.source>
16
+        <maven.compiler.target>1.8</maven.compiler.target>
22 17
     </properties>
23 18
 
24 19
     <dependencies>
25
-
20
+        <!-- jboot -->
26 21
         <dependency>
27
-            <groupId>junit</groupId>
28
-            <artifactId>junit</artifactId>
29
-            <version>4.11</version>
30
-            <scope>test</scope>
22
+            <groupId>io.jboot</groupId>
23
+            <artifactId>jboot</artifactId>
24
+            <version>2.0.9</version>
31 25
         </dependency>
32 26
 
33 27
         <!-- xxl-job-core -->
@@ -38,12 +32,12 @@
38 32
         </dependency>
39 33
 
40 34
         <dependency>
41
-            <groupId>io.jboot</groupId>
42
-            <artifactId>jboot</artifactId>
43
-            <version>2.0.9</version>
35
+            <groupId>junit</groupId>
36
+            <artifactId>junit</artifactId>
37
+            <version>4.11</version>
38
+            <scope>test</scope>
44 39
         </dependency>
45 40
 
46
-
47 41
         <dependency>
48 42
             <groupId>ch.qos.logback</groupId>
49 43
             <artifactId>logback-core</artifactId>
@@ -58,72 +52,4 @@
58 52
 
59 53
     </dependencies>
60 54
 
61
-    <build>
62
-
63
-        <resources>
64
-            <resource>
65
-                <directory>src/main/java</directory>
66
-                <includes>
67
-                    <include>**/*.xml</include>
68
-                </includes>
69
-                <filtering>true</filtering>
70
-            </resource>
71
-            <resource>
72
-                <directory>src/main/resources</directory>
73
-                <includes>
74
-                    <include>**/*</include>
75
-                </includes>
76
-                <filtering>true</filtering>
77
-            </resource>
78
-            <resource>
79
-                <directory>src/main/webapp</directory>
80
-                <includes>
81
-                    <include>**/</include>
82
-                </includes>
83
-                <filtering>true</filtering>
84
-            </resource>
85
-        </resources>
86
-
87
-        <plugins>
88
-            <plugin>
89
-                <groupId>org.apache.maven.plugins</groupId>
90
-                <artifactId>maven-compiler-plugin</artifactId>
91
-                <configuration>
92
-                    <source>1.8</source>
93
-                    <target>1.8</target>
94
-                </configuration>
95
-            </plugin>
96
-            <plugin>
97
-                <groupId>org.codehaus.mojo</groupId>
98
-                <artifactId>appassembler-maven-plugin</artifactId>
99
-                <version>1.10</version>
100
-                <configuration>
101
-                    <assembleDirectory>${project.build.directory}/app</assembleDirectory>
102
-                    <repositoryName>lib</repositoryName>
103
-                    <binFolder>bin</binFolder>
104
-                    <configurationDirectory>webRoot</configurationDirectory>
105
-                    <copyConfigurationDirectory>true</copyConfigurationDirectory>
106
-                    <configurationSourceDirectory>src/main/resources</configurationSourceDirectory>
107
-                    <repositoryLayout>flat</repositoryLayout>
108
-                    <encoding>UTF-8</encoding>
109
-                    <logsDirectory>logs</logsDirectory>
110
-                    <tempDirectory>tmp</tempDirectory>
111
-
112
-                    <programs>
113
-                        <program>
114
-                            <mainClass>io.jboot.Jboot</mainClass>
115
-                            <id>jboot</id>
116
-                            <platforms>
117
-                                <platform>windows</platform>
118
-                                <platform>unix</platform>
119
-                            </platforms>
120
-                        </program>
121
-                    </programs>
122
-                </configuration>
123
-            </plugin>
124
-
125
-        </plugins>
126
-
127
-    </build>
128
-
129 55
 </project>

xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/JbootApp.java → xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/JbootApp.java Bestand weergeven

@@ -1,11 +1,9 @@
1
-package com.xuxueli;
1
+package com.xuxueli.executor.sample.jboot;
2 2
 
3 3
 import io.jboot.app.JbootApplication;
4 4
 
5 5
 /**
6 6
  * Jboot app
7
- *
8
- * @author https://github.com/souvc
9 7
  */
10 8
 public class JbootApp {
11 9
     public static void main(String[] args) {

+ 0 - 4
xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/config/JbootConfig.java Bestand weergeven

@@ -10,11 +10,7 @@ import io.jboot.core.listener.JbootAppListenerBase;
10 10
 import org.slf4j.Logger;
11 11
 import org.slf4j.LoggerFactory;
12 12
 
13
-/**
14
- * @author https://github.com/souvc
15
- */
16 13
 public class JbootConfig extends JbootAppListenerBase {
17
-
18 14
     private Logger logger = LoggerFactory.getLogger(JbootConfig.class);
19 15
 
20 16
     // ---------------------- xxl-job executor ----------------------

+ 2 - 3
xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/controller/IndexController.java Bestand weergeven

@@ -3,13 +3,12 @@ package com.xuxueli.executor.sample.jboot.controller;
3 3
 import io.jboot.web.controller.JbootController;
4 4
 import io.jboot.web.controller.annotation.RequestMapping;
5 5
 
6
-/**
7
- * @author https://github.com/souvc
8
- */
6
+
9 7
 @RequestMapping("/")
10 8
 public class IndexController extends JbootController {
11 9
 
12 10
     public void index() {
13 11
         renderText("xxl job executor running.");
14 12
     }
13
+
15 14
 }

+ 2 - 2
xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/jboot.properties Bestand weergeven

@@ -1,4 +1,4 @@
1
-#jboot Æô¶¯¶Ë¿Ú
1
+#jboot port
2 2
 undertow.port=8082
3 3
 
4 4
 
@@ -8,7 +8,7 @@ xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
8 8
 ### xxl-job executor address
9 9
 xxl.job.executor.appname=xxl-job-executor-sample
10 10
 xxl.job.executor.ip=
11
-xxl.job.executor.port=9994
11
+xxl.job.executor.port=9995
12 12
 
13 13
 ### xxl-job, access token
14 14
 xxl.job.accessToken=

+ 11 - 131
xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/logback.xml Bestand weergeven

@@ -1,149 +1,29 @@
1 1
 <?xml version="1.0" encoding="UTF-8"?>
2
+<configuration debug="false" scan="true" scanPeriod="1 seconds">
2 3
 
3
-<!-- 级别从高到低 OFF 、 FATAL 、 ERROR 、 WARN 、 INFO 、 DEBUG 、 TRACE 、 ALL -->
4
-<!-- 日志输出规则 根据当前ROOT 级别,日志输出时,级别高于root默认的级别时 会输出 -->
5
-<!-- 以下 每个配置的 filter 是过滤掉输出文件里面,会出现高级别文件,依然出现低级别的日志信息,通过filter 过滤只记录本级别的日志 -->
6
-<!-- scan 当此属性设置为true时,配置文件如果发生改变,将会被重新加载,默认值为true。 -->
7
-<!-- scanPeriod 设置监测配置文件是否有修改的时间间隔,如果没有给出时间单位,默认单位是毫秒。当scan为true时,此属性生效。默认的时间间隔为1分钟。 -->
8
-<!-- debug 当此属性设置为true时,将打印出logback内部日志信息,实时查看logback运行状态。默认值为false。 -->
9
-<configuration scan="true" scanPeriod="60 seconds" debug="false">
4
+    <contextName>logback</contextName>
5
+    <property name="log.path" value="/data/applogs/xxl-job/xxl-job-executor-sample-jboot.log"/>
10 6
 
11
-    <!-- 动态日志级别 -->
12
-    <jmxConfigurator/>
13
-
14
-    <!-- 定义日志文件 输出位置 -->
15
-    <property name="log_dir" value="logs"/>
16
-
17
-    <!-- 日志最大的历史 30天 -->
18
-    <property name="maxHistory" value="30"/>
19
-
20
-    <!-- ConsoleAppender 控制台输出日志 -->
21 7
     <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
22 8
         <encoder>
23
-            <pattern>
24
-                <!-- 设置日志输出格式 -->
25
-                %d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %logger - %msg%n
26
-            </pattern>
9
+            <pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
27 10
         </encoder>
28 11
     </appender>
29 12
 
30
-    <!-- ERROR级别日志 -->
31
-    <!-- 滚动记录文件,先将日志记录到指定文件,当符合某个条件时,将日志记录到其他文件 RollingFileAppender -->
32
-    <appender name="ERROR"
33
-              class="ch.qos.logback.core.rolling.RollingFileAppender">
34
-        <!-- 过滤器,只记录WARN级别的日志 -->
35
-        <!-- 果日志级别等于配置级别,过滤器会根据onMath 和 onMismatch接收或拒绝日志。 -->
36
-        <filter class="ch.qos.logback.classic.filter.LevelFilter">
37
-            <!-- 设置过滤级别 -->
38
-            <level>ERROR</level>
39
-            <!-- 用于配置符合过滤条件的操作 -->
40
-            <onMatch>ACCEPT</onMatch>
41
-            <!-- 用于配置不符合过滤条件的操作 -->
42
-            <onMismatch>DENY</onMismatch>
43
-        </filter>
44
-        <!-- 最常用的滚动策略,它根据时间来制定滚动策略.既负责滚动也负责出发滚动 -->
13
+    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
14
+        <file>${log.path}</file>
45 15
         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
46
-            <!--日志输出位置 可相对、和绝对路径 -->
47
-            <fileNamePattern>
48
-                ${log_dir}/error/%d{yyyy-MM-dd}/logs.log
49
-            </fileNamePattern>
50
-            <!-- 可选节点,控制保留的归档文件的最大数量,超出数量就删除旧文件假设设置每个月滚动,且<maxHistory>是6, 则只保存最近6个月的文件,删除之前的旧文件。注意,删除旧文件是,那些为了归档而创建的目录也会被删除 -->
51
-            <maxHistory>${maxHistory}</maxHistory>
16
+            <fileNamePattern>${log.path}.%d{yyyy-MM-dd}.zip</fileNamePattern>
52 17
         </rollingPolicy>
53 18
         <encoder>
54
-            <pattern>
55
-                <!-- 设置日志输出格式 -->
56
-                %d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %logger - %msg%n
19
+            <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n
57 20
             </pattern>
58 21
         </encoder>
59 22
     </appender>
60 23
 
61
-
62
-    <!-- WARN级别日志 appender -->
63
-    <appender name="WARN" class="ch.qos.logback.core.rolling.RollingFileAppender">
64
-        <!-- 过滤器,只记录WARN级别的日志 -->
65
-        <!-- 果日志级别等于配置级别,过滤器会根据onMath 和 onMismatch接收或拒绝日志。 -->
66
-        <filter class="ch.qos.logback.classic.filter.LevelFilter">
67
-            <!-- 设置过滤级别 -->
68
-            <level>WARN</level>
69
-            <!-- 用于配置符合过滤条件的操作 -->
70
-            <onMatch>ACCEPT</onMatch>
71
-            <!-- 用于配置不符合过滤条件的操作 -->
72
-            <onMismatch>DENY</onMismatch>
73
-        </filter>
74
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
75
-            <!--日志输出位置 可相对、和绝对路径 -->
76
-            <fileNamePattern>${log_dir}/warn/%d{yyyy-MM-dd}/logs.log</fileNamePattern>
77
-            <maxHistory>${maxHistory}</maxHistory>
78
-        </rollingPolicy>
79
-        <encoder>
80
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %logger - %msg%n</pattern>
81
-        </encoder>
82
-    </appender>
83
-
84
-
85
-    <!-- INFO级别日志 appender -->
86
-    <appender name="INFO" class="ch.qos.logback.core.rolling.RollingFileAppender">
87
-        <filter class="ch.qos.logback.classic.filter.LevelFilter">
88
-            <level>INFO</level>
89
-            <onMatch>ACCEPT</onMatch>
90
-            <onMismatch>DENY</onMismatch>
91
-        </filter>
92
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
93
-            <fileNamePattern>${log_dir}/info/%d{yyyy-MM-dd}/logs.log</fileNamePattern>
94
-            <maxHistory>${maxHistory}</maxHistory>
95
-        </rollingPolicy>
96
-        <encoder>
97
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %logger - %msg%n</pattern>
98
-        </encoder>
99
-    </appender>
100
-
101
-
102
-    <!-- DEBUG级别日志 appender -->
103
-    <appender name="DEBUG" class="ch.qos.logback.core.rolling.RollingFileAppender">
104
-        <filter class="ch.qos.logback.classic.filter.LevelFilter">
105
-            <level>DEBUG</level>
106
-            <onMatch>ACCEPT</onMatch>
107
-            <onMismatch>DENY</onMismatch>
108
-        </filter>
109
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
110
-            <fileNamePattern>${log_dir}/debug/%d{yyyy-MM-dd}/logs.log</fileNamePattern>
111
-            <maxHistory>${maxHistory}</maxHistory>
112
-        </rollingPolicy>
113
-        <encoder>
114
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %logger - %msg%n</pattern>
115
-        </encoder>
116
-    </appender>
117
-
118
-
119
-    <!-- TRACE级别日志 appender -->
120
-    <appender name="TRACE" class="ch.qos.logback.core.rolling.RollingFileAppender">
121
-        <filter class="ch.qos.logback.classic.filter.LevelFilter">
122
-            <level>TRACE</level>
123
-            <onMatch>ACCEPT</onMatch>
124
-            <onMismatch>DENY</onMismatch>
125
-        </filter>
126
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
127
-            <fileNamePattern>${log_dir}/trace/%d{yyyy-MM-dd}/logs.log</fileNamePattern>
128
-            <maxHistory>${maxHistory}</maxHistory>
129
-        </rollingPolicy>
130
-        <encoder>
131
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %-5level %logger - %msg%n</pattern>
132
-        </encoder>
133
-    </appender>
134
-
135
-
136
-    <!-- root级别   DEBUG -->
137
-    <root>
138
-        <!-- 打印debug级别日志及以上级别日志 -->
139
-        <level value="info"/>
140
-        <!-- 控制台输出 -->
24
+    <root level="info">
141 25
         <appender-ref ref="console"/>
142
-        <!-- 文件输出 -->
143
-        <!--<appender-ref ref="ERROR"/>-->
144
-        <!--<appender-ref ref="INFO"/>-->
145
-        <!--<appender-ref ref="WARN"/>-->
146
-        <!--<appender-ref ref="DEBUG"/>-->
147
-        <!--<appender-ref ref="TRACE"/>-->
26
+        <appender-ref ref="file"/>
148 27
     </root>
28
+
149 29
 </configuration>

+ 5 - 7
xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/test/java/com/xuxueli/AppTest.java Bestand weergeven

@@ -1,20 +1,18 @@
1 1
 package com.xuxueli;
2 2
 
3
-import static org.junit.Assert.assertTrue;
4
-
5 3
 import org.junit.Test;
6 4
 
5
+import static org.junit.Assert.assertTrue;
6
+
7 7
 /**
8 8
  * Unit test for simple App.
9 9
  */
10
-public class AppTest 
11
-{
10
+public class AppTest {
12 11
     /**
13 12
      * Rigorous Test :-)
14 13
      */
15 14
     @Test
16
-    public void shouldAnswerWithTrue()
17
-    {
18
-        assertTrue( true );
15
+    public void shouldAnswerWithTrue() {
16
+        assertTrue(true);
19 17
     }
20 18
 }