Browse code 亦庄雨量流量接收，大数据平台kafka接收 master
0 parent commit 463d04af4a3839a6913246ab07d59822512effef chaizhuang authored on 27 Mar 2023

Showing 46 changed files

• pom.xml
• src/META-INF/MANIFEST.MF
• src/main/java/com/casic/yizhuang/Main.java
• src/main/java/com/casic/yizhuang/access/AccessDBUtils.java
• src/main/java/com/casic/yizhuang/access/DBUtils.java
• src/main/java/com/casic/yizhuang/core/Decoder.java
• src/main/java/com/casic/yizhuang/core/Server.java
• src/main/java/com/casic/yizhuang/core/ServerHandler.java
• src/main/java/com/casic/yizhuang/json/BigDataMessage.java
• src/main/java/com/casic/yizhuang/json/FlowmeterMessage.java
• src/main/java/com/casic/yizhuang/json/MBody.java
• src/main/java/com/casic/yizhuang/json/Message.java
• src/main/java/com/casic/yizhuang/json/Status.java
• src/main/java/com/casic/yizhuang/json/device/Locator.java
• src/main/java/com/casic/yizhuang/json/device/TempHumi.java
• src/main/java/com/casic/yizhuang/json/device/WasteGas.java
• src/main/java/com/casic/yizhuang/json/device/Well.java
• src/main/java/com/casic/yizhuang/kafka/Consumer.java
• src/main/java/com/casic/yizhuang/kafka/KafkaClient.java
• src/main/java/com/casic/yizhuang/kafka/KafkaProperties.java
• src/main/java/com/casic/yizhuang/kafka/Producer.java
• src/main/java/com/casic/yizhuang/kafka/SimplePartitioner.java
• src/main/java/com/casic/yizhuang/model/Flowmeter.java
• src/main/java/com/casic/yizhuang/model/Hyetometer.java
• src/main/java/com/casic/yizhuang/model/StandardData.java
• src/main/java/com/casic/yizhuang/model/StandardDataUtils.java
• src/main/java/com/casic/yizhuang/model/WellInfo.java
• src/main/java/com/casic/yizhuang/mysql/DAO.java
• src/main/java/com/casic/yizhuang/mysql/DBUtil.java
• src/main/java/com/casic/yizhuang/netty/Client.java
• src/main/java/com/casic/yizhuang/netty/ClientHandler.java
• src/main/java/com/casic/yizhuang/netty/Clientinitializer.java
• src/main/java/com/casic/yizhuang/quartz/ReadAccessJob.java
• src/main/java/com/casic/yizhuang/quartz/Scheduler.java
• src/main/java/com/casic/yizhuang/util/Common.java
• src/main/java/com/casic/yizhuang/util/KafkaUtils.java
• src/main/java/com/casic/yizhuang/util/LoginUtil.java
• src/main/resources/77042.jaas.conf
• src/main/resources/META-INF/MANIFEST.MF
• src/main/resources/consumer.properties
• src/main/resources/jdbc.properties
• src/main/resources/kafkaSecurityMode
• src/main/resources/krb5.conf
• src/main/resources/log4j.properties
• src/main/resources/producer.properties
• src/main/resources/user.keytab

Ignore Space Show notes View pom.xml 0 → 100644

Ignore Space Show notes View src/META-INF/MANIFEST.MF 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/Main.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/access/AccessDBUtils.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/access/DBUtils.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/core/Decoder.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/core/Server.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/core/ServerHandler.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/BigDataMessage.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/FlowmeterMessage.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/MBody.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/Message.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/Status.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/device/Locator.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/device/TempHumi.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/device/WasteGas.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/json/device/Well.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/kafka/Consumer.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/kafka/KafkaClient.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/kafka/KafkaProperties.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/kafka/Producer.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/kafka/SimplePartitioner.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/model/Flowmeter.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/model/Hyetometer.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/model/StandardData.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/model/StandardDataUtils.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/model/WellInfo.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/mysql/DAO.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/mysql/DBUtil.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/netty/Client.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/netty/ClientHandler.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/netty/Clientinitializer.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/quartz/ReadAccessJob.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/quartz/Scheduler.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/util/Common.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/util/KafkaUtils.java 0 → 100644

Ignore Space Show notes View src/main/java/com/casic/yizhuang/util/LoginUtil.java 0 → 100644

Ignore Space Show notes View src/main/resources/77042.jaas.conf 0 → 100644

Ignore Space Show notes View src/main/resources/META-INF/MANIFEST.MF 0 → 100644

Ignore Space Show notes View src/main/resources/consumer.properties 0 → 100644

Ignore Space Show notes View src/main/resources/jdbc.properties 0 → 100644

Ignore Space Show notes View src/main/resources/kafkaSecurityMode 0 → 100644

Ignore Space Show notes View src/main/resources/krb5.conf 0 → 100644

Ignore Space Show notes View src/main/resources/log4j.properties 0 → 100644

Ignore Space Show notes View src/main/resources/producer.properties 0 → 100644

Ignore Space Show notes View src/main/resources/user.keytab 0 → 100644
Not supported

Show line notes below