diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..f88f517
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,296 @@
+
+
+ 4.0.0
+
+ com.casic.yizhuang
+ yizhuang
+ 1.0-SNAPSHOT
+
+ 3.6.3-hw-ei-312005
+ 2.4.0-hw-ei-312005
+ UTF-8
+
+
+
+
+
+ io.netty
+ netty-all
+ 4.1.31.Final
+
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.25
+
+
+
+
+ mysql
+ mysql-connector-java
+ 8.0.16
+
+
+
+
+ com.alibaba
+ fastjson
+ 1.2.58
+
+
+
+
+ org.quartz-scheduler
+ quartz
+ 2.3.0
+
+
+
+
+ net.sf.ucanaccess
+ ucanaccess
+ 4.0.1
+
+
+
+ org.apache.kafka
+ kafka-clients
+ 0.11.0.0
+
+
+
+ org.apache.kafka
+ kafka_2.11
+ ${kafka.version}
+
+
+ org.apache.zookeeper
+ zookeeper
+
+
+ net.sf.jopt-simple
+ jopt-simple
+
+
+ com.huawei.mrs
+ manager-wc2frm
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ com.huawei.mrs
+ om-controller-api
+
+
+ com.101tec
+ zkclient
+
+
+
+
+ org.apache.kafka
+ kafka-clients
+ ${kafka.version}
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ net.jpountz.lz4
+ lz4
+
+
+ com.huawei.mrs
+ manager-hadoop-security-crypter
+
+
+
+
+ org.apache.zookeeper
+ zookeeper
+ ${zookeeper.version}
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ commons-cli
+ commons-cli
+
+
+ log4j
+ log4j
+
+
+ log4j
+ apache-log4j-extras
+
+
+ com.huawei.hadoop.dynalogger
+ dynalogger
+
+
+ io.netty
+ netty
+
+
+ net.java.dev.javacc
+ javacc
+
+
+
+
+ log4j
+ log4j
+ 1.2.17-atlassian-13
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.30
+
+
+ org.apache.kafka
+ kafka-streams-examples
+ ${kafka.version}
+
+
+ org.apache.kafka
+ connect-json
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ org.apache.kafka
+ kafka-streams
+
+
+
+
+ org.apache.kafka
+ kafka-streams
+ ${kafka.version}
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.apache.kafka
+ connect-json
+
+
+
+
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+ huaweicloudsdk
+ https://mirrors.huaweicloud.com/repository/maven/huaweicloudsdk/
+
+ true
+
+
+ true
+
+
+
+ central
+ Maven Central
+ https://repo1.maven.org/maven2/
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 8
+ 8
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 2.3.2
+
+ 1.8
+ 1.8
+
+
+
+
+ org.apache.maven.plugins
+ maven-shade-plugin
+ 1.2.1
+
+
+ package
+
+ shade
+
+
+
+
+ com.casic.yizhuang.Main
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ src/main/resources
+
+ **/*
+
+
+
+
+
+
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..f88f517
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,296 @@
+
+
+ 4.0.0
+
+ com.casic.yizhuang
+ yizhuang
+ 1.0-SNAPSHOT
+
+ 3.6.3-hw-ei-312005
+ 2.4.0-hw-ei-312005
+ UTF-8
+
+
+
+
+
+ io.netty
+ netty-all
+ 4.1.31.Final
+
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.25
+
+
+
+
+ mysql
+ mysql-connector-java
+ 8.0.16
+
+
+
+
+ com.alibaba
+ fastjson
+ 1.2.58
+
+
+
+
+ org.quartz-scheduler
+ quartz
+ 2.3.0
+
+
+
+
+ net.sf.ucanaccess
+ ucanaccess
+ 4.0.1
+
+
+
+ org.apache.kafka
+ kafka-clients
+ 0.11.0.0
+
+
+
+ org.apache.kafka
+ kafka_2.11
+ ${kafka.version}
+
+
+ org.apache.zookeeper
+ zookeeper
+
+
+ net.sf.jopt-simple
+ jopt-simple
+
+
+ com.huawei.mrs
+ manager-wc2frm
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ com.huawei.mrs
+ om-controller-api
+
+
+ com.101tec
+ zkclient
+
+
+
+
+ org.apache.kafka
+ kafka-clients
+ ${kafka.version}
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ net.jpountz.lz4
+ lz4
+
+
+ com.huawei.mrs
+ manager-hadoop-security-crypter
+
+
+
+
+ org.apache.zookeeper
+ zookeeper
+ ${zookeeper.version}
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ commons-cli
+ commons-cli
+
+
+ log4j
+ log4j
+
+
+ log4j
+ apache-log4j-extras
+
+
+ com.huawei.hadoop.dynalogger
+ dynalogger
+
+
+ io.netty
+ netty
+
+
+ net.java.dev.javacc
+ javacc
+
+
+
+
+ log4j
+ log4j
+ 1.2.17-atlassian-13
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.30
+
+
+ org.apache.kafka
+ kafka-streams-examples
+ ${kafka.version}
+
+
+ org.apache.kafka
+ connect-json
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ org.apache.kafka
+ kafka-streams
+
+
+
+
+ org.apache.kafka
+ kafka-streams
+ ${kafka.version}
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.apache.kafka
+ connect-json
+
+
+
+
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+ huaweicloudsdk
+ https://mirrors.huaweicloud.com/repository/maven/huaweicloudsdk/
+
+ true
+
+
+ true
+
+
+
+ central
+ Maven Central
+ https://repo1.maven.org/maven2/
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 8
+ 8
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 2.3.2
+
+ 1.8
+ 1.8
+
+
+
+
+ org.apache.maven.plugins
+ maven-shade-plugin
+ 1.2.1
+
+
+ package
+
+ shade
+
+
+
+
+ com.casic.yizhuang.Main
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ src/main/resources
+
+ **/*
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/META-INF/MANIFEST.MF b/src/META-INF/MANIFEST.MF
new file mode 100644
index 0000000..2692c5f
--- /dev/null
+++ b/src/META-INF/MANIFEST.MF
@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: com.casic.yizhuang.Main
+
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..f88f517
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,296 @@
+
+
+ 4.0.0
+
+ com.casic.yizhuang
+ yizhuang
+ 1.0-SNAPSHOT
+
+ 3.6.3-hw-ei-312005
+ 2.4.0-hw-ei-312005
+ UTF-8
+
+
+
+
+
+ io.netty
+ netty-all
+ 4.1.31.Final
+
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.25
+
+
+
+
+ mysql
+ mysql-connector-java
+ 8.0.16
+
+
+
+
+ com.alibaba
+ fastjson
+ 1.2.58
+
+
+
+
+ org.quartz-scheduler
+ quartz
+ 2.3.0
+
+
+
+
+ net.sf.ucanaccess
+ ucanaccess
+ 4.0.1
+
+
+
+ org.apache.kafka
+ kafka-clients
+ 0.11.0.0
+
+
+
+ org.apache.kafka
+ kafka_2.11
+ ${kafka.version}
+
+
+ org.apache.zookeeper
+ zookeeper
+
+
+ net.sf.jopt-simple
+ jopt-simple
+
+
+ com.huawei.mrs
+ manager-wc2frm
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ com.huawei.mrs
+ om-controller-api
+
+
+ com.101tec
+ zkclient
+
+
+
+
+ org.apache.kafka
+ kafka-clients
+ ${kafka.version}
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ net.jpountz.lz4
+ lz4
+
+
+ com.huawei.mrs
+ manager-hadoop-security-crypter
+
+
+
+
+ org.apache.zookeeper
+ zookeeper
+ ${zookeeper.version}
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ commons-cli
+ commons-cli
+
+
+ log4j
+ log4j
+
+
+ log4j
+ apache-log4j-extras
+
+
+ com.huawei.hadoop.dynalogger
+ dynalogger
+
+
+ io.netty
+ netty
+
+
+ net.java.dev.javacc
+ javacc
+
+
+
+
+ log4j
+ log4j
+ 1.2.17-atlassian-13
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.30
+
+
+ org.apache.kafka
+ kafka-streams-examples
+ ${kafka.version}
+
+
+ org.apache.kafka
+ connect-json
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ org.apache.kafka
+ kafka-streams
+
+
+
+
+ org.apache.kafka
+ kafka-streams
+ ${kafka.version}
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.apache.kafka
+ connect-json
+
+
+
+
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+ huaweicloudsdk
+ https://mirrors.huaweicloud.com/repository/maven/huaweicloudsdk/
+
+ true
+
+
+ true
+
+
+
+ central
+ Maven Central
+ https://repo1.maven.org/maven2/
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 8
+ 8
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 2.3.2
+
+ 1.8
+ 1.8
+
+
+
+
+ org.apache.maven.plugins
+ maven-shade-plugin
+ 1.2.1
+
+
+ package
+
+ shade
+
+
+
+
+ com.casic.yizhuang.Main
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ src/main/resources
+
+ **/*
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/META-INF/MANIFEST.MF b/src/META-INF/MANIFEST.MF
new file mode 100644
index 0000000..2692c5f
--- /dev/null
+++ b/src/META-INF/MANIFEST.MF
@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: com.casic.yizhuang.Main
+
diff --git a/src/main/java/com/casic/yizhuang/Main.java b/src/main/java/com/casic/yizhuang/Main.java
new file mode 100644
index 0000000..408006f
--- /dev/null
+++ b/src/main/java/com/casic/yizhuang/Main.java
@@ -0,0 +1,40 @@
+package com.casic.yizhuang;
+
+import com.casic.yizhuang.core.Server;
+import com.casic.yizhuang.kafka.KafkaClient;
+import com.casic.yizhuang.kafka.Producer;
+import com.casic.yizhuang.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class Main {
+
+ private static final Logger logger = LoggerFactory.getLogger(Main.class);
+ public static void main(String[] args) throws Exception {
+
+ // 初始化日志路径
+ String path=System.getProperty("user.dir");
+ System.setProperty("log.base",path);
+ System.out.println(path);
+
+ logger.info("Start scheduler");
+ try {
+ new Scheduler().start();
+ } catch (SchedulerException e) {
+ e.printStackTrace();
+ }
+
+ System.out.println("Start server");
+ logger.info("Start server");
+ new Thread(new Server()).start();
+
+ System.out.println("Start Kafka Consume");
+ logger.info("Start Kafka Consume");
+
+ Producer.send("怎么回事儿");
+ new KafkaClient().kafkaDataConsumer();
+ }
+
+}
+
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..f88f517
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,296 @@
+
+
+ 4.0.0
+
+ com.casic.yizhuang
+ yizhuang
+ 1.0-SNAPSHOT
+
+ 3.6.3-hw-ei-312005
+ 2.4.0-hw-ei-312005
+ UTF-8
+
+
+
+
+
+ io.netty
+ netty-all
+ 4.1.31.Final
+
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.25
+
+
+
+
+ mysql
+ mysql-connector-java
+ 8.0.16
+
+
+
+
+ com.alibaba
+ fastjson
+ 1.2.58
+
+
+
+
+ org.quartz-scheduler
+ quartz
+ 2.3.0
+
+
+
+
+ net.sf.ucanaccess
+ ucanaccess
+ 4.0.1
+
+
+
+ org.apache.kafka
+ kafka-clients
+ 0.11.0.0
+
+
+
+ org.apache.kafka
+ kafka_2.11
+ ${kafka.version}
+
+
+ org.apache.zookeeper
+ zookeeper
+
+
+ net.sf.jopt-simple
+ jopt-simple
+
+
+ com.huawei.mrs
+ manager-wc2frm
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ com.huawei.mrs
+ om-controller-api
+
+
+ com.101tec
+ zkclient
+
+
+
+
+ org.apache.kafka
+ kafka-clients
+ ${kafka.version}
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ net.jpountz.lz4
+ lz4
+
+
+ com.huawei.mrs
+ manager-hadoop-security-crypter
+
+
+
+
+ org.apache.zookeeper
+ zookeeper
+ ${zookeeper.version}
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ commons-cli
+ commons-cli
+
+
+ log4j
+ log4j
+
+
+ log4j
+ apache-log4j-extras
+
+
+ com.huawei.hadoop.dynalogger
+ dynalogger
+
+
+ io.netty
+ netty
+
+
+ net.java.dev.javacc
+ javacc
+
+
+
+
+ log4j
+ log4j
+ 1.2.17-atlassian-13
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.30
+
+
+ org.apache.kafka
+ kafka-streams-examples
+ ${kafka.version}
+
+
+ org.apache.kafka
+ connect-json
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ org.apache.kafka
+ kafka-streams
+
+
+
+
+ org.apache.kafka
+ kafka-streams
+ ${kafka.version}
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.apache.kafka
+ connect-json
+
+
+
+
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+ huaweicloudsdk
+ https://mirrors.huaweicloud.com/repository/maven/huaweicloudsdk/
+
+ true
+
+
+ true
+
+
+
+ central
+ Maven Central
+ https://repo1.maven.org/maven2/
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 8
+ 8
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 2.3.2
+
+ 1.8
+ 1.8
+
+
+
+
+ org.apache.maven.plugins
+ maven-shade-plugin
+ 1.2.1
+
+
+ package
+
+ shade
+
+
+
+
+ com.casic.yizhuang.Main
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ src/main/resources
+
+ **/*
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/META-INF/MANIFEST.MF b/src/META-INF/MANIFEST.MF
new file mode 100644
index 0000000..2692c5f
--- /dev/null
+++ b/src/META-INF/MANIFEST.MF
@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: com.casic.yizhuang.Main
+
diff --git a/src/main/java/com/casic/yizhuang/Main.java b/src/main/java/com/casic/yizhuang/Main.java
new file mode 100644
index 0000000..408006f
--- /dev/null
+++ b/src/main/java/com/casic/yizhuang/Main.java
@@ -0,0 +1,40 @@
+package com.casic.yizhuang;
+
+import com.casic.yizhuang.core.Server;
+import com.casic.yizhuang.kafka.KafkaClient;
+import com.casic.yizhuang.kafka.Producer;
+import com.casic.yizhuang.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class Main {
+
+ private static final Logger logger = LoggerFactory.getLogger(Main.class);
+ public static void main(String[] args) throws Exception {
+
+ // 初始化日志路径
+ String path=System.getProperty("user.dir");
+ System.setProperty("log.base",path);
+ System.out.println(path);
+
+ logger.info("Start scheduler");
+ try {
+ new Scheduler().start();
+ } catch (SchedulerException e) {
+ e.printStackTrace();
+ }
+
+ System.out.println("Start server");
+ logger.info("Start server");
+ new Thread(new Server()).start();
+
+ System.out.println("Start Kafka Consume");
+ logger.info("Start Kafka Consume");
+
+ Producer.send("怎么回事儿");
+ new KafkaClient().kafkaDataConsumer();
+ }
+
+}
+
diff --git a/src/main/java/com/casic/yizhuang/access/AccessDBUtils.java b/src/main/java/com/casic/yizhuang/access/AccessDBUtils.java
new file mode 100644
index 0000000..f22f604
--- /dev/null
+++ b/src/main/java/com/casic/yizhuang/access/AccessDBUtils.java
@@ -0,0 +1,60 @@
+package com.casic.yizhuang.access;
+
+import java.sql.*;
+
+public class AccessDBUtils {
+
+ private static final String dbURL = "jdbc:ucanaccess://" +
+ //"D:\\WeChat Files\\wxid_jcvfr68ppkhi11\\FileStorage\\File\\2020-07\\dat.mdb";
+ "C:\\Program Files (x86)\\WeatherStation\\Data\\Access\\dat.mdb";
+
+ /*
+ * 加载驱动
+ */
+ static {
+ try {
+ // Step 1: Loading or registering Oracle JDBC driver class
+ Class.forName("net.ucanaccess.jdbc.UcanaccessDriver");
+ } catch (ClassNotFoundException cnfex) {
+ System.out.println("Problem in loading or registering MS Access JDBC driver");
+ cnfex.printStackTrace();
+ }
+ }
+
+ //建立连接
+ public static Connection getConn() {
+ try {
+ // Step 2: Opening database connection
+ // Step 2.A: Create and get connection using DriverManager class
+ return DriverManager.getConnection(dbURL);
+ } catch (Exception e) {
+ System.out.println("AccessDB connection fail");
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ // 关闭资源
+ public static void close(Connection con, PreparedStatement ps, ResultSet rs) {
+ try {
+ if (rs != null)
+ rs.close();// 这里出现异常了,rs关闭了吗?,如果没有怎么解决,ps , con也是一样的。
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ if (ps != null)
+ ps.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if (con != null)
+ try {
+ con.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ }
+}
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..f88f517
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,296 @@
+
+
+ 4.0.0
+
+ com.casic.yizhuang
+ yizhuang
+ 1.0-SNAPSHOT
+
+ 3.6.3-hw-ei-312005
+ 2.4.0-hw-ei-312005
+ UTF-8
+
+
+
+
+
+ io.netty
+ netty-all
+ 4.1.31.Final
+
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.25
+
+
+
+
+ mysql
+ mysql-connector-java
+ 8.0.16
+
+
+
+
+ com.alibaba
+ fastjson
+ 1.2.58
+
+
+
+
+ org.quartz-scheduler
+ quartz
+ 2.3.0
+
+
+
+
+ net.sf.ucanaccess
+ ucanaccess
+ 4.0.1
+
+
+
+ org.apache.kafka
+ kafka-clients
+ 0.11.0.0
+
+
+
+ org.apache.kafka
+ kafka_2.11
+ ${kafka.version}
+
+
+ org.apache.zookeeper
+ zookeeper
+
+
+ net.sf.jopt-simple
+ jopt-simple
+
+
+ com.huawei.mrs
+ manager-wc2frm
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ com.huawei.mrs
+ om-controller-api
+
+
+ com.101tec
+ zkclient
+
+
+
+
+ org.apache.kafka
+ kafka-clients
+ ${kafka.version}
+
+
+ org.xerial.snappy
+ snappy-java
+
+
+ net.jpountz.lz4
+ lz4
+
+
+ com.huawei.mrs
+ manager-hadoop-security-crypter
+
+
+
+
+ org.apache.zookeeper
+ zookeeper
+ ${zookeeper.version}
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ commons-cli
+ commons-cli
+
+
+ log4j
+ log4j
+
+
+ log4j
+ apache-log4j-extras
+
+
+ com.huawei.hadoop.dynalogger
+ dynalogger
+
+
+ io.netty
+ netty
+
+
+ net.java.dev.javacc
+ javacc
+
+
+
+
+ log4j
+ log4j
+ 1.2.17-atlassian-13
+
+
+ org.slf4j
+ slf4j-log4j12
+ 1.7.30
+
+
+ org.apache.kafka
+ kafka-streams-examples
+ ${kafka.version}
+
+
+ org.apache.kafka
+ connect-json
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+ org.apache.kafka
+ kafka-streams
+
+
+
+
+ org.apache.kafka
+ kafka-streams
+ ${kafka.version}
+
+
+ org.apache.kafka
+ kafka-clients
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.apache.kafka
+ connect-json
+
+
+
+
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+ huaweicloudsdk
+ https://mirrors.huaweicloud.com/repository/maven/huaweicloudsdk/
+
+ true
+
+
+ true
+
+
+
+ central
+ Maven Central
+ https://repo1.maven.org/maven2/
+
+
+
+
+
+ bigdata
+ http://wlg1.artifactory.cd-cloud-artifact.tools.huawei.com/artifactory/cbu-maven-public/
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 8
+ 8
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 2.3.2
+
+ 1.8
+ 1.8
+
+
+
+
+ org.apache.maven.plugins
+ maven-shade-plugin
+ 1.2.1
+
+
+ package
+
+ shade
+
+
+
+
+ com.casic.yizhuang.Main
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ src/main/resources
+
+ **/*
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/META-INF/MANIFEST.MF b/src/META-INF/MANIFEST.MF
new file mode 100644
index 0000000..2692c5f
--- /dev/null
+++ b/src/META-INF/MANIFEST.MF
@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: com.casic.yizhuang.Main
+
diff --git a/src/main/java/com/casic/yizhuang/Main.java b/src/main/java/com/casic/yizhuang/Main.java
new file mode 100644
index 0000000..408006f
--- /dev/null
+++ b/src/main/java/com/casic/yizhuang/Main.java
@@ -0,0 +1,40 @@
+package com.casic.yizhuang;
+
+import com.casic.yizhuang.core.Server;
+import com.casic.yizhuang.kafka.KafkaClient;
+import com.casic.yizhuang.kafka.Producer;
+import com.casic.yizhuang.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class Main {
+
+ private static final Logger logger = LoggerFactory.getLogger(Main.class);
+ public static void main(String[] args) throws Exception {
+
+ // 初始化日志路径
+ String path=System.getProperty("user.dir");
+ System.setProperty("log.base",path);
+ System.out.println(path);
+
+ logger.info("Start scheduler");
+ try {
+ new Scheduler().start();
+ } catch (SchedulerException e) {
+ e.printStackTrace();
+ }
+
+ System.out.println("Start server");
+ logger.info("Start server");
+ new Thread(new Server()).start();
+
+ System.out.println("Start Kafka Consume");
+ logger.info("Start Kafka Consume");
+
+ Producer.send("怎么回事儿");
+ new KafkaClient().kafkaDataConsumer();
+ }
+
+}
+
diff --git a/src/main/java/com/casic/yizhuang/access/AccessDBUtils.java b/src/main/java/com/casic/yizhuang/access/AccessDBUtils.java
new file mode 100644
index 0000000..f22f604
--- /dev/null
+++ b/src/main/java/com/casic/yizhuang/access/AccessDBUtils.java
@@ -0,0 +1,60 @@
+package com.casic.yizhuang.access;
+
+import java.sql.*;
+
+public class AccessDBUtils {
+
+ private static final String dbURL = "jdbc:ucanaccess://" +
+ //"D:\\WeChat Files\\wxid_jcvfr68ppkhi11\\FileStorage\\File\\2020-07\\dat.mdb";
+ "C:\\Program Files (x86)\\WeatherStation\\Data\\Access\\dat.mdb";
+
+ /*
+ * 加载驱动
+ */
+ static {
+ try {
+ // Step 1: Loading or registering Oracle JDBC driver class
+ Class.forName("net.ucanaccess.jdbc.UcanaccessDriver");
+ } catch (ClassNotFoundException cnfex) {
+ System.out.println("Problem in loading or registering MS Access JDBC driver");
+ cnfex.printStackTrace();
+ }
+ }
+
+ //建立连接
+ public static Connection getConn() {
+ try {
+ // Step 2: Opening database connection
+ // Step 2.A: Create and get connection using DriverManager class
+ return DriverManager.getConnection(dbURL);
+ } catch (Exception e) {
+ System.out.println("AccessDB connection fail");
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ // 关闭资源
+ public static void close(Connection con, PreparedStatement ps, ResultSet rs) {
+ try {
+ if (rs != null)
+ rs.close();// 这里出现异常了,rs关闭了吗?,如果没有怎么解决,ps , con也是一样的。
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ if (ps != null)
+ ps.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ } finally {
+ if (con != null)
+ try {
+ con.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ }
+}
diff --git a/src/main/java/com/casic/yizhuang/access/DBUtils.java b/src/main/java/com/casic/yizhuang/access/DBUtils.java
new file mode 100644
index 0000000..56c9649
--- /dev/null
+++ b/src/main/java/com/casic/yizhuang/access/DBUtils.java
@@ -0,0 +1,147 @@
+package com.casic.yizhuang.access;
+
+import java.lang.reflect.Field;
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class DBUtils {
+ /**
+ * 增加、删除、改
+ *
+ * @param sql sql
+ * @param params 参数
+ * @return 添加结果
+ */
+ public static boolean update(String sql, List