Skip to content

D
data-adapter
Commit d223e22e by hy
Options

refactor the structure of the project

parent d39055e8
Showing with 163 additions and 52 deletions
dataadapter-console/pom.xml 0 → 100644
<?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.tbyf.dataadapter</groupId>
<artifactId>dataadapter</artifactId>
<version>3.0-SNAPSHOT</version>
</parent>
<artifactId>dataadapter-console</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.tbyf.dataadapter</groupId>
<artifactId>dataadapter-core</artifactId>
<version>3.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
</project>
\ No newline at end of file
dataadapter-console/src/main/resources/application.yml 0 → 100644
spring:
servlet:
multipart:
max-request-size: 100MB
max-file-size: 100MB
pluginsRepoLocation: PluginRepo
zk: localhost:2181
server:
port: 18080
\ No newline at end of file
dataadapter-core/pom.xml
...@@ -17,4 +17,51 @@ ...@@ -17,4 +17,51 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties> </properties>
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>5.2.0</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.10.1</version>
</dependency>
<dependency>
<groupId>org.pf4j</groupId>
<artifactId>pf4j</artifactId>
<version>3.10.0</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>logging-interceptor</artifactId>
</dependency>
</dependencies>
</project> </project>
\ No newline at end of file
dataadapter-worker/pom.xml 0 → 100644
<?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.tbyf.dataadapter</groupId>
<artifactId>dataadapter</artifactId>
<version>3.0-SNAPSHOT</version>
</parent>
<artifactId>dataadapter-worker</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.tbyf.dataadapter</groupId>
<artifactId>dataadapter-core</artifactId>
<version>3.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project>
\ No newline at end of file
dataadapter-worker/src/main/java/com/tbyf/dataadapter/app/WorkerBootstrap.java 0 → 100644
package com.tbyf.dataadapter.app;
import com.tbyf.dataadapter.Worker;
import com.tbyf.dataadapter.WorkerApiRequestHandler;
import com.tbyf.dataadapter.WorkerProperties;
import com.tbyf.dataadapter.api.impl.WorkerBizImpl;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
public class WorkerBootstrap {
public static void main(String[] args) {
Properties props = loadProps();
WorkerProperties wp = new WorkerProperties();
wp.setName(props.getProperty("name"));
wp.setGroup(props.getProperty("group"));
wp.setRegistryAddress(props.getProperty("registryAddress"));
wp.setPort(Integer.parseInt(props.getProperty("port")));
Worker worker = new Worker(wp);
WorkerApiRequestHandler handler = new WorkerApiRequestHandler(new WorkerBizImpl(props.getProperty("pluginsRoot"), props.getProperty("pluginRepositoryUrl")));
worker.setRequestHandler(handler);
worker.start();
}
private static Properties loadProps() {
ClassLoader cld = WorkerBootstrap.class.getClassLoader();
Properties props = new Properties();
try (InputStream is = cld.getResourceAsStream("worker.conf")) {
props.load(is);
} catch (IOException e) {
}
return props;
}
}
dataadapter-worker/src/main/resources/worker.conf 0 → 100644
name=w008
group=biz02
registryAddress=127.0.0.1:2181
port=8083
pluginsRoot=plugin01
pluginRepositoryUrl=http://localhost:8082/plugin/download
pom.xml
...@@ -10,6 +10,8 @@ ...@@ -10,6 +10,8 @@
<packaging>pom</packaging> <packaging>pom</packaging>
<modules> <modules>
<module>dataadapter-core</module> <module>dataadapter-core</module>
<module>dataadapter-console</module>
<module>dataadapter-worker</module>
</modules> </modules>
<properties> <properties>
...@@ -30,55 +32,4 @@ ...@@ -30,55 +32,4 @@
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>5.2.0</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.10.1</version>
</dependency>
<dependency>
<groupId>org.pf4j</groupId>
<artifactId>pf4j</artifactId>
<version>3.10.0</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>logging-interceptor</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
</project> </project>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment