Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
X
xxl-job
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
刘晓滨
xxl-job
Commits
a360eaa5
Commit
a360eaa5
authored
Dec 17, 2018
by
陈烨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
新增xxl-job-springboot-bak
parent
0e27fc29
Show whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
701 additions
and
0 deletions
+701
-0
pom.xml
...or-samples/xxl-job-executor-sample-springboot-bak/pom.xml
+129
-0
XxlJobExecutorApplication.java
.../java/com/xxl/job/executor/XxlJobExecutorApplication.java
+18
-0
XxlJobConfig.java
...n/java/com/xxl/job/executor/core/config/XxlJobConfig.java
+63
-0
IndexController.java
.../com/xxl/job/executor/mvc/controller/IndexController.java
+19
-0
CommandJobHandler.java
...xl/job/executor/service/jobhandler/CommandJobHandler.java
+58
-0
DemoJobHandler.java
...m/xxl/job/executor/service/jobhandler/DemoJobHandler.java
+38
-0
HttpJobHandler.java
...m/xxl/job/executor/service/jobhandler/HttpJobHandler.java
+67
-0
PushKcDateHandler.java
...xl/job/executor/service/jobhandler/PushKcDateHandler.java
+58
-0
SendReadAlarmJobHandler.java
.../executor/service/jobhandler/SendReadAlarmJobHandler.java
+37
-0
ShardingJobHandler.java
...l/job/executor/service/jobhandler/ShardingJobHandler.java
+38
-0
application.properties
...-springboot-bak/src/main/resources/application.properties
+22
-0
logback.xml
...utor-sample-springboot-bak/src/main/resources/logback.xml
+30
-0
spacetech-consumer-apihub.xml
...boot-bak/src/main/resources/spacetech-consumer-apihub.xml
+106
-0
XxlJobExecutorExampleBootApplicationTests.java
...cutor/test/XxlJobExecutorExampleBootApplicationTests.java
+18
-0
No files found.
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/pom.xml
0 → 100644
View file @
a360eaa5
<?xml version="1.0" encoding="UTF-8"?>
<project
xmlns=
"http://maven.apache.org/POM/4.0.0"
xmlns:xsi=
"http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation=
"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
>
<modelVersion>
4.0.0
</modelVersion>
<parent>
<groupId>
com.xuxueli
</groupId>
<artifactId>
xxl-job-executor-samples
</artifactId>
<version>
2.0.1-SNAPSHOT
</version>
</parent>
<artifactId>
com-spacetech-service-xxl-job-springboot-bak
</artifactId>
<packaging>
jar
</packaging>
<name>
${project.artifactId}
</name>
<description>
Example executor project for spring boot.
</description>
<url>
http://www.xuxueli.com/
</url>
<properties>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<!-- Import dependency management from Spring Boot (依赖管理:继承一些默认的依赖,工程需要依赖的jar包的管理,申明其他dependency的时候就不需要version) -->
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-parent
</artifactId>
<version>
${spring-boot.version}
</version>
<type>
pom
</type>
<scope>
import
</scope>
</dependency>
<!-- jetty -->
<dependency>
<groupId>
org.eclipse.jetty
</groupId>
<artifactId>
jetty-server
</artifactId>
<version>
${jetty-server.version}
</version>
</dependency>
<dependency>
<groupId>
org.eclipse.jetty
</groupId>
<artifactId>
jetty-util
</artifactId>
<version>
${jetty-server.version}
</version>
</dependency>
<dependency>
<groupId>
org.eclipse.jetty
</groupId>
<artifactId>
jetty-http
</artifactId>
<version>
${jetty-server.version}
</version>
</dependency>
<dependency>
<groupId>
org.eclipse.jetty
</groupId>
<artifactId>
jetty-io
</artifactId>
<version>
${jetty-server.version}
</version>
</dependency>
<dependency>
<groupId>
org.eclipse.jetty
</groupId>
<artifactId>
jetty-client
</artifactId>
<version>
${jetty-server.version}
</version>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<!-- spring-boot-starter-web (spring-webmvc + tomcat) -->
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-web
</artifactId>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-test
</artifactId>
<scope>
test
</scope>
</dependency>
<!-- xxl-job-core -->
<dependency>
<groupId>
com.xuxueli
</groupId>
<artifactId>
xxl-job-core
</artifactId>
<version>
${project.parent.version}
</version>
</dependency>
<!-- dubbo -->
<dependency>
<groupId>
com.alibaba
</groupId>
<artifactId>
dubbo
</artifactId>
<version>
2.8.4
</version>
</dependency>
<!-- 公用的服务接口 -->
<dependency>
<groupId>
com.spacetech.gateway
</groupId>
<artifactId>
gateway
</artifactId>
<version>
2.98-SNAPSHOT
</version>
</dependency>
<dependency>
<groupId>
org.javassist
</groupId>
<artifactId>
javassist
</artifactId>
<version>
3.18.1-GA
</version>
<!--$NO-MVN-MAN-VER$-->
</dependency>
<dependency>
<groupId>
com.101tec
</groupId>
<artifactId>
zkclient
</artifactId>
<version>
0.9
</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- spring-boot-maven-plugin (提供了直接运行项目的插件:如果是通过parent方式继承spring-boot-starter-parent则不用此插件) -->
<plugin>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-maven-plugin
</artifactId>
<version>
${spring-boot.version}
</version>
<executions>
<execution>
<goals>
<goal>
repackage
</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/XxlJobExecutorApplication.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
import
org.springframework.context.annotation.ComponentScan
;
/**
* @author xuxueli 2018-10-28 00:38:13
*/
@SpringBootApplication
public
class
XxlJobExecutorApplication
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
XxlJobExecutorApplication
.
class
,
args
);
}
}
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/core/config/XxlJobConfig.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
core
.
config
;
import
com.xxl.job.core.executor.impl.XxlJobSpringExecutor
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.ComponentScan
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.context.annotation.ImportResource
;
/**
* xxl-job config
*
* @author xuxueli 2017-04-28
*/
@Configuration
@ComponentScan
(
basePackages
=
"com.xxl.job.executor.service.jobhandler"
)
@ImportResource
(
locations
=
"classpath:spacetech-consumer-apihub.xml"
)
public
class
XxlJobConfig
{
private
Logger
logger
=
LoggerFactory
.
getLogger
(
XxlJobConfig
.
class
);
@Value
(
"${xxl.job.admin.addresses}"
)
private
String
adminAddresses
;
@Value
(
"${xxl.job.executor.appname}"
)
private
String
appName
;
@Value
(
"${xxl.job.executor.ip}"
)
private
String
ip
;
@Value
(
"${xxl.job.executor.port}"
)
private
int
port
;
@Value
(
"${xxl.job.accessToken}"
)
private
String
accessToken
;
@Value
(
"${xxl.job.executor.logpath}"
)
private
String
logPath
;
@Value
(
"${xxl.job.executor.logretentiondays}"
)
private
int
logRetentionDays
;
@Bean
(
initMethod
=
"start"
,
destroyMethod
=
"destroy"
)
public
XxlJobSpringExecutor
xxlJobExecutor
()
{
logger
.
info
(
">>>>>>>>>>> xxl-job config init."
);
XxlJobSpringExecutor
xxlJobSpringExecutor
=
new
XxlJobSpringExecutor
();
xxlJobSpringExecutor
.
setAdminAddresses
(
adminAddresses
);
xxlJobSpringExecutor
.
setAppName
(
appName
);
xxlJobSpringExecutor
.
setIp
(
ip
);
xxlJobSpringExecutor
.
setPort
(
port
);
xxlJobSpringExecutor
.
setAccessToken
(
accessToken
);
xxlJobSpringExecutor
.
setLogPath
(
logPath
);
xxlJobSpringExecutor
.
setLogRetentionDays
(
logRetentionDays
);
return
xxlJobSpringExecutor
;
}
}
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/mvc/controller/IndexController.java
0 → 100644
View file @
a360eaa5
//package com.xxl.job.executor.mvc.controller;
//
//import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
//import org.springframework.stereotype.Controller;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.ResponseBody;
//
//@Controller
//@EnableAutoConfiguration
//public class IndexController {
//
// @RequestMapping("/")
// @ResponseBody
// String index() {
// return "xxl job executor running.";
// }
//
//}
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/service/jobhandler/CommandJobHandler.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
service
.
jobhandler
;
import
com.xxl.job.core.biz.model.ReturnT
;
import
com.xxl.job.core.handler.IJobHandler
;
import
com.xxl.job.core.handler.annotation.JobHandler
;
import
com.xxl.job.core.log.XxlJobLogger
;
import
org.springframework.stereotype.Component
;
import
java.io.BufferedInputStream
;
import
java.io.BufferedReader
;
import
java.io.InputStreamReader
;
/**
* 命令行任务
*
* @author xuxueli 2018-09-16 03:48:34
*/
@JobHandler
(
value
=
"commandJobHandler"
)
@Component
public
class
CommandJobHandler
extends
IJobHandler
{
@Override
public
ReturnT
<
String
>
execute
(
String
param
)
throws
Exception
{
String
command
=
param
;
int
exitValue
=
-
1
;
BufferedReader
bufferedReader
=
null
;
try
{
// command process
Process
process
=
Runtime
.
getRuntime
().
exec
(
command
);
BufferedInputStream
bufferedInputStream
=
new
BufferedInputStream
(
process
.
getInputStream
());
bufferedReader
=
new
BufferedReader
(
new
InputStreamReader
(
bufferedInputStream
));
// command log
String
line
;
while
((
line
=
bufferedReader
.
readLine
())
!=
null
)
{
XxlJobLogger
.
log
(
line
);
}
// command exit
process
.
waitFor
();
exitValue
=
process
.
exitValue
();
}
catch
(
Exception
e
)
{
XxlJobLogger
.
log
(
e
);
}
finally
{
if
(
bufferedReader
!=
null
)
{
bufferedReader
.
close
();
}
}
if
(
exitValue
==
0
)
{
return
IJobHandler
.
SUCCESS
;
}
else
{
return
new
ReturnT
<
String
>(
IJobHandler
.
FAIL
.
getCode
(),
"command exit value("
+
exitValue
+
") is failed"
);
}
}
}
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/service/jobhandler/DemoJobHandler.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
service
.
jobhandler
;
import
com.xxl.job.core.biz.model.ReturnT
;
import
com.xxl.job.core.handler.IJobHandler
;
import
com.xxl.job.core.handler.annotation.JobHandler
;
import
com.xxl.job.core.log.XxlJobLogger
;
import
org.springframework.stereotype.Component
;
import
java.util.concurrent.TimeUnit
;
/**
* 任务Handler示例(Bean模式)
*
* 开发步骤:
* 1、继承"IJobHandler":“com.xxl.job.core.handler.IJobHandler”;
* 2、注册到Spring容器:添加“@Component”注解,被Spring容器扫描为Bean实例;
* 3、注册到执行器工厂:添加“@JobHandler(value="自定义jobhandler名称")”注解,注解value值对应的是调度中心新建任务的JobHandler属性的值。
* 4、执行日志:需要通过 "XxlJobLogger.log" 打印执行日志;
*
* @author xuxueli 2015-12-19 19:43:36
*/
@JobHandler
(
value
=
"demoJobHandler"
)
@Component
public
class
DemoJobHandler
extends
IJobHandler
{
@Override
public
ReturnT
<
String
>
execute
(
String
param
)
throws
Exception
{
XxlJobLogger
.
log
(
"XXL-JOB, Hello World."
);
for
(
int
i
=
0
;
i
<
5
;
i
++)
{
XxlJobLogger
.
log
(
"beat at:"
+
i
);
TimeUnit
.
SECONDS
.
sleep
(
2
);
}
return
SUCCESS
;
}
}
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/service/jobhandler/HttpJobHandler.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
service
.
jobhandler
;
import
com.xxl.job.core.biz.model.ReturnT
;
import
com.xxl.job.core.handler.IJobHandler
;
import
com.xxl.job.core.handler.annotation.JobHandler
;
import
com.xxl.job.core.log.XxlJobLogger
;
import
org.eclipse.jetty.client.HttpClient
;
import
org.eclipse.jetty.client.api.ContentResponse
;
import
org.eclipse.jetty.client.api.Request
;
import
org.eclipse.jetty.http.HttpMethod
;
import
org.eclipse.jetty.http.HttpStatus
;
import
org.springframework.stereotype.Component
;
import
java.util.concurrent.TimeUnit
;
/**
* 跨平台Http任务
*
* @author xuxueli 2018-09-16 03:48:34
*/
@JobHandler
(
value
=
"httpJobHandler"
)
@Component
public
class
HttpJobHandler
extends
IJobHandler
{
@Override
public
ReturnT
<
String
>
execute
(
String
param
)
throws
Exception
{
// valid
if
(
param
==
null
||
param
.
trim
().
length
()==
0
)
{
XxlJobLogger
.
log
(
"URL Empty"
);
return
FAIL
;
}
// httpclient
HttpClient
httpClient
=
null
;
try
{
httpClient
=
new
HttpClient
();
httpClient
.
setFollowRedirects
(
false
);
// Configure HttpClient, for example:
httpClient
.
start
();
// Start HttpClient
// request
Request
request
=
httpClient
.
newRequest
(
param
);
request
.
method
(
HttpMethod
.
GET
);
request
.
timeout
(
5000
,
TimeUnit
.
MILLISECONDS
);
// invoke
ContentResponse
response
=
request
.
send
();
if
(
response
.
getStatus
()
!=
HttpStatus
.
OK_200
)
{
XxlJobLogger
.
log
(
"Http StatusCode({}) Invalid."
,
response
.
getStatus
());
return
FAIL
;
}
String
responseMsg
=
response
.
getContentAsString
();
XxlJobLogger
.
log
(
responseMsg
);
return
SUCCESS
;
}
catch
(
Exception
e
)
{
XxlJobLogger
.
log
(
e
);
return
FAIL
;
}
finally
{
if
(
httpClient
!=
null
)
{
httpClient
.
stop
();
}
}
}
}
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/service/jobhandler/PushKcDateHandler.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
service
.
jobhandler
;
import
java.util.Date
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Component
;
import
com.alibaba.fastjson.JSONObject
;
import
com.spacetech.gateway.BaseDataApiHub
;
import
com.spacetech.gateway.SqxyApiHub
;
import
com.xxl.job.core.biz.model.ReturnT
;
import
com.xxl.job.core.handler.IJobHandler
;
import
com.xxl.job.core.handler.annotation.JobHandler
;
import
com.xxl.job.core.log.XxlJobLogger
;
/**
* 任务Handler示例(Bean模式)
*
* 开发步骤:
* 1、继承"IJobHandler":“com.xxl.job.core.handler.IJobHandler”;
* 2、注册到Spring容器:添加“@Component”注解,被Spring容器扫描为Bean实例;
* 3、注册到执行器工厂:添加“@JobHandler(value="自定义jobhandler名称")”注解,注解value值对应的是调度中心新建任务的JobHandler属性的值。
* 4、执行日志:需要通过 "XxlJobLogger.log" 打印执行日志;
*
* @author xuxueli 2015-12-19 19:43:36
*/
@JobHandler
(
value
=
"pushKcDateHandler"
)
@Component
public
class
PushKcDateHandler
extends
IJobHandler
{
private
static
Long
SQXY_CAMPUSID
=
3418L
;
private
static
Integer
TYPE_TEACHER
=
1
;
private
static
Integer
TYPE_STUDENT
=
2
;
@Autowired
private
SqxyApiHub
sqxyApiHub
;
@Override
public
ReturnT
<
String
>
execute
(
String
param
)
throws
Exception
{
XxlJobLogger
.
log
(
"XXL-JOB, Hello World."
);
String
api
=
"sqxy_kcsj_push"
;
XxlJobLogger
.
log
(
" start - 课程开课提醒接口调用启动;time:"
+
new
Date
());
for
(
Integer
type
=
TYPE_TEACHER
;
type
<=
TYPE_STUDENT
;
type
++)
{
JSONObject
params
=
new
JSONObject
();
params
.
put
(
"campusid"
,
SQXY_CAMPUSID
);
sqxyApiHub
.
callApi
(
api
.
split
(
"_"
)[
1
]
+
"_"
+
api
.
split
(
"_"
)[
2
],
false
,
params
);
}
XxlJobLogger
.
log
(
" end - 课程开课提醒接口调用结束;time:"
+
new
Date
());
return
SUCCESS
;
}
}
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/service/jobhandler/SendReadAlarmJobHandler.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
service
.
jobhandler
;
import
java.util.Date
;
import
org.springframework.stereotype.Component
;
import
com.alibaba.fastjson.JSONObject
;
import
com.xxl.job.core.biz.model.ReturnT
;
import
com.xxl.job.core.handler.IJobHandler
;
import
com.xxl.job.core.handler.annotation.JobHandler
;
import
com.xxl.job.core.log.XxlJobLogger
;
import
com.xxl.job.core.util.ConstantVar
;
import
com.xxl.job.core.util.HttpClientUtil
;
@JobHandler
(
value
=
"SendReadAlarmJobHandler"
)
@Component
public
class
SendReadAlarmJobHandler
extends
IJobHandler
{
@Override
public
ReturnT
<
String
>
execute
(
String
param
)
throws
Exception
{
XxlJobLogger
.
log
(
" start -推送阅读提醒消息接口调用启动;time:"
+
new
Date
());
String
responseMessage
=
HttpClientUtil
.
postTaskJob
(
ConstantVar
.
DEVELOP_URL
,
"taskJob_sendReadAlarm"
);
XxlJobLogger
.
log
(
" responseMessage: "
+
responseMessage
);
JSONObject
retJson
=
JSONObject
.
parseObject
(
responseMessage
).
getJSONObject
(
"ret"
);
if
(
retJson
==
null
||
retJson
.
getString
(
"code"
)
!=
"200"
)
{
return
FAIL
;
}
XxlJobLogger
.
log
(
" end - 推送阅读提醒消息接口调用结束;time:"
+
new
Date
());
return
SUCCESS
;
}
}
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/java/com/xxl/job/executor/service/jobhandler/ShardingJobHandler.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
service
.
jobhandler
;
import
com.xxl.job.core.biz.model.ReturnT
;
import
com.xxl.job.core.handler.IJobHandler
;
import
com.xxl.job.core.handler.annotation.JobHandler
;
import
com.xxl.job.core.log.XxlJobLogger
;
import
com.xxl.job.core.util.ShardingUtil
;
import
org.springframework.stereotype.Service
;
/**
* 分片广播任务
*
* @author xuxueli 2017-07-25 20:56:50
*/
@JobHandler
(
value
=
"shardingJobHandler"
)
@Service
public
class
ShardingJobHandler
extends
IJobHandler
{
@Override
public
ReturnT
<
String
>
execute
(
String
param
)
throws
Exception
{
// 分片参数
ShardingUtil
.
ShardingVO
shardingVO
=
ShardingUtil
.
getShardingVo
();
XxlJobLogger
.
log
(
"分片参数:当前分片序号 = {}, 总分片数 = {}"
,
shardingVO
.
getIndex
(),
shardingVO
.
getTotal
());
// 业务逻辑
for
(
int
i
=
0
;
i
<
shardingVO
.
getTotal
();
i
++)
{
if
(
i
==
shardingVO
.
getIndex
())
{
XxlJobLogger
.
log
(
"第 {} 片, 命中分片开始处理"
,
i
);
}
else
{
XxlJobLogger
.
log
(
"第 {} 片, 忽略"
,
i
);
}
}
return
SUCCESS
;
}
}
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/resources/application.properties
0 → 100644
View file @
a360eaa5
# web port
server.port
=
-1
# log config
logging.config
=
classpath:logback.xml
### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
xxl.job.admin.addresses
=
http://127.0.0.1:8181/xxl-job-admin
### xxl-job executor address
xxl.job.executor.appname
=
com-spacetech-service-xxl-job-springboot-bak
xxl.job.executor.ip
=
xxl.job.executor.port
=
8888
### xxl-job, access token
xxl.job.accessToken
=
### xxl-job log path
xxl.job.executor.logpath
=
/data/applogs/xxl-job/jobhandler
### xxl-job log retention days
xxl.job.executor.logretentiondays
=
-1
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/resources/logback.xml
0 → 100644
View file @
a360eaa5
<?xml version="1.0" encoding="UTF-8"?>
<configuration
debug=
"false"
scan=
"true"
scanPeriod=
"1 seconds"
>
<contextName>
logback
</contextName>
<property
name=
"log.path"
value=
"/mnt/work/dubbo/logs/xxl-job-executor-sample-springboot-bak.log"
/>
<appender
name=
"console"
class=
"ch.qos.logback.core.ConsoleAppender"
>
<encoder>
<pattern>
%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n
</pattern>
</encoder>
</appender>
<appender
name=
"file"
class=
"ch.qos.logback.core.rolling.RollingFileAppender"
>
<file>
${log.path}
</file>
<rollingPolicy
class=
"ch.qos.logback.core.rolling.TimeBasedRollingPolicy"
>
<fileNamePattern>
${log.path}.%d{yyyy-MM-dd}.zip
</fileNamePattern>
</rollingPolicy>
<encoder>
<pattern>
%date %level [%thread] %logger{36} [%file : %line] %msg%n
</pattern>
</encoder>
</appender>
<root
level=
"info"
>
<appender-ref
ref=
"console"
/>
<appender-ref
ref=
"file"
/>
</root>
</configuration>
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/main/resources/spacetech-consumer-apihub.xml
0 → 100644
View file @
a360eaa5
<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns=
"http://www.springframework.org/schema/beans"
xmlns:xsi=
"http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo=
"http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation=
"http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"
>
<dubbo:application
name=
"spacetech-consumer-xxljob"
owner=
"programmer"
organization=
"dubbox"
/>
<dubbo:registry
address=
"zookeeper://10.10.10.190:2182"
/>
<dubbo:consumer
retries=
"0"
check=
"false"
timeout=
"60000"
/>
<dubbo:reference
id=
"appStoreApiHub"
interface=
"com.spacetech.gateway.AppStoreApiHub"
check=
"false"
/>
<dubbo:reference
id=
"electiveApiHub"
interface=
"com.spacetech.gateway.ElectiveApiHub"
check=
"false"
/>
<dubbo:reference
id=
"portalApiHub"
interface=
"com.spacetech.gateway.PortalApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"messageApiHub"
interface=
"com.spacetech.gateway.MessageApiHub"
check=
"false"
/>
<dubbo:reference
id=
"microlectureApiHub"
interface=
"com.spacetech.gateway.MicrolectureApiHub"
check=
"false"
/>
<dubbo:reference
id=
"homeworkApiHub"
interface=
"com.spacetech.gateway.HomeworkApiHub"
check=
"false"
/>
<dubbo:reference
id=
"examScoreApiHub"
interface=
"com.spacetech.gateway.ExamScoreApiHub"
check=
"false"
/>
<dubbo:reference
id=
"oaApiHub"
interface=
"com.spacetech.gateway.OaApiHub"
check=
"false"
/>
<dubbo:reference
id=
"baseDataApiHub"
interface=
"com.spacetech.gateway.BaseDataApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"userApiHub"
interface=
"com.spacetech.gateway.UserApiHub"
check=
"false"
/>
<dubbo:reference
id=
"wechatApiHub"
interface=
"com.spacetech.gateway.WechatApiHub"
check=
"false"
/>
<dubbo:reference
id=
"evaluationApiHub"
interface=
"com.spacetech.gateway.EvaluationApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"parentlicenseApiHub"
interface=
"com.spacetech.gateway.ParentlicenseApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"logApiHub"
interface=
"com.spacetech.gateway.LogApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"tokenApiHub"
interface=
"com.spacetech.gateway.TokenApiHub"
check=
"false"
/>
<dubbo:reference
id=
"faceApiHub"
interface=
"com.spacetech.gateway.FaceApiHub"
check=
"false"
/>
<dubbo:reference
id=
"growthApiHub"
interface=
"com.spacetech.gateway.GrowthApiHub"
check=
"false"
timeout=
"90000"
retries=
"2"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"surveyApiHub"
interface=
"com.spacetech.gateway.SurveyApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"attendanceApiHub"
interface=
"com.spacetech.gateway.AttendanceApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"registrationApiHub"
interface=
"com.spacetech.gateway.RegistrationApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"metaqApiHub"
interface=
"com.spacetech.gateway.MetaqApiHub"
check=
"false"
>
<dubbo:method
name=
"callApiAsync"
async=
"true"
return=
"false"
/>
</dubbo:reference>
<dubbo:reference
id=
"payApiHub"
interface=
"com.spacetech.gateway.PayApiHub"
check=
"false"
/>
<dubbo:reference
id=
"sqxyApiHub"
interface=
"com.spacetech.gateway.SqxyApiHub"
check=
"false"
/>
<dubbo:reference
id=
"qualityApiHub"
interface=
"com.spacetech.gateway.QualityApiHub"
check=
"false"
/>
</beans>
\ No newline at end of file
xxl-job-executor-samples/xxl-job-executor-sample-springboot-bak/src/test/java/com/xxl/job/executor/test/XxlJobExecutorExampleBootApplicationTests.java
0 → 100644
View file @
a360eaa5
package
com
.
xxl
.
job
.
executor
.
test
;
import
org.junit.Test
;
/*@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = Application.class)
@WebAppConfiguration*/
/*@RunWith(SpringRunner.class)
@SpringBootTest(classes = Application.class ,webEnvironment= SpringBootTest.WebEnvironment.DEFINED_PORT)*/
public
class
XxlJobExecutorExampleBootApplicationTests
{
@Test
public
void
test
()
{
}
}
\ No newline at end of file
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment