Skip to content

Commit efdeb2b

Browse files
committed
Merge pull request !92 from 胡贵/develop
2 parents 9cb8c07 + 66073a5 commit efdeb2b

File tree

868 files changed

+4597
-4604
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

868 files changed

+4597
-4604
lines changed

README.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -157,17 +157,17 @@ Response response = jobClient.submitJob(job);
157157

158158
###Spring XML方式启动
159159
```java
160-
<bean id="jobClient" class="com.lts.spring.JobClientFactoryBean">
160+
<bean id="jobClient" class="com.github.ltsopensource.spring.JobClientFactoryBean">
161161
<property name="clusterName" value="test_cluster"/>
162162
<property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
163163
<property name="nodeGroup" value="test_jobClient"/>
164164
<property name="masterChangeListeners">
165165
<list>
166-
<bean class="com.lts.example.support.MasterChangeListenerImpl"/>
166+
<bean class="com.github.ltsopensource.example.support.MasterChangeListenerImpl"/>
167167
</list>
168168
</property>
169169
<property name="jobFinishedHandler">
170-
<bean class="com.lts.example.support.JobFinishedHandlerImpl"/>
170+
<bean class="com.github.ltsopensource.example.support.JobFinishedHandlerImpl"/>
171171
</property>
172172
<property name="configs">
173173
<props>
@@ -231,16 +231,16 @@ taskTracker.start();
231231
```
232232
###Spring XML方式启动
233233
```java
234-
<bean id="taskTracker" class="com.lts.spring.TaskTrackerAnnotationFactoryBean" init-method="start">
235-
<property name="jobRunnerClass" value="com.lts.example.support.MyJobRunner"/>
234+
<bean id="taskTracker" class="com.github.ltsopensource.spring.TaskTrackerAnnotationFactoryBean" init-method="start">
235+
<property name="jobRunnerClass" value="com.github.ltsopensource.example.support.MyJobRunner"/>
236236
<property name="bizLoggerLevel" value="INFO"/>
237237
<property name="clusterName" value="test_cluster"/>
238238
<property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
239239
<property name="nodeGroup" value="test_trade_TaskTracker"/>
240240
<property name="workThreads" value="20"/>
241241
<property name="masterChangeListeners">
242242
<list>
243-
<bean class="com.lts.example.support.MasterChangeListenerImpl"/>
243+
<bean class="com.github.ltsopensource.example.support.MasterChangeListenerImpl"/>
244244
</list>
245245
</property>
246246
<property name="configs">
@@ -352,7 +352,7 @@ class JobRunnerB implements JobRunner {
352352
}
353353
```
354354
##TaskTracker的JobRunner测试
355-
一般在编写TaskTracker的时候,只需要测试JobRunner的实现逻辑是否正确,又不想启动LTS进行远程测试。为了方便测试,LTS提供了JobRunner的快捷测试方法。自己的测试类集成`com.lts.tasktracker.runner.JobRunnerTester`即可,并实现`initContext``newJobRunner`方法即可。如`lts-example`中的例子:
355+
一般在编写TaskTracker的时候,只需要测试JobRunner的实现逻辑是否正确,又不想启动LTS进行远程测试。为了方便测试,LTS提供了JobRunner的快捷测试方法。自己的测试类集成`com.github.ltsopensource.tasktracker.runner.JobRunnerTester`即可,并实现`initContext``newJobRunner`方法即可。如`lts-example`中的例子:
356356

357357
```java
358358
public class TestJobRunnerTester extends JobRunnerTester {
@@ -383,7 +383,7 @@ public class TestJobRunnerTester extends JobRunnerTester {
383383
对于Quartz的Cron任务只需要在Spring配置中增加一下代码就可以接入LTS平台
384384

385385
```xml
386-
<bean class="com.lts.spring.quartz.QuartzLTSProxyBean">
386+
<bean class="com.github.ltsopensource.spring.quartz.QuartzLTSProxyBean">
387387
<property name="clusterName" value="test_cluster"/>
388388
<property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
389389
<property name="nodeGroup" value="quartz_test_group"/>
@@ -404,7 +404,7 @@ public class Application {
404404
}
405405
```
406406

407-
剩下的就只是在application.properties中添加相应的配置就行了, 具体见lts-example中的`com.lts.examples.springboot`包下的例子
407+
剩下的就只是在application.properties中添加相应的配置就行了, 具体见lts-example中的`com.github.ltsopensource.examples.springboot`包下的例子
408408

409409

410410
##多网卡选择问题

docs/LTS文档.md

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -148,17 +148,17 @@ Response response = jobClient.submitJob(job);
148148

149149
###Spring XML方式启动
150150
```java
151-
<bean id="jobClient" class="com.lts.spring.JobClientFactoryBean">
151+
<bean id="jobClient" class="com.github.ltsopensource.spring.JobClientFactoryBean">
152152
<property name="clusterName" value="test_cluster"/>
153153
<property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
154154
<property name="nodeGroup" value="test_jobClient"/>
155155
<property name="masterChangeListeners">
156156
<list>
157-
<bean class="com.lts.example.support.MasterChangeListenerImpl"/>
157+
<bean class="com.github.ltsopensource.example.support.MasterChangeListenerImpl"/>
158158
</list>
159159
</property>
160160
<property name="jobFinishedHandler">
161-
<bean class="com.lts.example.support.JobFinishedHandlerImpl"/>
161+
<bean class="com.github.ltsopensource.example.support.JobFinishedHandlerImpl"/>
162162
</property>
163163
<property name="configs">
164164
<props>
@@ -221,16 +221,16 @@ taskTracker.start();
221221
```
222222
###Spring XML方式启动
223223
```java
224-
<bean id="taskTracker" class="com.lts.spring.TaskTrackerAnnotationFactoryBean" init-method="start">
225-
<property name="jobRunnerClass" value="com.lts.example.support.MyJobRunner"/>
224+
<bean id="taskTracker" class="com.github.ltsopensource.spring.TaskTrackerAnnotationFactoryBean" init-method="start">
225+
<property name="jobRunnerClass" value="com.github.ltsopensource.example.support.MyJobRunner"/>
226226
<property name="bizLoggerLevel" value="INFO"/>
227227
<property name="clusterName" value="test_cluster"/>
228228
<property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
229229
<property name="nodeGroup" value="test_trade_TaskTracker"/>
230230
<property name="workThreads" value="20"/>
231231
<property name="masterChangeListeners">
232232
<list>
233-
<bean class="com.lts.example.support.MasterChangeListenerImpl"/>
233+
<bean class="com.github.ltsopensource.example.support.MasterChangeListenerImpl"/>
234234
</list>
235235
</property>
236236
<property name="configs">
@@ -340,7 +340,7 @@ class JobRunnerB implements JobRunner {
340340
###LTS-Logger扩展
341341
1. 引入`lts-core-{version}.jar`
342342
2. 实现`JobLogger``JobLoggerFactory`接口
343-
3. 在 resources `META-INF/lts/com.lts.biz.logger.JobLoggerFactory`文件,文件内容为`xxx=com.lts.biz.logger.xxx.XxxJobLoggerFactory`
343+
3. 在 resources `META-INF/lts/com.github.ltsopensource.biz.logger.JobLoggerFactory`文件,文件内容为`xxx=com.github.ltsopensource.biz.logger.xxx.XxxJobLoggerFactory`
344344
4. 使用自己的logger扩展,修改jobtracker参数配置 configs.job.logger=xxx。(如果你自己引入JobTracker jar包的方式的话,使用 `jobtracker.addConfig("job.logger", "xxx"))`
345345

346346
###LTS-Queue扩展

docs/包引入说明.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77

88
```java
99
<dependency>
10-
<groupId>com.lts</groupId>
10+
<groupId>com.github.ltsopensource</groupId>
1111
<artifactId>lts-core</artifactId>
1212
<version>${lts版本号}</version>
1313
</dependency>
@@ -152,7 +152,7 @@ LoggerFactory.setLoggerAdapter("可选值: slf4j, jcl, log4j, jdk"), 不手动
152152

153153
```java
154154
<dependency>
155-
<groupId>com.lts</groupId>
155+
<groupId>com.github.ltsopensource</groupId>
156156
<artifactId>lts-spring</artifactId>
157157
<version>${lts版本号}</version>
158158
</dependency>
@@ -164,7 +164,7 @@ LoggerFactory.setLoggerAdapter("可选值: slf4j, jcl, log4j, jdk"), 不手动
164164

165165
```java
166166
<dependency>
167-
<groupId>com.lts</groupId>
167+
<groupId>com.github.ltsopensource</groupId>
168168
<artifactId>lts-jobtracker</artifactId>
169169
<version>${lts版本号}</version>
170170
</dependency>
@@ -208,7 +208,7 @@ LoggerFactory.setLoggerAdapter("可选值: slf4j, jcl, log4j, jdk"), 不手动
208208

209209
```java
210210
<dependency>
211-
<groupId>com.lts</groupId>
211+
<groupId>com.github.ltsopensource</groupId>
212212
<artifactId>lts-jobclient</artifactId>
213213
<version>${project.version}</version>
214214
</dependency>
@@ -251,7 +251,7 @@ FailStore存储包(四选一)
251251

252252
```java
253253
<dependency>
254-
<groupId>com.lts</groupId>
254+
<groupId>com.github.ltsopensource</groupId>
255255
<artifactId>lts-tasktracker</artifactId>
256256
<version>${project.version}</version>
257257
</dependency>

lts-admin/pom.xml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
55
<parent>
66
<artifactId>lts-parent</artifactId>
7-
<groupId>com.lts</groupId>
7+
<groupId>com.github.ltsopensource</groupId>
88
<version>1.6.7-SNAPSHOT</version>
99
</parent>
1010
<modelVersion>4.0.0</modelVersion>
@@ -30,12 +30,12 @@
3030

3131
<dependencies>
3232
<dependency>
33-
<groupId>com.lts</groupId>
33+
<groupId>com.github.ltsopensource</groupId>
3434
<artifactId>lts-core</artifactId>
3535
<version>${project.version}</version>
3636
</dependency>
3737
<dependency>
38-
<groupId>com.lts</groupId>
38+
<groupId>com.github.ltsopensource</groupId>
3939
<artifactId>lts-monitor</artifactId>
4040
<version>${project.parent.version}</version>
4141
</dependency>

lts-admin/src/main/java/com/lts/admin/access/BackendAccessFactory.java renamed to lts-admin/src/main/java/com/github/ltsopensource/admin/access/BackendAccessFactory.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.lts.admin.access;
1+
package com.github.ltsopensource.admin.access;
22

3-
import com.lts.admin.access.face.*;
4-
import com.lts.core.cluster.Config;
5-
import com.lts.core.spi.SPI;
6-
import com.lts.core.spi.SpiExtensionKey;
3+
import com.github.ltsopensource.admin.access.face.*;
4+
import com.github.ltsopensource.core.cluster.Config;
5+
import com.github.ltsopensource.core.spi.SPI;
6+
import com.github.ltsopensource.core.spi.SpiExtensionKey;
77

88
/**
99
* @author Robert HG ([email protected]) on 3/9/16.

lts-admin/src/main/java/com/lts/admin/access/RshHandler.java renamed to lts-admin/src/main/java/com/github/ltsopensource/admin/access/RshHandler.java

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,11 @@
1-
package com.lts.admin.access;
2-
3-
import com.lts.admin.access.domain.NodeOnOfflineLog;
4-
import com.lts.admin.web.vo.NodeInfo;
5-
import com.lts.core.cluster.Node;
6-
import com.lts.core.cluster.NodeType;
7-
import com.lts.monitor.access.domain.*;
8-
import com.lts.store.jdbc.dbutils.JdbcTypeUtils;
9-
import com.lts.store.jdbc.dbutils.ResultSetHandler;
1+
package com.github.ltsopensource.admin.access;
2+
3+
import com.github.ltsopensource.admin.access.domain.NodeOnOfflineLog;
4+
import com.github.ltsopensource.admin.web.vo.NodeInfo;
5+
import com.github.ltsopensource.core.cluster.Node;
6+
import com.github.ltsopensource.core.cluster.NodeType;
7+
import com.github.ltsopensource.monitor.access.domain.*;
8+
import com.github.ltsopensource.store.jdbc.dbutils.ResultSetHandler;
109

1110
import java.sql.ResultSet;
1211
import java.sql.SQLException;

lts-admin/src/main/java/com/lts/admin/access/domain/NodeOnOfflineLog.java renamed to lts-admin/src/main/java/com/github/ltsopensource/admin/access/domain/NodeOnOfflineLog.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package com.lts.admin.access.domain;
1+
package com.github.ltsopensource.admin.access.domain;
22

3-
import com.lts.core.cluster.NodeType;
3+
import com.github.ltsopensource.core.cluster.NodeType;
44

55
import java.util.Date;
66

@@ -18,7 +18,7 @@ public class NodeOnOfflineLog {
1818

1919
/**
2020
* 下面属性来自
21-
* {@link com.lts.core.cluster.Node}
21+
* {@link com.github.ltsopensource.core.cluster.Node}
2222
*/
2323
private String clusterName;
2424
private String ip;
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package com.github.ltsopensource.admin.access.face;
2+
3+
import com.github.ltsopensource.admin.request.JvmDataReq;
4+
import com.github.ltsopensource.admin.request.MDataPaginationReq;
5+
import com.github.ltsopensource.monitor.access.domain.JVMGCDataPo;
6+
import com.github.ltsopensource.monitor.access.face.JVMGCAccess;
7+
8+
import java.util.List;
9+
10+
/**
11+
* @author Robert HG ([email protected]) on 9/28/15.
12+
*/
13+
public interface BackendJVMGCAccess extends JVMGCAccess {
14+
15+
void delete(JvmDataReq request);
16+
17+
List<JVMGCDataPo> queryAvg(MDataPaginationReq request);
18+
}
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package com.github.ltsopensource.admin.access.face;
2+
3+
import com.github.ltsopensource.admin.request.JvmDataReq;
4+
import com.github.ltsopensource.admin.request.MDataPaginationReq;
5+
import com.github.ltsopensource.monitor.access.domain.JVMMemoryDataPo;
6+
import com.github.ltsopensource.monitor.access.face.JVMMemoryAccess;
7+
8+
import java.util.List;
9+
10+
/**
11+
* @author Robert HG ([email protected]) on 9/28/15.
12+
*/
13+
public interface BackendJVMMemoryAccess extends JVMMemoryAccess{
14+
15+
void delete(JvmDataReq request);
16+
17+
List<JVMMemoryDataPo> queryAvg(MDataPaginationReq request);
18+
}
Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
package com.github.ltsopensource.admin.access.face;
2+
3+
import com.github.ltsopensource.admin.request.JvmDataReq;
4+
import com.github.ltsopensource.admin.request.MDataPaginationReq;
5+
import com.github.ltsopensource.monitor.access.domain.JVMThreadDataPo;
6+
import com.github.ltsopensource.monitor.access.face.JVMThreadAccess;
7+
8+
import java.util.List;
9+
10+
/**
11+
* @author Robert HG ([email protected]) on 9/28/15.
12+
*/
13+
public interface BackendJVMThreadAccess extends JVMThreadAccess {
14+
15+
void delete(JvmDataReq request);
16+
17+
List<JVMThreadDataPo> queryAvg(MDataPaginationReq request);
18+
19+
}

0 commit comments

Comments
 (0)