diff options
| author | wcc <[email protected]> | 2021-02-22 14:39:45 +0800 |
|---|---|---|
| committer | wcc <[email protected]> | 2021-02-22 14:39:45 +0800 |
| commit | 1e0ce60391e4bfa6d71af5499577137f1e4b5635 (patch) | |
| tree | 592efdec22eb86c929ff7327961bbd4ac401644e | |
| parent | f70cc806b7cfa907ccc44e5306f310864ca492eb (diff) | |
2021.2.22
95 files changed, 1450 insertions, 83 deletions
diff --git a/.idea/codeStyles/codeStyleConfig.xml b/.idea/codeStyles/codeStyleConfig.xml new file mode 100644 index 0000000..a55e7a1 --- /dev/null +++ b/.idea/codeStyles/codeStyleConfig.xml @@ -0,0 +1,5 @@ +<component name="ProjectCodeStyleConfiguration"> + <state> + <option name="PREFERRED_PROJECT_CODE_STYLE" value="Default" /> + </state> +</component>
\ No newline at end of file diff --git a/.idea/workspace.xml b/.idea/workspace.xml new file mode 100644 index 0000000..49a092c --- /dev/null +++ b/.idea/workspace.xml @@ -0,0 +1,158 @@ +<?xml version="1.0" encoding="UTF-8"?> +<project version="4"> + <component name="ChangeListManager"> + <list default="true" id="715e28dd-b570-4ce0-b2aa-11c6e9141195" name="Default Changelist" comment=""> + <change afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/hos/DownloadObject.java" afterDir="false" /> + <change afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/hos/UploadObject.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/.idea/xj-log-etl.iml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/xj-log-etl.iml" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/pom.xml" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnHTTPSendBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/conn/ConnHTTPSendBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnIPSendBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/conn/ConnIPSendBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnParseBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/conn/ConnParseBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnSSLSendBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/conn/ConnSSLSendBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnSendBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/conn/ConnSendBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/gk/GkParseBolt.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/bolt/gk/GkParseBolt.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/topology/StreamAggregateTopology.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/topology/StreamAggregateTopology.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/general/CONNAssignment.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/general/CONNAssignment.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/general/GKAssignment.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/general/GKAssignment.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/general/JCAssignment.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/ac/iie/storm/utils/general/JCAssignment.java" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/resources/common_province_coding.properties" beforeDir="false" afterPath="$PROJECT_DIR$/src/resources/common_province_coding.properties" afterDir="false" /> + <change beforePath="$PROJECT_DIR$/src/resources/service_flow_config.properties" beforeDir="false" afterPath="$PROJECT_DIR$/src/resources/service_flow_config.properties" afterDir="false" /> + </list> + <option name="SHOW_DIALOG" value="false" /> + <option name="HIGHLIGHT_CONFLICTS" value="true" /> + <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" /> + <option name="LAST_RESOLUTION" value="IGNORE" /> + </component> + <component name="CodeStyleSettingsInfer"> + <option name="done" value="true" /> + </component> + <component name="FileTemplateManagerImpl"> + <option name="RECENT_TEMPLATES"> + <list> + <option value="Class" /> + </list> + </option> + </component> + <component name="Git.Settings"> + <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" /> + </component> + <component name="ProjectCodeStyleSettingsMigration"> + <option name="version" value="1" /> + </component> + <component name="ProjectId" id="1odVtmsa8GZVB6bL9hetndEJE2g" /> + <component name="ProjectViewState"> + <option name="hideEmptyMiddlePackages" value="true" /> + <option name="showExcludedFiles" value="true" /> + <option name="showLibraryContents" value="true" /> + </component> + <component name="PropertiesComponent"> + <property name="RunOnceActivity.ShowReadmeOnStart" value="true" /> + <property name="last_opened_file_path" value="$PROJECT_DIR$" /> + <property name="dynamic.classpath" value="true" /> + </component> + <component name="RunManager" selected="Application.StreamAggregateTopology"> + <configuration name="DownloadObject" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true"> + <option name="MAIN_CLASS_NAME" value="cn.ac.iie.storm.utils.hos.DownloadObject" /> + <module name="xj-log-etl" /> + <extension name="coverage"> + <pattern> + <option name="PATTERN" value="cn.ac.iie.storm.utils.hos.*" /> + <option name="ENABLED" value="true" /> + </pattern> + </extension> + <method v="2"> + <option name="Make" enabled="true" /> + </method> + </configuration> + <configuration name="StreamAggregateTopology" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true"> + <option name="MAIN_CLASS_NAME" value="cn.ac.iie.storm.topology.StreamAggregateTopology" /> + <module name="xj-log-etl" /> + <extension name="coverage"> + <pattern> + <option name="PATTERN" value="cn.ac.iie.storm.topology.*" /> + <option name="ENABLED" value="true" /> + </pattern> + </extension> + <method v="2"> + <option name="Make" enabled="true" /> + </method> + </configuration> + <configuration name="UploadObject" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true"> + <option name="MAIN_CLASS_NAME" value="cn.ac.iie.storm.utils.hos.UploadObject" /> + <module name="xj-log-etl" /> + <extension name="coverage"> + <pattern> + <option name="PATTERN" value="cn.ac.iie.storm.utils.hos.*" /> + <option name="ENABLED" value="true" /> + </pattern> + </extension> + <method v="2"> + <option name="Make" enabled="true" /> + </method> + </configuration> + <recent_temporary> + <list> + <item itemvalue="Application.StreamAggregateTopology" /> + <item itemvalue="Application.UploadObject" /> + <item itemvalue="Application.DownloadObject" /> + </list> + </recent_temporary> + </component> + <component name="ServiceViewManager"> + <option name="viewStates"> + <list> + <serviceView> + <treeState> + <expand /> + <select /> + </treeState> + </serviceView> + </list> + </option> + </component> + <component name="SvnConfiguration"> + <configuration /> + </component> + <component name="TaskManager"> + <task active="true" id="Default" summary="Default task"> + <changelist id="715e28dd-b570-4ce0-b2aa-11c6e9141195" name="Default Changelist" comment="" /> + <created>1613616671567</created> + <option name="number" value="Default" /> + <option name="presentableId" value="Default" /> + <updated>1613616671567</updated> + </task> + <servers /> + </component> + <component name="WindowStateProjectService"> + <state x="1010" y="454" key="#com.intellij.codeInsight.editorActions.RestoreReferencesDialog" timestamp="1613628525495"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state x="1010" y="454" key="#com.intellij.codeInsight.editorActions.RestoreReferencesDialog/[email protected]" timestamp="1613628525495" /> + <state width="2224" height="335" key="GridCell.Tab.0.bottom" timestamp="1613812252833"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state width="2224" height="335" key="GridCell.Tab.0.bottom/[email protected]" timestamp="1613812252833" /> + <state width="2224" height="335" key="GridCell.Tab.0.center" timestamp="1613812252833"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state width="2224" height="335" key="GridCell.Tab.0.center/[email protected]" timestamp="1613812252833" /> + <state width="2224" height="335" key="GridCell.Tab.0.left" timestamp="1613812252833"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state width="2224" height="335" key="GridCell.Tab.0.left/[email protected]" timestamp="1613812252833" /> + <state width="2224" height="335" key="GridCell.Tab.0.right" timestamp="1613812252833"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state width="2224" height="335" key="GridCell.Tab.0.right/[email protected]" timestamp="1613812252833" /> + <state x="960" y="523" key="com.intellij.ide.util.TipDialog" timestamp="1613972172271"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state x="960" y="523" key="com.intellij.ide.util.TipDialog/[email protected]" timestamp="1613972172271" /> + <state x="654" y="394" key="new project wizard" timestamp="1613635538509"> + <screen x="0" y="0" width="2560" height="1400" /> + </state> + <state x="654" y="394" key="new project wizard/[email protected]" timestamp="1613635538509" /> + </component> +</project>
\ No newline at end of file diff --git a/.idea/xj-log-etl.iml b/.idea/xj-log-etl.iml index 6014b6f..43fbf60 100644 --- a/.idea/xj-log-etl.iml +++ b/.idea/xj-log-etl.iml @@ -42,19 +42,19 @@ <orderEntry type="library" name="Maven: com.yammer.metrics:metrics-core:2.2.0" level="project" /> <orderEntry type="library" name="Maven: org.scala-lang:scala-library:2.11.11" level="project" /> <orderEntry type="library" name="Maven: com.101tec:zkclient:0.10" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.storm:storm-core:1.0.2" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.esotericsoftware:kryo:3.0.3" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.esotericsoftware:reflectasm:1.10.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.ow2.asm:asm:5.0.3" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.esotericsoftware:minlog:1.3.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.objenesis:objenesis:2.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.clojure:clojure:1.7.0" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: com.lmax:disruptor:3.3.2" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.logging.log4j:log4j-api:2.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.logging.log4j:log4j-core:2.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.apache.logging.log4j:log4j-slf4j-impl:2.1" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: org.slf4j:log4j-over-slf4j:1.6.6" level="project" /> - <orderEntry type="library" scope="PROVIDED" name="Maven: javax.servlet:servlet-api:2.5" level="project" /> + <orderEntry type="library" name="Maven: org.apache.storm:storm-core:1.0.2" level="project" /> + <orderEntry type="library" name="Maven: com.esotericsoftware:kryo:3.0.3" level="project" /> + <orderEntry type="library" name="Maven: com.esotericsoftware:reflectasm:1.10.1" level="project" /> + <orderEntry type="library" name="Maven: org.ow2.asm:asm:5.0.3" level="project" /> + <orderEntry type="library" name="Maven: com.esotericsoftware:minlog:1.3.0" level="project" /> + <orderEntry type="library" name="Maven: org.objenesis:objenesis:2.1" level="project" /> + <orderEntry type="library" name="Maven: org.clojure:clojure:1.7.0" level="project" /> + <orderEntry type="library" name="Maven: com.lmax:disruptor:3.3.2" level="project" /> + <orderEntry type="library" name="Maven: org.apache.logging.log4j:log4j-api:2.1" level="project" /> + <orderEntry type="library" name="Maven: org.apache.logging.log4j:log4j-core:2.1" level="project" /> + <orderEntry type="library" name="Maven: org.apache.logging.log4j:log4j-slf4j-impl:2.1" level="project" /> + <orderEntry type="library" name="Maven: org.slf4j:log4j-over-slf4j:1.6.6" level="project" /> + <orderEntry type="library" name="Maven: javax.servlet:servlet-api:2.5" level="project" /> <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.7" level="project" /> <orderEntry type="library" name="Maven: org.apache.storm:storm-kafka:1.0.2" level="project" /> <orderEntry type="library" name="Maven: org.apache.curator:curator-framework:2.10.0" level="project" /> @@ -172,7 +172,7 @@ <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>${storm.version}</version> - <scope>provided</scope> +<!-- <scope>provided</scope>--> </dependency> <dependency> diff --git a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnHTTPSendBolt.java b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnHTTPSendBolt.java index 9ce3479..376f509 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnHTTPSendBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnHTTPSendBolt.java @@ -1,4 +1,4 @@ -package cn.ac.iie.storm.bolt.flooding; +package cn.ac.iie.storm.bolt.conn; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; import cn.ac.iie.storm.utils.http.HttpClientService; diff --git a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnIPSendBolt.java b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnIPSendBolt.java index 50e8073..fbff431 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnIPSendBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnIPSendBolt.java @@ -1,4 +1,4 @@ -package cn.ac.iie.storm.bolt.flooding; +package cn.ac.iie.storm.bolt.conn; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; import cn.ac.iie.storm.utils.http.HttpClientService; diff --git a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnParseBolt.java b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnParseBolt.java index f157198..8b03e3c 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnParseBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnParseBolt.java @@ -1,4 +1,4 @@ -package cn.ac.iie.storm.bolt.flooding; +package cn.ac.iie.storm.bolt.conn; import cn.ac.iie.storm.bean.SessionRecordLog; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; @@ -167,7 +167,7 @@ public class ConnParseBolt extends BaseBasicBolt { } } catch (Exception e) { e.printStackTrace(); - logger.error("-----------ip_rzzb数据封装处理异常-----yyy为：------"+e ); + logger.error("-----------ip_rzzb数据封装处理异常-----：------"+e ); loadFail++; } } @@ -175,6 +175,7 @@ public class ConnParseBolt extends BaseBasicBolt { case "HTTP": try { GenericRecord http_rzzb = new GenericData.Record(httpSchema); + setHTTP_RZZB(http_rzzb, sessionRecordLog); HTTPList.add(http_rzzb); count++; diff --git a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnSSLSendBolt.java b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnSSLSendBolt.java index b5fbcc1..8569ade 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnSSLSendBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnSSLSendBolt.java @@ -1,4 +1,4 @@ -package cn.ac.iie.storm.bolt.flooding; +package cn.ac.iie.storm.bolt.conn; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; import cn.ac.iie.storm.utils.http.HttpClientService; diff --git a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnSendBolt.java b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnSendBolt.java index a10c633..1e65abe 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/flooding/ConnSendBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/conn/ConnSendBolt.java @@ -1,4 +1,4 @@ -package cn.ac.iie.storm.bolt.flooding; +package cn.ac.iie.storm.bolt.conn; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; import cn.ac.iie.storm.utils.http.HttpClientService; diff --git a/src/main/java/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.java b/src/main/java/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.java index bb0d84e..d5d4c4c 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.java @@ -1,6 +1,5 @@ package cn.ac.iie.storm.bolt.gk; -import cn.ac.iie.storm.bolt.flooding.ConnIPSendBolt; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; import cn.ac.iie.storm.utils.http.HttpClientService; import org.apache.log4j.Logger; @@ -9,8 +8,6 @@ import org.apache.storm.topology.OutputFieldsDeclarer; import org.apache.storm.topology.base.BaseBasicBolt; import org.apache.storm.tuple.Tuple; -import java.util.Map; - import static cn.ac.iie.storm.utils.http.HttpGetUrl.getPostUrl; public class GKIPSendBolt extends BaseBasicBolt { diff --git a/src/main/java/cn/ac/iie/storm/bolt/gk/GkParseBolt.java b/src/main/java/cn/ac/iie/storm/bolt/gk/GkParseBolt.java index ed6f3e5..54f0a05 100644 --- a/src/main/java/cn/ac/iie/storm/bolt/gk/GkParseBolt.java +++ b/src/main/java/cn/ac/iie/storm/bolt/gk/GkParseBolt.java @@ -3,7 +3,7 @@ package cn.ac.iie.storm.bolt.gk; import cn.ac.iie.storm.bean.SessionRecordLog; import cn.ac.iie.storm.bean.Traffic_Forward; import cn.ac.iie.storm.bean.UserRegion; -import cn.ac.iie.storm.bolt.flooding.ConnParseBolt; +import cn.ac.iie.storm.bolt.conn.ConnParseBolt; import cn.ac.iie.storm.utils.config.StreamAggregateConfig; import com.alibaba.fastjson.JSONObject; import org.apache.avro.Schema; @@ -26,7 +26,6 @@ import java.util.Map; import static cn.ac.iie.storm.utils.general.GKAssignment.*; import static cn.ac.iie.storm.utils.general.TransFormUtils.generate; -import static cn.ac.iie.storm.utils.general.TransFormUtils.getValidLength; public class GkParseBolt extends BaseBasicBolt { private final static Logger logger = Logger.getLogger(ConnParseBolt.class); diff --git a/src/main/java/cn/ac/iie/storm/topology/StreamAggregateTopology.java b/src/main/java/cn/ac/iie/storm/topology/StreamAggregateTopology.java index aa41caa..9d03c19 100644 --- a/src/main/java/cn/ac/iie/storm/topology/StreamAggregateTopology.java +++ b/src/main/java/cn/ac/iie/storm/topology/StreamAggregateTopology.java @@ -1,6 +1,6 @@ package cn.ac.iie.storm.topology; -import cn.ac.iie.storm.bolt.flooding.*; +import cn.ac.iie.storm.bolt.conn.*; import cn.ac.iie.storm.bolt.gk.*; diff --git a/src/main/java/cn/ac/iie/storm/utils/general/CONNAssignment.java b/src/main/java/cn/ac/iie/storm/utils/general/CONNAssignment.java index e957be5..d3d0f21 100644 --- a/src/main/java/cn/ac/iie/storm/utils/general/CONNAssignment.java +++ b/src/main/java/cn/ac/iie/storm/utils/general/CONNAssignment.java @@ -22,15 +22,15 @@ public class CONNAssignment { dns_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); dns_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); dns_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - dns_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + dns_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); dns_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); dns_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); dns_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); dns_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - dns_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 - dns_rzzb.put("DETAIL_ID","02999"); //同上 - dns_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - dns_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 //getYys(sessionRecordLog.getCommon_isp()) + dns_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); + dns_rzzb.put("DETAIL_ID","02999"); + dns_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + dns_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); dns_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //dns特有 dns_rzzb.put("CS_PKTS",sessionRecordLog.getCommon_c2s_pkt_num()); @@ -45,15 +45,15 @@ public class CONNAssignment { IP_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); IP_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); IP_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - IP_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + IP_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); IP_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); IP_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); IP_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); IP_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - IP_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 - IP_rzzb.put("DETAIL_ID","08003"); //同上 - IP_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - IP_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 getYys(sessionRecordLog.getCommon_isp())// + IP_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); + IP_rzzb.put("DETAIL_ID","08003"); + IP_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + IP_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); IP_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //dns特有 IP_rzzb.put("CS_PKTS",sessionRecordLog.getCommon_c2s_pkt_num()); @@ -65,18 +65,17 @@ public class CONNAssignment { public static void setHTTP_RZZB(GenericRecord http_rzzb, SessionRecordLog sessionRecordLog) throws IOException { http_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); - http_rzzb.put("YDY", getDy(sessionRecordLog.getCommon_client_location())); http_rzzb.put("MDDY", getDy(sessionRecordLog.getCommon_server_location())); - http_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + http_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); http_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(), sessionRecordLog.getCommon_client_ip())); http_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(), sessionRecordLog.getCommon_server_ip())); http_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); http_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - http_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 - http_rzzb.put("DETAIL_ID","01999"); //同上 - http_rzzb.put("PROTOCOL", getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - http_rzzb.put("YYS", getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 //getYys(sessionRecordLog.getCommon_isp()) + http_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); + http_rzzb.put("DETAIL_ID","01999"); + http_rzzb.put("PROTOCOL", getProtocol(sessionRecordLog.getCommon_l4_protocol())); + http_rzzb.put("YYS", getYys(sessionRecordLog.getCommon_data_center())); http_rzzb.put("YL1", sessionRecordLog.getCommon_address_type()); //http特有 http_rzzb.put("CS_PKTS",sessionRecordLog.getCommon_c2s_pkt_num()); @@ -95,15 +94,15 @@ public class CONNAssignment { vpn_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); vpn_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); vpn_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - vpn_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + vpn_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); vpn_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); vpn_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); vpn_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); vpn_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - vpn_rzzb.put("PROTO_ID","04"); ///--转化表 还没弄 - vpn_rzzb.put("DETAIL_ID",getVpnDetail_id(sessionRecordLog.getCommon_l7_protocol())); //同上 - vpn_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - vpn_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 getYys(sessionRecordLog.getCommon_isp())// + vpn_rzzb.put("PROTO_ID","04"); + vpn_rzzb.put("DETAIL_ID",getVpnDetail_id(sessionRecordLog.getCommon_l7_protocol())); + vpn_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + vpn_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); vpn_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //vpn特有 vpn_rzzb.put("CS_PKTS",sessionRecordLog.getCommon_c2s_pkt_num()); @@ -116,15 +115,15 @@ public class CONNAssignment { ssl_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); ssl_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); ssl_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - ssl_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + ssl_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); ssl_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); ssl_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); ssl_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); ssl_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - ssl_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 + ssl_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ssl_rzzb.put("DETAIL_ID","07999"); //同上 - ssl_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - ssl_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 getYys(sessionRecordLog.getCommon_isp())// + ssl_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + ssl_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); ssl_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //ssl特有 @@ -140,15 +139,15 @@ public class CONNAssignment { ftp_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); ftp_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); ftp_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - ftp_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + ftp_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); ftp_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); ftp_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); ftp_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); ftp_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - ftp_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 + ftp_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ftp_rzzb.put("DETAIL_ID","06999"); //同上 - ftp_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - ftp_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 //getYys(sessionRecordLog.getCommon_isp()) + ftp_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + ftp_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); ftp_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //ftp特有 @@ -164,15 +163,15 @@ public class CONNAssignment { mail_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); mail_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); mail_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - mail_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + mail_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); mail_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); mail_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); mail_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); mail_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - mail_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 - mail_rzzb.put("DETAIL_ID",getMailDetail_id(sessionRecordLog.getMail_protocol_type())); //同上 - mail_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - mail_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 getYys(sessionRecordLog.getCommon_isp())// + mail_rzzb.put("PROTO_ID",getProto_id(sessionRecordLog.getCommon_schema_type())); + mail_rzzb.put("DETAIL_ID",getMailDetail_id(sessionRecordLog.getMail_protocol_type())); + mail_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + mail_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); mail_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //根据mail_bcc填充 @@ -181,10 +180,10 @@ public class CONNAssignment { mail_rzzb.put("CS_BYTES",sessionRecordLog.getCommon_c2s_byte_num()); mail_rzzb.put("SC_PKTS",sessionRecordLog.getCommon_s2c_pkt_num()); mail_rzzb.put("SC_BYTES",sessionRecordLog.getCommon_s2c_byte_num()); - mail_rzzb.put("MAIL_SENDER",sessionRecordLog.getMail_from()); mail_rzzb.put("MAIL_SENDER",sessionRecordLog.getMail_from()); + mail_rzzb.put("MAIL_RECEVER", getMailRecever(sessionRecordLog.getMail_to())); mail_rzzb.put("RECEVER_NUM", getNum(sessionRecordLog.getMail_to())); @@ -193,8 +192,9 @@ public class CONNAssignment { mail_rzzb.put("CC_NUM", getNum(sessionRecordLog.getMail_cc())); - mail_rzzb.put("CONTENT",sessionRecordLog.getMail_subject()); - mail_rzzb.put("MAIL_RECEVER",sessionRecordLog.getMail_content()); + mail_rzzb.put("MAIL_SUBJECT",sessionRecordLog.getMail_subject()); + + mail_rzzb.put("CONTENT",sessionRecordLog.getMail_content()); mail_rzzb.put("ACCESSORY", getAccessory(sessionRecordLog.getMail_attachment_name())); @@ -203,11 +203,10 @@ public class CONNAssignment { mail_rzzb.put("PWD",sessionRecordLog.getMail_passwd()); mail_rzzb.put("FJFWS",getFjfws(sessionRecordLog.getMail_from())); - mail_rzzb.put("FJFWS_SZD",getSzd(sessionRecordLog.getCommon_client_location())); // //境内境外未知，根据Location填充 + mail_rzzb.put("FJFWS_SZD",getSzd(sessionRecordLog.getCommon_client_location())); mail_rzzb.put("SJFWS",sessionRecordLog.getMail_to()); - mail_rzzb.put("SJFWS_SZD",getSzd(sessionRecordLog.getCommon_server_location()));//境内境外未知，根据Location填充 - + mail_rzzb.put("SJFWS_SZD",getSzd(sessionRecordLog.getCommon_server_location())); mail_rzzb.put("YL2",getNum(sessionRecordLog.getMail_bcc())); mail_rzzb.put("YL4",getMailRecever(sessionRecordLog.getMail_bcc())); @@ -219,15 +218,15 @@ public class CONNAssignment { jstx_rzzb.put("BHSJ",sessionRecordLog.getCommon_recv_time()); jstx_rzzb.put("YDY",getDy(sessionRecordLog.getCommon_client_location())); jstx_rzzb.put("MDDY",getDy(sessionRecordLog.getCommon_server_location())); - jstx_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); //--其实是使用网络序列 + jstx_rzzb.put("QDJIP",getQDJIP(sessionRecordLog.getCommon_server_ip())); jstx_rzzb.put("SIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_client_ip())); jstx_rzzb.put("DIP",getIP(sessionRecordLog.getCommon_address_type(),sessionRecordLog.getCommon_server_ip())); jstx_rzzb.put("SPORT",sessionRecordLog.getCommon_client_port()); jstx_rzzb.put("DPORT",sessionRecordLog.getCommon_server_port()); - jstx_rzzb.put("PROTO_ID", GetMap.getProto_id(sessionRecordLog.getCommon_schema_type())); ///--转化表 还没弄 - jstx_rzzb.put("DETAIL_ID", GetMap.getJstxDetail_id(sessionRecordLog.getCommon_app_id())); //同上 - jstx_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); //-common_l4_protocol其实是这个字段 - jstx_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 getYys(sessionRecordLog.getCommon_isp())// + jstx_rzzb.put("PROTO_ID", GetMap.getProto_id(sessionRecordLog.getCommon_schema_type())); + jstx_rzzb.put("DETAIL_ID", GetMap.getJstxDetail_id(sessionRecordLog.getCommon_app_id())); + jstx_rzzb.put("PROTOCOL",getProtocol(sessionRecordLog.getCommon_l4_protocol())); + jstx_rzzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); jstx_rzzb.put("YL1",sessionRecordLog.getCommon_address_type()); //ftp特有 jstx_rzzb.put("CS_PKTS",sessionRecordLog.getCommon_c2s_pkt_num()); diff --git a/src/main/java/cn/ac/iie/storm/utils/general/GKAssignment.java b/src/main/java/cn/ac/iie/storm/utils/general/GKAssignment.java index bebef89..69e06fc 100644 --- a/src/main/java/cn/ac/iie/storm/utils/general/GKAssignment.java +++ b/src/main/java/cn/ac/iie/storm/utils/general/GKAssignment.java @@ -89,6 +89,7 @@ public class GKAssignment { http_gkzb.put("YYS",getYys(sessionRecordLog.getCommon_data_center())); //-**common_isp这个字段 http_gkzb.put("YL1",sessionRecordLog.getCommon_address_type()); //http特有 + http_gkzb.put("HOST",sessionRecordLog.getHttp_host()); http_gkzb.put("URL",sessionRecordLog.getHttp_url()); http_gkzb.put("USER_AGENT",sessionRecordLog.getHttp_user_agent()); http_gkzb.put("COOKIE",sessionRecordLog.getHttp_cookie()); @@ -150,6 +151,7 @@ public class GKAssignment { //wygjc特有 wygjc_gkzb.put("JC_URL",getFile_Name(sessionRecordLog.getHttp_url())); wygjc_gkzb.put("SSYQ",getSsqy(sessionRecordLog.getHttp_user_agent())); + wygjc_gkzb.put("CONTENT",sessionRecordLog.getHttp_snapshot()); wygjc_gkzb.put("YYZL",sessionRecordLog.getYyzl()); } @@ -182,15 +184,17 @@ public class GKAssignment { mail_gkzb.put("MAIL_SENDER",sessionRecordLog.getMail_from()); - mail_gkzb.put("MAIL_SENDER",sessionRecordLog.getMail_from()); mail_gkzb.put("MAIL_RECEVER",getMailRecever(sessionRecordLog.getMail_to())); + mail_gkzb.put("RECEVER_NUM",getNum(sessionRecordLog.getMail_to())); mail_gkzb.put("MAIL_CC",sessionRecordLog.getMail_cc()); mail_gkzb.put("CC_NUM",getNum(sessionRecordLog.getMail_cc())); - mail_gkzb.put("CONTENT",sessionRecordLog.getMail_subject()); - mail_gkzb.put("MAIL_RECEVER",sessionRecordLog.getMail_content()); + mail_gkzb.put("MAIL_SUBJECT",sessionRecordLog.getMail_subject()); + + mail_gkzb.put("CONTENT",sessionRecordLog.getMail_content()); + mail_gkzb.put("ACCESSORY",getAccessory(sessionRecordLog.getMail_attachment_name())); mail_gkzb.put("FILE_NAME",sessionRecordLog.getMail_attachment_name()); @@ -204,6 +208,10 @@ public class GKAssignment { mail_gkzb.put("XYLX",sessionRecordLog.getMail_protocol_type()); + + mail_gkzb.put("GJZ",sessionRecordLog.getMail_snapshot()); + mail_gkzb.put("YYZL",sessionRecordLog.getYyzl()); + } diff --git a/src/main/java/cn/ac/iie/storm/utils/general/JCAssignment.java b/src/main/java/cn/ac/iie/storm/utils/general/JCAssignment.java index db6b663..7d5ad81 100644 --- a/src/main/java/cn/ac/iie/storm/utils/general/JCAssignment.java +++ b/src/main/java/cn/ac/iie/storm/utils/general/JCAssignment.java @@ -167,6 +167,8 @@ public class JCAssignment { wygjc_jczb.put("JC_URL",getFile_Name(sessionRecordLog.getHttp_url())); wygjc_jczb.put("SSYQ",getSsqy(sessionRecordLog.getHttp_user_agent())); + + wygjc_jczb.put("CONTENT",sessionRecordLog.getHttp_snapshot()); wygjc_jczb.put("YYZL",sessionRecordLog.getYyzl()); } public static void setMAIL_JCZB(GenericRecord mail_jczb, SessionRecordLog sessionRecordLog) throws IOException { @@ -208,20 +210,26 @@ public class JCAssignment { mail_jczb.put("MAIL_CC",sessionRecordLog.getMail_cc()); mail_jczb.put("CC_NUM",getNum(sessionRecordLog.getMail_cc())); - mail_jczb.put("CONTENT",sessionRecordLog.getMail_subject()); - mail_jczb.put("MAIL_RECEVER",sessionRecordLog.getMail_content()); + mail_jczb.put("MAIL_SUBJECT",sessionRecordLog.getMail_subject()); + + mail_jczb.put("CONTENT",sessionRecordLog.getMail_content()); mail_jczb.put("ACCESSORY",getAccessory(sessionRecordLog.getMail_attachment_name())); mail_jczb.put("FILE_NAME",sessionRecordLog.getMail_attachment_name()); mail_jczb.put("FILE_CONTENT",sessionRecordLog.getMail_attachment_content()); mail_jczb.put("PWD",sessionRecordLog.getMail_passwd()); mail_jczb.put("FJFWS",getFjfws(sessionRecordLog.getMail_from())); - mail_jczb.put("FJFWS_SZD",getSzd(sessionRecordLog.getCommon_client_location())); // //境内境外未知，根据Location填充 - mail_jczb.put("SJFWS",sessionRecordLog.getMail_to()); mail_jczb.put("SJFWS_SZD",getSzd(sessionRecordLog.getCommon_server_location()));//境内境外未知，根据Location填充 + mail_jczb.put("XYLX",sessionRecordLog.getMail_protocol_type()); + + mail_jczb.put("GJZ",sessionRecordLog.getMail_snapshot()); + mail_jczb.put("YYZL",sessionRecordLog.getYyzl()); + + + } public static void setFTP_JCZB(GenericRecord ftp_jczb, SessionRecordLog sessionRecordLog) throws IOException { diff --git a/src/main/java/cn/ac/iie/storm/utils/hos/DownloadObject.java b/src/main/java/cn/ac/iie/storm/utils/hos/DownloadObject.java new file mode 100644 index 0000000..b181c3a --- /dev/null +++ b/src/main/java/cn/ac/iie/storm/utils/hos/DownloadObject.java @@ -0,0 +1,61 @@ +package cn.ac.iie.storm.utils.hos; + +import com.amazonaws.auth.AWSStaticCredentialsProvider; +import com.amazonaws.auth.BasicAWSCredentials; +import com.amazonaws.client.builder.AwsClientBuilder; +import com.amazonaws.services.s3.AmazonS3; +import com.amazonaws.services.s3.AmazonS3ClientBuilder; +import com.amazonaws.services.s3.model.ObjectMetadata; +import com.amazonaws.services.s3.model.S3Object; +import com.amazonaws.services.s3.model.S3ObjectInputStream; +import org.apache.avro.io.BinaryEncoder; +import org.apache.avro.io.EncoderFactory; + +import java.io.*; + +public class DownloadObject { + public static void main(String[] args) throws IOException { + String endpoint = "http://192.168.44.12:9098/hos/"; + String accessKey = "default"; + String secretKey = "default"; + + AmazonS3 s3 = AmazonS3ClientBuilder.standard().withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(accessKey, secretKey))) + .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, "us-east-1")).withChunkedEncodingDisabled(true).build(); + + S3Object s3Object = s3.getObject("test218", "ceshi"); + + ObjectMetadata objectMetadata = s3Object.getObjectMetadata(); + + long contentLength = objectMetadata.getContentLength(); + String fileMessage = objectMetadata.getRawMetadataValue("x-hos-meta-message").toString(); + + S3ObjectInputStream objectContent = s3Object.getObjectContent(); + + + + byte[] buffer = null; + + ByteArrayOutputStream bos = new ByteArrayOutputStream(); + byte[] b = new byte[1024]; + int n; + while ((n = objectContent.read(b)) != -1) + { + bos.write(b, 0, n); + } + objectContent.close(); + bos.close(); + buffer = bos.toByteArray(); + s3.shutdown(); + + OutputStream out = new FileOutputStream("src/resources/1.txt"); + ByteArrayInputStream is = new ByteArrayInputStream(buffer); + byte[] buf = new byte[1024]; + int len = 0; + while((len=is.read(buf))!=-1){ + out.write(buf, 0, len); + } + is.close(); + out.close(); + } + +} diff --git a/src/main/java/cn/ac/iie/storm/utils/hos/UploadObject.java b/src/main/java/cn/ac/iie/storm/utils/hos/UploadObject.java new file mode 100644 index 0000000..d094319 --- /dev/null +++ b/src/main/java/cn/ac/iie/storm/utils/hos/UploadObject.java @@ -0,0 +1,38 @@ +package cn.ac.iie.storm.utils.hos; + +import com.amazonaws.auth.AWSStaticCredentialsProvider; +import com.amazonaws.auth.BasicAWSCredentials; +import com.amazonaws.client.builder.AwsClientBuilder; +import com.amazonaws.services.s3.AmazonS3; +import com.amazonaws.services.s3.AmazonS3ClientBuilder; +import com.amazonaws.services.s3.model.ObjectMetadata; + +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.io.InputStream; + +public class UploadObject { + public static void main(String[] args) throws IOException { + + String endpoint = "http://192.168.44.12:9098/hos/"; + String accessKey = "default"; + String secretKey = "default"; + AmazonS3 s3 = AmazonS3ClientBuilder.standard(). + withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(accessKey, secretKey))) + .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, "us-east-1")) + .withChunkedEncodingDisabled(true) + .build(); + + ObjectMetadata metadata = new ObjectMetadata(); + metadata.setContentType("avsc"); + + metadata.setHeader("x-hos-meta-message", "message"); + + InputStream input = new FileInputStream(new File("src/resources/common_app_id_coding.properties")); + s3.putObject("test218", "appid",input,metadata); + + input.close(); // AmazonS3Client + s3.shutdown(); + } +} diff --git a/src/resources/common_province_coding.properties b/src/resources/common_province_coding.properties index caf6869..b33cd7f 100644 --- a/src/resources/common_province_coding.properties +++ b/src/resources/common_province_coding.properties @@ -1,6 +1,6 @@ Beijing=110000 Tianjin=120000 -Hebei=13000 +Hebei=130000 Shanxi=140000 InnerMongoliaAutonomousRegion=150000 Liaoning=210000 diff --git a/src/resources/service_flow_config.properties b/src/resources/service_flow_config.properties index d35254c..ad639f0 100644 --- a/src/resources/service_flow_config.properties +++ b/src/resources/service_flow_config.properties @@ -1,11 +1,11 @@ #\u7BA1\u7406kafka\u5730\u5740 -bootstrap.servers=10.111.200.5:9092,10.111.200.6:9092,10.111.200.7:9092,10.111.200.8:9092,10.111.200.9:9092 +bootstrap.servers=192.168.44.12:9092 #latest/earliest -auto.offset.reset=latest +auto.offset.reset=earliest #\u538B\u7F29\u6A21\u5F0F none or snappy kafka.compression.type=none -topology.logo=gk +topology.logo=conn #kafka broker\u4E0B\u7684\u6CDB\u6536topic\u540D\u79F0 kafka.topic=CONNECTION-RECORD-COMPLETED-LOG @@ -14,7 +14,7 @@ kafka.topic=CONNECTION-RECORD-COMPLETED-LOG kafka.safe.topic=SECURITY-EVENT-COMPLETED-LOG #\u8BFB\u53D6topic,\u5B58\u50A8\u8BE5spout id\u7684\u6D88\u8D39offset\u4FE1\u606F\uFF0C\u53EF\u901A\u8FC7\u8BE5\u62D3\u6251\u547D\u540D;\u5177\u4F53\u5B58\u50A8offset\u7684\u4F4D\u7F6E\uFF0C\u786E\u5B9A\u4E0B\u6B21\u8BFB\u53D6\u4E0D\u91CD\u590D\u7684\u6570\u636E\uFF1B -group.id=test-consumer-group2021020516551 +group.id=test-consumer-group20210205165511 group.safe.id=test-consumer-group20210130111111111211111111 #kafka\u6BCF\u4E00\u6279\u62C9\u591A\u4E45\u7684\u6570\u636E kafka.consumer.poll=1000 diff --git a/target/classes/META-INF/xj-log-etl.kotlin_module b/target/classes/META-INF/xj-log-etl.kotlin_module Binary files differnew file mode 100644 index 0000000..a49347a --- /dev/null +++ b/target/classes/META-INF/xj-log-etl.kotlin_module diff --git a/target/classes/cn/ac/iie/storm/bean/SessionRecordLog.class b/target/classes/cn/ac/iie/storm/bean/SessionRecordLog.class Binary files differnew file mode 100644 index 0000000..fc939a3 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bean/SessionRecordLog.class diff --git a/target/classes/cn/ac/iie/storm/bean/Traffic_Forward.class b/target/classes/cn/ac/iie/storm/bean/Traffic_Forward.class Binary files differnew file mode 100644 index 0000000..865c34a --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bean/Traffic_Forward.class diff --git a/target/classes/cn/ac/iie/storm/bean/UserRegion.class b/target/classes/cn/ac/iie/storm/bean/UserRegion.class Binary files differnew file mode 100644 index 0000000..b1eeb87 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bean/UserRegion.class diff --git a/target/classes/cn/ac/iie/storm/bolt/conn/ConnHTTPSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/conn/ConnHTTPSendBolt.class Binary files differnew file mode 100644 index 0000000..2c4c9a0 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/conn/ConnHTTPSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/conn/ConnIPSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/conn/ConnIPSendBolt.class Binary files differnew file mode 100644 index 0000000..b2baeb1 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/conn/ConnIPSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/conn/ConnParseBolt.class b/target/classes/cn/ac/iie/storm/bolt/conn/ConnParseBolt.class Binary files differnew file mode 100644 index 0000000..0312cea --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/conn/ConnParseBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/conn/ConnSSLSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/conn/ConnSSLSendBolt.class Binary files differnew file mode 100644 index 0000000..fe072ec --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/conn/ConnSSLSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/conn/ConnSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/conn/ConnSendBolt.class Binary files differnew file mode 100644 index 0000000..e365e2e --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/conn/ConnSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/gk/GKHTTPSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/gk/GKHTTPSendBolt.class Binary files differnew file mode 100644 index 0000000..2c53093 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/gk/GKHTTPSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.class Binary files differnew file mode 100644 index 0000000..b140e4b --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/gk/GKIPSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/gk/GKSSLSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/gk/GKSSLSendBolt.class Binary files differnew file mode 100644 index 0000000..059a25f --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/gk/GKSSLSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/gk/GkParseBolt.class b/target/classes/cn/ac/iie/storm/bolt/gk/GkParseBolt.class Binary files differnew file mode 100644 index 0000000..58b42a7 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/gk/GkParseBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/gk/GkSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/gk/GkSendBolt.class Binary files differnew file mode 100644 index 0000000..9c83d67 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/gk/GkSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/index/ConnCountBolt.class b/target/classes/cn/ac/iie/storm/bolt/index/ConnCountBolt.class Binary files differnew file mode 100644 index 0000000..1aa6be7 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/index/ConnCountBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/index/GkCountBolt.class b/target/classes/cn/ac/iie/storm/bolt/index/GkCountBolt.class Binary files differnew file mode 100644 index 0000000..629eb33 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/index/GkCountBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/index/JCCountBolt.class b/target/classes/cn/ac/iie/storm/bolt/index/JCCountBolt.class Binary files differnew file mode 100644 index 0000000..9799d5f --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/index/JCCountBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/jc/JCDNSSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/jc/JCDNSSendBolt.class Binary files differnew file mode 100644 index 0000000..c473a81 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/jc/JCDNSSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/jc/JCHTTPSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/jc/JCHTTPSendBolt.class Binary files differnew file mode 100644 index 0000000..125b9d7 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/jc/JCHTTPSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/jc/JCIPSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/jc/JCIPSendBolt.class Binary files differnew file mode 100644 index 0000000..818423a --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/jc/JCIPSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/jc/JCParseBolt.class b/target/classes/cn/ac/iie/storm/bolt/jc/JCParseBolt.class Binary files differnew file mode 100644 index 0000000..2b51503 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/jc/JCParseBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/jc/JCSSLSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/jc/JCSSLSendBolt.class Binary files differnew file mode 100644 index 0000000..36568d4 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/jc/JCSSLSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/bolt/jc/JCSendBolt.class b/target/classes/cn/ac/iie/storm/bolt/jc/JCSendBolt.class Binary files differnew file mode 100644 index 0000000..9b730ae --- /dev/null +++ b/target/classes/cn/ac/iie/storm/bolt/jc/JCSendBolt.class diff --git a/target/classes/cn/ac/iie/storm/spout/FloodingKafkaSpout.class b/target/classes/cn/ac/iie/storm/spout/FloodingKafkaSpout.class Binary files differnew file mode 100644 index 0000000..07de136 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/spout/FloodingKafkaSpout.class diff --git a/target/classes/cn/ac/iie/storm/spout/SafeKafkaSpout.class b/target/classes/cn/ac/iie/storm/spout/SafeKafkaSpout.class Binary files differnew file mode 100644 index 0000000..33de183 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/spout/SafeKafkaSpout.class diff --git a/target/classes/cn/ac/iie/storm/topology/StormRunner.class b/target/classes/cn/ac/iie/storm/topology/StormRunner.class Binary files differnew file mode 100644 index 0000000..0397459 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/topology/StormRunner.class diff --git a/target/classes/cn/ac/iie/storm/topology/StreamAggregateTopology.class b/target/classes/cn/ac/iie/storm/topology/StreamAggregateTopology.class Binary files differnew file mode 100644 index 0000000..550bfd4 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/topology/StreamAggregateTopology.class diff --git a/target/classes/cn/ac/iie/storm/utils/combine/httpurl/Http_URL_process.class b/target/classes/cn/ac/iie/storm/utils/combine/httpurl/Http_URL_process.class Binary files differnew file mode 100644 index 0000000..2b00991 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/combine/httpurl/Http_URL_process.class diff --git a/target/classes/cn/ac/iie/storm/utils/config/GetMap.class b/target/classes/cn/ac/iie/storm/utils/config/GetMap.class Binary files differnew file mode 100644 index 0000000..0376112 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/config/GetMap.class diff --git a/target/classes/cn/ac/iie/storm/utils/config/StreamAggregateConfig.class b/target/classes/cn/ac/iie/storm/utils/config/StreamAggregateConfig.class Binary files differnew file mode 100644 index 0000000..db0bee1 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/config/StreamAggregateConfig.class diff --git a/target/classes/cn/ac/iie/storm/utils/config/StreamAggregateConfigurations.class b/target/classes/cn/ac/iie/storm/utils/config/StreamAggregateConfigurations.class Binary files differnew file mode 100644 index 0000000..7533d5f --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/config/StreamAggregateConfigurations.class diff --git a/target/classes/cn/ac/iie/storm/utils/general/CONNAssignment.class b/target/classes/cn/ac/iie/storm/utils/general/CONNAssignment.class Binary files differnew file mode 100644 index 0000000..b9add81 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/general/CONNAssignment.class diff --git a/target/classes/cn/ac/iie/storm/utils/general/GKAssignment.class b/target/classes/cn/ac/iie/storm/utils/general/GKAssignment.class Binary files differnew file mode 100644 index 0000000..47821af --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/general/GKAssignment.class diff --git a/target/classes/cn/ac/iie/storm/utils/general/JCAssignment.class b/target/classes/cn/ac/iie/storm/utils/general/JCAssignment.class Binary files differnew file mode 100644 index 0000000..efb4012 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/general/JCAssignment.class diff --git a/target/classes/cn/ac/iie/storm/utils/general/MailTrans.class b/target/classes/cn/ac/iie/storm/utils/general/MailTrans.class Binary files differnew file mode 100644 index 0000000..6fc74dc --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/general/MailTrans.class diff --git a/target/classes/cn/ac/iie/storm/utils/general/TransFormUtils.class b/target/classes/cn/ac/iie/storm/utils/general/TransFormUtils.class Binary files differnew file mode 100644 index 0000000..c6c95b9 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/general/TransFormUtils.class diff --git a/target/classes/cn/ac/iie/storm/utils/hos/DownloadObject.class b/target/classes/cn/ac/iie/storm/utils/hos/DownloadObject.class Binary files differnew file mode 100644 index 0000000..5c23432 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/hos/DownloadObject.class diff --git a/target/classes/cn/ac/iie/storm/utils/hos/UploadObject.class b/target/classes/cn/ac/iie/storm/utils/hos/UploadObject.class Binary files differnew file mode 100644 index 0000000..c316bb3 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/hos/UploadObject.class diff --git a/target/classes/cn/ac/iie/storm/utils/http/HttpClientService.class b/target/classes/cn/ac/iie/storm/utils/http/HttpClientService.class Binary files differnew file mode 100644 index 0000000..2e31934 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/http/HttpClientService.class diff --git a/target/classes/cn/ac/iie/storm/utils/http/HttpConfig.class b/target/classes/cn/ac/iie/storm/utils/http/HttpConfig.class Binary files differnew file mode 100644 index 0000000..c0e40ec --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/http/HttpConfig.class diff --git a/target/classes/cn/ac/iie/storm/utils/http/HttpGetUrl.class b/target/classes/cn/ac/iie/storm/utils/http/HttpGetUrl.class Binary files differnew file mode 100644 index 0000000..b5623f6 --- /dev/null +++ b/target/classes/cn/ac/iie/storm/utils/http/HttpGetUrl.class diff --git a/target/classes/common_app_id_coding.properties b/target/classes/common_app_id_coding.properties new file mode 100644 index 0000000..7aef802 --- /dev/null +++ b/target/classes/common_app_id_coding.properties @@ -0,0 +1 @@ +#common_app_id_conding
HTTP=01999
DNS=02999
WEBMAIL=03001
SMTP=03002
POP3=03003
IMAP=03004
PPTP=04001
L2TP=04002
OpenVPN=04003
IPSec=04004
QQ=05001
BlackLight=05002
钉钉=05003
翼聊=05004
Hangouts=05005
个信=05006
微信电话本=05007
飞聊=05008
环聊=05009
有信电话=05010
友约=05011
遇见=05012
Kik=05013
微爱=05014
Tango=05015
敢聊=05016
微信=05017
易信=05018
旺信=05019
Tumblr=05020
Blued=05021
网聊=05022
快传=05023
唱吧=05024
比邻=05025
千牛=05026
派派=05027
找对象=05028
IM+=05029
微聚=05030
BBM=05031
LOFTER=05032
Weico=05033
米聊=05034
YY语音=05035
Skype=05036
Path=05037
网易泡泡=05038
有你=05039
微乐=05040
GO短信=05041
和通讯录=05042
约爱=05043
无秘=05044
Wicker=05045
约会吧=05046
hike messager=05047
摩擦=05048
探探=05049
陌陌=05050
来往点点虫=05051
百度Hi=05052
ZANK=05053
小恩爱=05054
飞信=05055
ChatON=05056
QT语音=05057
爱聊=05058
nice好赞=05059
朋友印象=05060
Googletalk=05061
友加=05062
Keechat=05063
啪啪啪啪音乐圈=05064
微会=05065
Radicall=05066
槽厂=05067
想恋爱=05068
颜值颜值点评=05069
LinkedIn=05070
Telegram=05071
DiDi=05072
ICQ=05073
Zello=05074
NextDoor=05075
Pinterest=05076
叮咚=05077
床上=05078
Nimbuzz=05079
微人脉=05080
陪陪=05081
微密=05082
Vine=05083
Line=05084
between=05085
facebook=05086
Viber=05087
MeetUP=05088
MeetMe=05089
OkCupidDating=05090
碰碰=05091
Diaspora=05092
咚呱=05093
陪聊=05094
Twitter=05095
Kakao=05096
MSN=05097
Voxer=05098
Airetalk=05099
ooVoo=05100
Mico=05101
Banjo=05102
TextNow=05103
抱抱=05104
多多的鱼=05105
个性=05106
闺蜜圈=05107
Instagram=05108
Whatsapp=05109
Talkbox=05110
ChatOn=05111
Coco=05112
Badoo=05113
Match.com=05114
TextFree=05115
Tapatalk=05116
KC网络电话=05117
爱唱=05118
酷我=05119
荔枝FM=05120
铁血=05121
酷友社区=05122
花田交友=05123
红娘网=05124
知乎=05125
百度贴吧=05126
百合婚恋=05127
珍爱网=05128
猫扑=05129
新浪微博=05130
开心网=05131
天际好好约=05132
天涯社区=05133
人人网=05134
世纪佳缘=05135
We heart it=05136
Avocado=05137
Tinder=05138
Swarm=05139
Snapchat=05140
Dating for everyone=05141
Skout=05142
QQ空间=05143
Couple=05144
Happn=05145
FTP=06999
SSL=07999
IP黑=08001
IP监测=08002
IP日志总表=08003
\ No newline at end of file diff --git a/target/classes/common_app_label_coding.properties b/target/classes/common_app_label_coding.properties new file mode 100644 index 0000000..f89b09f --- /dev/null +++ b/target/classes/common_app_label_coding.properties @@ -0,0 +1 @@ +全部=00
HTTP=01
DNS=02
MAIL=03
VPN=04
JSTX=05
FTP=06
SSL=07
IP=08
\ No newline at end of file diff --git a/target/classes/common_city_coding.properties b/target/classes/common_city_coding.properties new file mode 100644 index 0000000..c93ebd3 --- /dev/null +++ b/target/classes/common_city_coding.properties @@ -0,0 +1,367 @@ +#河北 +Shijiazhuang,HeBei,China=130100 +Tangshan,Hebei,China=130200 +Qinhuangdao,Hebei,China=130300 +Handan,Hebei,China=130400 +Xingtai,Hebei,China=130500 +Baoding,Hebei,China=130600 +Zhangjiakou,Hebei,China=130700 +Chengde,Hebei,China=130800 +Cangzhou,Hebei,China=130900 +Langfang,Hebei,China=131000 +Hengshui,Hebei,China=131100 + +#山西 +Taiyuan,Shanxi,China=140100 +Datong,Shanxi,China=140200 +Yangquan,Shanxi,China=140300 +Changzhi,Shanxi,China=140400 +Jincheng,Shanxi,China=140500 +Shuozhou,Shanxi,China=140600 +Jinzhong,Shanxi,China=140700 +Yuncheng,Shanxi,China=140800 +Xinzhou,Shanxi,China=140900 +Linfen,Shanxi,China=141000 +Lvliang,Shanxi,China=141100 + +#内蒙古 +Other,InnerMongoliaAutonomousRegion,China=150000 +Huhehaote,InnerMongoliaAutonomousRegion,China=150100 +Baotou,InnerMongoliaAutonomousRegion,China=150200 +Wuhai,InnerMongoliaAutonomousRegion,China=150300 +Chifeng,InnerMongoliaAutonomousRegion,China=150400 +Tongliao,InnerMongoliaAutonomousRegion,China=150500 +Eerduosi,InnerMongoliaAutonomousRegion,China=150600 +Hulunbeier,InnerMongoliaAutonomousRegion,China=150700 +Bayannaoer,InnerMongoliaAutonomousRegion,China=150800 +Wulanchabu,InnerMongoliaAutonomousRegion,China=150900 +Xingan,InnerMongoliaAutonomousRegion,China=152200 +Xilinguolei,InnerMongoliaAutonomousRegion,China=152500 +Alashan,InnerMongoliaAutonomousRegion,China=152900 + +#辽宁 +Shenyang,Liaoning,China=210100 +Dalian,Liaoning,China=210200 +Anshan,Liaoning,China=210300 +Funshun,Liaoning,China=210400 +Benxi,Liaoning,China=210500 +Dandong,Liaoning,China=210600 +Jinzhou,Liaoning,China=210700 +Yingkou,Liaoning,China=210800 +Fuxin,Liaoning,China=210900 +LiaoYang,Liaoning,China=211000 +Panjin,Liaoning,China=211100 +Tieling,Liaoning,China=211200 +Chaoyang,Liaoning,China=211300 +Huludao,Liaoning,China=211400 + +#吉林 +Changchun,Jilin,China=220100 +Jilin,Jilin,China=220200 +Siping,Jilin,China=220300 +Liaoyuan,Jilin,China=220400 +Tonghua,Jilin,China=220500 +Baishan,Jilin,China=220600 +Songyuan,Jilin,China=220700 +Baicheng,Jilin,China=220800 + + +#黑龙江 +Ha'erbin,Heilongjiang,China=230100 +Qiqiha'er,Heilongjiang,China=230200 +Jixi,Heilongjiang,China=230300 +Hegang,Heilongjiang,China=230400 +Shuangyashan,Heilongjiang,China=230500 +Daqing,Heilongjiang,China=230600 +Yichun,Heilongjiang,China=230700 +Jiamusi,Heilongjiang,China=230800 +Qitaihe,Heilongjiang,China=230900 +Mudanjiang,Heilongjiang,China=231000 +Heihe,Heilongjiang,China=231100 +Suihua,Heilongjiang,China=231200 + +#江苏省 +Nanjing,Jiangsu,China=320100 +Wuxi,Jiangsu,China=320200 +Xuzhou,Jiangsu,China=320300 +Changzhou,Jiangsu,China=320400 +Suzhou,Jiangsu,China=320500 +Nantong,Jiangsu,China=320600 +Lianyungang,Jiangsu,China=320700 +Huai'an,Jiangsu,China=320800 +Yancheng,Jiangsu,China=320900 +Yangzhou,Jiangsu,China=321000 +Zhenjiang,Jiangsu,China=321100 +Suqian,Jiangsu,China=321300 + + +#浙江省 +Hangzhou,Zhejiang,China=330100 +Ningbo,Zhejiang,China=330200 +Wenzhou,Zhejiang,China=330300 +Jiaxing,Zhejiang,China=330400 +Huzhou,Zhejiang,China=330500 +Shaoxing,Zhejiang,China=330600 +Jinhua,Zhejiang,China=330700 +Quzhou,Zhejiang,China=330800 +Zhoushan,Zhejiang,China=330900 +Taizhou,Zhejiang,China=331000 +Lishui,Zhejiang,China=331100 + +#安徽省 +Hefei,Anhui,China=340100 +Wuhu,Anhui,China=340200 +Bangbu,Anhui,China=340300 +Huainan,Anhui,China=340400 +Ma'anshan,Anhui,China=340500 +Huaibei,Anhui,China=340600 +Tongling,Anhui,China=340700 +Anqing,Anhui,China=340800 +Huangshan,Anhui,China=341000 +Chuzhou,Anhui,China=341100 +Fuyang,Anhui,China=341200 +Suzhou,Anhui,China=341300 +Liu'an,Anhui,China=341500 +Haozhou,Anhui,China=341600 +Chizhou,Anhui,China=341700 +Xuancheng,Anhui,China=341800 + +#福建省 +Fuzhou,Fujian,China=350100 +Xiamen,Fujian,China=350200 +Putian,Fujian,China=350300 +Sanming,Fujian,China=350400 +Quanzhou,Fujian,China=350500 +Zhangzhou,Fujian,China=350600 +Nanping,Fujian,China=350700 +Longyan,Fujian,China=350800 +Ningde,Fujian,China=350900 + +#江西省 +Nanchang,Jiangxi,China=360100 +Jingdezhen,Jiangxi,China=360200 +Pingxiang,Jiangxi,China=360300 +Jiujiang,Jiangxi,China=360400 +Xinyu,Jiangxi,China=360500 +Yingtan,Jiangxi,China=360600 +Ganzhou,Jiangxi,China=360700 +Ji'an,Jiangxi,China=360800 +Yichun,Jiangxi,China=360900 +Fuzhou,Jiangxi,China=361000 +Shang'rao,Jiangxi,China=361100 + +#山东省 +Jinan,Shandong,China=370100 +Qingdao,Shandong,China=370200 +Zibo,Shandong,China=370300 +Zaozhuang,Shandong,China=370400 +Dongying,Shandong,China=370500 +Yantai,Shandong,China=370600 +Weifang,Shandong,China=370700 +Jining,Shandong,China=370800 +Tai'an,Shandong,China=370900 +Weihai,Shandong,China=371000 +RiZhao,Shandong,China=371100 +Laiwu,Shandong,China=371200 +Linyi,Shandong,China=371300 +Dezhou,Shandong,China=371400 +Liaocheng,Shandong,China=371500 +Binzhou,Shandong,China=371600 +Heze,Shandong,China=371700 + +#河南省 +Zhengzhou,Henan,China=410100 +Kaifeng,Henan,China=410200 +Luoyang,Henan,China=410300 +Pingdingshan,Henan,China=410400 +Anyang,Henan,China=410500 +Hebi,Henan,China=410600 +Xinxiang,Henan,China=410700 +Jiaozuo,Henan,China=410800 +Puyang,Henan,China=410900 +Xuchang,Henan,China=411000 +Luohe,Henan,China=411100 +Sanmenxia,Henan,China=411200 +Nanyang,Henan,China=411300 +Shangqiu,Henan,China=411400 +Xinyang,Henan,China=411500 +Zhoukou,Henan,China=411600 +Zhumadian,Henan,China=411700 + +#湖北省 +Wuhan,Hubei,China=420100 +Huangshi,Hubei,China=420200 +Shiyan,Hubei,China=420300 +Yichang,Hubei,China=420500 +Xiangyang,Hubei,China=420600 +Ezhou,Hubei,China=420700 +Xingmen,Hubei,China=420800 +Xiaogan,Hubei,China=420900 +Jingzhou,Hubei,China=420100 +Huanggang,Hubei,China=421100 +Xianning,Hubei,China=421200 +Suizhou,Hubei,China=421300 +Enshi,Hubei,China=422800 + + +#湖南省 +Changsha,Hunan,China=430100 +Zhuzhou,Hunan,China=430200 +Xiangtan,Hunan,China=430300 +Hengyang,Hunan,China=430400 +Shaoyang,Hunan,China=430500 +Yueyang,Hunan,China=430600 +Changde,Hunan,China=430700 +Zhangjiajie,Hunan,China=430800 +Yiyang,Hunan,China=430900 +Chenzhou,Hunan,China=431000 +Yongzhou,Hunan,China=431100 +Huaihua,Hunan,China=431200 +Loudi,Hunan,China=431300 + + +#广东省 +Guangzhou,Guangdong,China=440100 +Shaoguan,Guangdong,China=440200 +Shenzhen,Guangdong,China=440300 +Zhuhai,Guangdong,China=440400 +Shantou,Guangdong,China=440500 +Foshan,Guangdong,China=440600 +Jiangmen,Guangdong,China=440700 +Zhanjiang,Guangdong,China=440800 +Maoming,Guangdong,China=440900 +Zhaoqing,Guangdong,China=441200 +Huizhou,Guangdong,China=441300 +Meizhou,Guangdong,China=441400 +Shanwei,Guangdong,China=441500 +Heyuan,Guangdong,China=441600 +Yangjiang,Guangdong,China=441700 +Qingyuan,Guangdong,China=441800 +Dongguan,Guangdong,China=441900 +Zhongshan,Guangdong,China=442000 +Chaozhou,Guangdong,China=445100 +Jieyang,Guangdong,China=445200 +Yunfu,Guangdong,China=445300 + + +#广西壮族自治区 +Nanning,GuangxiZhuangAutonomousRegion,China=450100 +Liuzhou,GuangxiZhuangAutonomousRegion,China=450200 +Guilin,GuangxiZhuangAutonomousRegion,China=450300 +Wuzhou,GuangxiZhuangAutonomousRegion,China=450400 +Beihai,GuangxiZhuangAutonomousRegion,China=450500 +Fangchenggang,GuangxiZhuangAutonomousRegion,China=450600 +Qinzhou,GuangxiZhuangAutonomousRegion,China=450700 +Guigang,GuangxiZhuangAutonomousRegion,China=450800 +Yulin,GuangxiZhuangAutonomousRegion,China=450900 +Baise,GuangxiZhuangAutonomousRegion,China=451000 +Hezhou,GuangxiZhuangAutonomousRegion,China=451100 +Hechi,GuangxiZhuangAutonomousRegion,China=451200 +Laibin,GuangxiZhuangAutonomousRegion,China=451300 +Chongzuo,GuangxiZhuangAutonomousRegion,China=451400 + + + +#海南省 +Haikou,Hainan,China=460100 +Sanya,Hainan,China=460200 +Sansha,Hainan,China=460300 +Danzhou,Hainan,China=460400 + +#四川 +Chengdou,Sichuan,China=510100 +Zigong,Sichuan,China=510300 +Panzhihua,Sichuan,China=510400 +Luzhou,Sichuan,China=510500 +Deyang,Sichuan,China=510600 +Mianyang,Sichuan,China=510700 +Guangyuan,Sichuan,China=510800 +Suining,Sichuan,China=510900 +Neijiang,Sichuan,China=511000 +Leshan,Sichuan,China=511100 +Nanchong,Sichuan,China=511300 +Meishan,Sichuan,China=511400 +Yibin,Sichuan,China=511500 +Guang'an,Sichuan,China=511600 +Dazhou,Sichuan,China=511700 +Ya'an,Sichuan,China=511800 +Bazhong,Sichuan,China=511900 +Ziyang,Sichuan,China=512000 + + +#贵州省 +Guiyang,Guizhou,China=520100 +Liupanshui,Sichuan,China=520200 +Zunyi,Sichuan,China=520300 +Anshun,Sichuan,China=520400 +Bijie,Sichuan,China=520500 +Tongren,Sichuan,China=520600 + +#云南省 +Kunming,Yunnan,China=530100 +Qujing,Yunnan,China=530300 +Yuxi,Yunnan,China=530400 +Baoshan,Yunnan,China=530500 +Zhaotong,Yunnan,China=530600 +Lijiang,Yunnan,China=530700 +Pu'er,Yunnan,China=530800 +Lincang,Yunnan,China=530900 +XishuangbannaDaiAutonomousPrefecture,Yunnan,China=532800 +Dali,Yunnan,China=532900 + + +#陕西省 +xi'an,Shaanxi,China=610100 +Tongchuan,Shaanxi,China=610200 +Baoji,Shaanxi,China=610300 +Xianyang,Shaanxi,China=610400 +Weinan,Shaanxi,China=610500 +Yan'an,Shaanxi,China=610600 +Hanzhong,Shaanxi,China=610700 +Yulin,Shaanxi,China=610800 +Ankang,Shaanxi,China=610900 +Shangluo,Shaanxi,China=611000 + + +#甘肃省 +Lanzhou,Gansu,China=620100 +Jiayuguan,Gansu,China=620200 +Jinchang,Gansu,China=620300 +Baiyin,Gansu,China=620400 +Tianshui,Gansu,China=620500 +Wuwei,Gansu,China=620600 +Zhangye,Gansu,China=620700 +Pingliang,Gansu,China=620800 +Jiuquan,Gansu,China=620900 +Qingyang,Gansu,China=621000 +Dingxi,Gansu,China=621100 +Longnan,Gansu,China=621200 + +#青海省 +Xining,Qinghai,China=630100 +Haidong,Qinghai,China=630200 + + +#宁夏回族自治区 +Yinchuan,NingxiaHuiAutonomousRegion,China=640100 +Zuishan,NingxiaHuiAutonomousRegion,China=640200 +Wuzhong,NingxiaHuiAutonomousRegion,China=640300 +Guyuan,NingxiaHuiAutonomousRegion,China=640400 +Zhongwei,NingxiaHuiAutonomousRegion,China=640500 + + +#台湾 +Taibei,Taiwan,China=710100 +Gaoxiong,Taiwan,China=710200 +Tainan,Taiwan,China=710300 +Taizhong,Taiwan,China=710400 +Nantou,Taiwan,China=710600 +Jilong,Taiwan,China=710700 +Xinzhu,Taiwan,China=710800 +Jiayi,Taiwan,China=710900 +Xinbei,Taiwan,China=711100 +Taoyuan,Taiwan,China=711400 + + +#西藏 +Lhasa,Tibet,China=540100
\ No newline at end of file diff --git a/target/classes/common_country_coding.properties b/target/classes/common_country_coding.properties new file mode 100644 index 0000000..d6257c2 --- /dev/null +++ b/target/classes/common_country_coding.properties @@ -0,0 +1,252 @@ +UnitedStates=1 +Canada=1 +Russia=7 +Egypt=20 +SouthAfrica=27 +Greece=30 +Netherlands=31 +Belgium=32 +France=33 +Spain=34 +Hungary=36 +EastGermany=37 +Yugoslavia=38 +Italy=39 +Romania=40 +Switzerland=41 +Czechoslovakia=42 +Austria=43 +UnitedKingdom=44 +Denmark=44 +Sweden=46 +Norway=47 +Poland=48 +Germany=49 +Peru=51 +Mexico=52 +Cuba=53 +Argentina=54 +Brazil=55 +Chile=56 +Colombia=57 +Venezuela=58 +Malaysia=60 +Australia=61 +Indonesia=62 +Philippines=63 +newZealand=64 +Singapore=65 +Thailand=66 +Japa=81 +Korea=82 +Vietnam=84 +China=86 +Turkey=90 +India=91 +Pakistan=92 +Afghanistan=93 +SriLanka=94 +Myanmar=95 +Iran=98 +SouthSudan=211 +Morocco=212 +Algeria=213 +Tunisia=216 +Libya=218 +Gambia=220 +Senegal=221 +Mauritania=222 +Mali=223 +Guinea=224 +Coted'Ivoire=225 +BurkinaFaso=226 +Niger=227 +Togo=228 +Benin=229 +Mauritius=230 +Liberia=231 +SierraLeone=232 +Ghana=233 +Nigeria=234 +Chad=235 +CentralAfricanRepublic=236 +Cameroon=237 +CapeVerde=238 +SaoTomeandPrincipe=239 +EquatorialGuinea=240 +Gabon=241 +therepublicofCongo=242 +DemocraticRepublicofCongo=243 +Angola=244 +Guinea-Bissau=245 +DiegoGarcia=246 +AscensionIsland=247 +Seychelles=248 +Sudan=249 +Rwanda=250 +Ethiopia=251 +Somalia=252 +Djibouti=253 +Kenya=254 +Tanzania=255 +Uganda=256 +Burundi=257 +Mozambique=258 +Zanzibar=259 +Zambia=260 +Madagascar=261 +Reunion=262 +Zimbabwe=263 +Namibia=264 +Malawi=265 +Lesotho=266 +Botswana=267 +Swaziland=268 +ComorosandMayotte=269 +St.Helena=290 +Eritrea=291 +Aruba=297 +FaroeIslands=298 +Greenland=299 +Gibraltar=350 +Portugal=351 +Luxembourg=352 +Ireland=353 +Iceland=354 +Albania=355 +Malta=356 +Cyprus=357 +Finland=358 +Bulgaria=359 +Lithuania=370 +Latvia=371 +Estonia=372 +Moldova=373 +Armenia=374 +Belarus=375 +Andorra=376 +Monaco=377 +SanMarino=378 +Vatican=379 +Ukraine=380 +Serbia=381 +Montenegro=382 +Croatia=385 +Slovenia=386 +BosniaandHerzegovina=387 +Europeantelephonenumberspace-ringEuropeservice=388 +Macedonia=389 +CzechRepublic=420 +Slovakia=421 +Liechtenstein=423 +FalklandIslands=500 +Belize=501 +Guatemala=502 +Salvador=503 +Honduras=504 +Nicaragua=505 +CostaRica=506 +Panama=507 +SaintPierreandMiquelon=508 +Haiti=509 +Guadeloupe(includingFrenchSaintMartinandSaintBarthelemy)=590 +Bolivia=591 +Guyana=592 +Ecuador=593 +FrenchGuiana=594 +Paraguay=595 +Martinique=596 +Suriname=597 +Uruguay=598 +NetherlandsAntilles=599 +EastTimor=670 +Australianoverseasterritories:Antarctica,ChristmasIsland,CocosIslands,NorfolkIsland=672 +Brunei=673 +Nauru=674 +PapuaNewGuinea=675 +Tonga=676 +SolomonIslands=677 +Vanuatu=678 +Fiji=679 +Palau=680 +WallisandFutunaIslands=681 +CookIslands=682 +Niue=683 +Samoa=685 +Kiribati,GilbertIslands=686 +NewCaledonia=687 +Tuvalu,EllisIslands=688 +FrenchPolynesia=689 +Tokelau=690 +FederatedStatesofMicronesia=691 +MarshallIslands=692 +NorthKorea=850 +HongKong=852 +Macao,China=853 +Cambodia=855 +Laos=856 +InternationalMaritimeSatelliteOrganization=870 +GlobalPersonalCommunicationService=878 +Bangladesh=880 +Mobilesatellitesystem=881 +Internet=882 +Taiwan=886 +Maldives=960 +Lebanon=961 +Jordan=962 +Syria=963 +Iraq=964 +Kuwait=965 +SaudiArabia=966 +Yemen=967 +Oman=968 +YemenDemocraticRepublic=969 +Palestine=970 +UnitedArabEmirates=971 +Israel=972 +Bahrain=973 +Qatar=974 +Bhutan=975 +Mongolia=976 +Nepal=977 +Internationalrateservice=979 +InternationalTelecommunicationsPublicCommunicationServiceTest=991 +Tajikistan=992 +Turkmenistan=993 +Azerbaijan=994 +Georgia=995 +Kyrgyzstan=996 +Uzbekistan=998 +Bahamas=1242 +Barbados=1246 +Anguilla=1264 +AntiguaandBarbuda=1268 +BritishVirginIslands=1284 +U.S.VirginIslands=1240 +CaymanIslands=1345 +Bermuda=1441 +Grenada=1473 +TurksandCaicosIslands=1649 +Montserrat=1664 +NorthernMarianaIslands=1670 +Guam=1671 +AmericanSamoa=1684 +SaintLucia=1758t +Dominica=1767 +SaintVincentandheGrenadines=1784 +PuertoRico=1787 +DominicanRepublic=1809 +TrinidadandTobago=1868 +SaintKittsandNevis=1869 +Jamaica=1876 +Curacao=5999 +Macao=820000 + + + + + + + + + diff --git a/target/classes/common_jstx_id_coding.properties b/target/classes/common_jstx_id_coding.properties new file mode 100644 index 0000000..ac60791 --- /dev/null +++ b/target/classes/common_jstx_id_coding.properties @@ -0,0 +1,194 @@ +100=Unknown_TCP +101=Unknown_UDP +102=Unknown_Other +103=DNS +104=FTP +105=FTPS +106=HTTP +107=HTTPS +108=ICMP +109=IKE +110=MAIL +111=IMAPS +112=IPSEC +113=XMPP +114=L2TP +115=NTP +117=POP3S +118=PPTP +119=QUIC +120=SIP +121=SMB +123=SMTPS +124=SPDY +125=SSH +126=SSL +127=SOCKS +128=TELNET +129=DHCP +130=RADIUS +131=OPENVPN +132=STUN +133=TEREDO +134=DTLS +135=DoH +136=ISAKMP +137=MDNS +138=NETBIOS +139=NETFLOW +140=RDP +141=RTCP +142=RTP +143=SLP +144=SNMP +145=SSDP +146=TFTP +147=BJNP +148=LDAP +149=RTMP +150=RTSP +200=05001 +201=05002 +202=05003 +203=05004 +204=05005 +205=05006 +206=05007 +207=05008 +208=05009 +209=05010 +210=05011 +211=05012 +212=05013 +213=05014 +214=05015 +215=05016 +216=05017 +217=05018 +218=05019 +219=05020 +220=05021 +221=05022 +222=05023 +223=05024 +224=05025 +225=05026 +226=05027 +227=05028 +228=05029 +229=05030 +230=05031 +231=05032 +232=05033 +233=05034 +234=05035 +235=05036 +236=05037 +237=05038 +238=05039 +239=05040 +240=05041 +241=05042 +242=05043 +243=05044 +244=05045 +245=05046 +246=05047 +247=05048 +248=05049 +249=05050 +250=05051 +251=05052 +252=05053 +253=05054 +254=05055 +255=05056 +256=05057 +257=05058 +258=05059 +259=05060 +260=05061 +261=05062 +262=05063 +263=05064 +264=05065 +265=05066 +266=05067 +267=05068 +268=05069 +269=05070 +270=05071 +271=05072 +272=05073 +273=05074 +274=05075 +275=05076 +276=05077 +277=05078 +278=05079 +279=05080 +280=05081 +281=05082 +282=05083 +283=05084 +284=05085 +285=05086 +286=05087 +287=05088 +288=05089 +289=05090 +290=05091 +291=05092 +292=05093 +293=05094 +294=05095 +295=05096 +296=05097 +297=05098 +298=05099 +299=05100 +300=05101 +301=05102 +302=05103 +303=05104 +304=05105 +305=05106 +306=05107 +307=05108 +308=05109 +309=05110 +310=05111 +311=05112 +312=05113 +313=05114 +314=05115 +315=05116 +316=05117 +317=05118 +318=05119 +319=05120 +320=05121 +321=05122 +322=05123 +323=05124 +324=05125 +325=05126 +326=05127 +327=05128 +328=05129 +329=05130 +330=05131 +331=05132 +332=05133 +333=05134 +334=05135 +335=05136 +336=05137 +337=05138 +338=05139 +339=05140 +340=05141 +341=05142 +342=05143 +343=05144 +344=05145
\ No newline at end of file diff --git a/target/classes/common_province_coding.properties b/target/classes/common_province_coding.properties new file mode 100644 index 0000000..caf6869 --- /dev/null +++ b/target/classes/common_province_coding.properties @@ -0,0 +1,34 @@ +Beijing=110000 +Tianjin=120000 +Hebei=13000 +Shanxi=140000 +InnerMongoliaAutonomousRegion=150000 +Liaoning=210000 +Jilin=220000 +Heilongjiang=230000 +Shanghai=310000 +Jiangsu=320000 +Zhejiang=330000 +Anhui=340000 +Fujian=350000 +Jiangxi=360000 +Shandong=370000 +Henan=410000 +Hubei=420000 +Hunan=430000 +Guangdong=440000 +GuangxiZhuangAutonomousRegion=450000 +Hainan=460000 +Chongqing=500000 +Sichuan=510000 +Guizhou=520000 +Yunnan=530000 +TibetAutonomousRegion=540000 +Shaanxi=610000 +Gansu=620000 +Qinghai=630000 +NingxiaHuiAutonomousRegion=640000 +Taiwan=710000 +HongKong=810000 +Macao=820000 +Tibet=540000
\ No newline at end of file diff --git a/target/classes/service_bolt_config.properties b/target/classes/service_bolt_config.properties new file mode 100644 index 0000000..fba3993 --- /dev/null +++ b/target/classes/service_bolt_config.properties @@ -0,0 +1,68 @@ +#Flooding-spout-field + + +#conn-bolt-StreamID +conn.dns.streamid=CONN-DNS-SOURCE +conn.ftp.streamid=CONN-FTP-SOURCE +conn.http.streamid=CONN-HTTP-SOURCE +conn.ip.streamid=CONN-IP-SOURCE +conn.jstx.streamid=CONN-JSTX-SOURCE +conn.mail.streamid=CONN-MAIL-SOURCE +conn.ssl.streamid=CONN-SSL-SOURCE +conn.vpn.streamid=CONN-VPN-SOURCE + + +#conn-ComponentId-spout +kafka.spout=KAFKA-SPOUT + +#conn-ComponentId-bolt +conn.parse.componentid=CONN-PARSE-COMPONENTID + + +conn.ybinputsize.streamid=CONN-YBInputSize-STREAMID + + + +#safe-spout-field +safe.spout.field=SAFE-SOURCE + + +#GK-SOURCE-STREAMID +gk.ip.streamid=GK-IP-STREAMID +gk.dns.streamid=GK-DNS-STREAMID +gk.http.streamid=GK-HTTP-STREAMID +gk.ssl.streamid=GK-SSL-STREAMID +gk.wygjc.streamid=GK-WYGJC-STREAMID +gk.mail.streamid=GK-MAIL-STREAMID +gk.ftp.streamid=GK-FTP-STREAMID +gk.vpn.streamid=GK-VPN-STREAMID +gk.jstx.streamid=GK-JSTX-STREAMID + + +gk.count.streamid=GK-COUNT-STREAMID + + + +#JC-SOURCE-STREAMID +jc.ip.streamid=JC-IP-STREAMID +jc.dns.streamid=JC-DNS-STREAMID +jc.http.streamid=JC-HTTP-STREAMID +jc.ssl.streamid=JC-SSL-STREAMID +jc.wygjc.streamid=JC-WYGJC-STREAMID +jc.mail.streamid=JC-MAIL-STREAMID +jc.ftp.streamid=JC-FTP-STREAMID +jc.vpn.streamid=JC-VPN-STREAMID +jc.jstx.streamid=JC-JSTX-STREAMID +jc.pic.streamid=JC-PIC-STREAMID +jc.media.streamid=JC-MEDIA-STREAMID +jc.count.streamid=JC-COUNT-STREAMID + + + + + + + + + + diff --git a/target/classes/service_flow_config.properties b/target/classes/service_flow_config.properties new file mode 100644 index 0000000..ad639f0 --- /dev/null +++ b/target/classes/service_flow_config.properties @@ -0,0 +1,176 @@ +#\u7BA1\u7406kafka\u5730\u5740 +bootstrap.servers=192.168.44.12:9092 +#latest/earliest +auto.offset.reset=earliest +#\u538B\u7F29\u6A21\u5F0F none or snappy +kafka.compression.type=none + +topology.logo=conn + +#kafka broker\u4E0B\u7684\u6CDB\u6536topic\u540D\u79F0 +kafka.topic=CONNECTION-RECORD-COMPLETED-LOG + +#kafka broker\u4E0B\u7684\u5B89\u5168topic\u540D\u79F0 +kafka.safe.topic=SECURITY-EVENT-COMPLETED-LOG + +#\u8BFB\u53D6topic,\u5B58\u50A8\u8BE5spout id\u7684\u6D88\u8D39offset\u4FE1\u606F\uFF0C\u53EF\u901A\u8FC7\u8BE5\u62D3\u6251\u547D\u540D;\u5177\u4F53\u5B58\u50A8offset\u7684\u4F4D\u7F6E\uFF0C\u786E\u5B9A\u4E0B\u6B21\u8BFB\u53D6\u4E0D\u91CD\u590D\u7684\u6570\u636E\uFF1B +group.id=test-consumer-group20210205165511 +group.safe.id=test-consumer-group20210130111111111211111111 +#kafka\u6BCF\u4E00\u6279\u62C9\u591A\u4E45\u7684\u6570\u636E +kafka.consumer.poll=1000 + +#storm topology workers +topology.workers=5 + +#spout\u6700\u5927\u5E76\u884C\u5EA6 +max.spout.parallelism=10 +conn.spout.parallelism=10 +safe.spout.parallelism=10 + + +#ack\u8BBE\u7F6E 1\u542F\u52A8ack 0\u4E0D\u542F\u52A8ack +topology.num.acks=0 + +#spout\u63A5\u6536\u7761\u7720\u65F6\u95F4 +topology.spout.sleep.time=1 + + +#flooding-bolt\u6BCF\u6279\u6B21\u5904\u7406\u7684\u65F6\u95F4\u95F4\u9694 +conn.topology.tick.tuple.freq.secs=60 +#conn-bolt\u6BCF\u6279\u5904\u7406\u6761\u6570 +conn.batch.inter.num=10000 + + +#safe-bolt\u6BCF\u6279\u6B21\u5904\u7406\u7684\u65F6\u95F4\u95F4\u9694 +safe.topology.tick.tuple.freq.secs=10 +#safe-bolt\u6BCF\u6279\u5904\u7406\u6761\u6570 +safe.batch.inter.num=2000 + +#conn-bolt-parallelism_hint + +conn.parse.parallelism=10 +conn.send.parallelism=5 +conn.ip.send.parallelism=5 +conn.ssl.send.parallelism=5 +conn.http.send.parallelism=5 +conn.count.send.parallelism=5 + +#gk-bolt-parallelism_hint +gk.parse.parallelism=5 +gk.send.parallelism=5 +gk.http.send.parallelism=5 +gk.ip.send.parallelism=5 +gk.ssl.send.parallelism=5 +gk.count.send.parallelism=5 + +#jc-bolt-parallelism_hint +jc.parse.parallelism=5 +jc.send.parallelism=5 +jc.http.send.parallelism=5 +jc.ip.send.parallelism=5 +jc.ssl.send.parallelism=5 +jc.count.send.parallelism=5 +jc.dns.send.parallelism=5 + + + + + +#conn-schema +ftp.rzzb.schema={"type":"record","name":"FTP_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"FILE_CONTENT","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +dns.rzzb.schema={"type":"record","name":"DNS_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"DNS_NAME","type":["string","null"]},{"name":"DNS_VALUE","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +http.rzzb.schema={"type":"record","name":"HTTP_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"USER_AGENT","type":["string","null"]},{"name":"COOKIE","type":["string","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ip.rzzb.schema={"type":"record","name":"IP_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +jstx.rzzb.schema={"type":"record","name":"JSTX_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"DZ_ID","type":["string","null"]},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"URL_AGENT","type":["string","null"]},{"name":"USER_ID","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"RESERVED","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ssl.rzzb.schema={"type":"record","name":"SSL_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"ZSMC","type":["string","null"]},{"name":"BFZ","type":["string","null"]},{"name":"SYZ","type":["string","null"]},{"name":"FWQMC","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +vpn.rzzb.schema={"type":"record","name":"VPN_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"URL","type":["int","null"]},{"name":"USERNAME","type":["int","null"]},{"name":"PWD","type":["int","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +mail.rzzb.schema={"type":"record","name":"MAIL_RZZB","fields":[{"name":"BHSJ","type":"long"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"MAIL_SENDER","type":["string","null"]},{"name":"MAIL_RECEVER","type":["string","null"]},{"name":"RECEVER_NUM","type":["int","null"]},{"name":"MAIL_CC","type":["string","null"]},{"name":"CC_NUM","type":["int","null"]},{"name":"MAIL_SUBJECT","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"ACCESSORY","type":["int","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"FILE_CONTENT","type":["string","null"]},{"name":"PWD","type":["string","null"]},{"name":"FJFWS","type":["string","null"]},{"name":"FJFWS_SZD","type":["string","null"]},{"name":"SJFWS","type":["string","null"]},{"name":"SJFWS_SZD","type":["string","null"]},{"name":"XYLX","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} + + +#Flooding-http-post-socketTimeOut +flooding.http.post.socketTimeOut=10 + +flooding.post.dns.topic=t_dns_rzzb +flooding.post.ftp.topic=t_ftp_rzzb +flooding.post.http.topic=t_http_rzzb +flooding.post.ip.topic=t_ip_rzzb +flooding.post.jstx.topic=t_jstx_rzzb +flooding.post.mail.topic=t_mail_rzzb +flooding.post.ssl.topic=t_ssl_rzzb +flooding.post.vpn.topic=t_vpn_rzzb + + +gk.post.dns.topic=t_dns_gkzb +gk.post.ftp.topic=t_ftp_gkzb +gk.post.http.topic=t_http_gkzb +gk.post.ip.topic=t_ip_gkzb +gk.post.jstx.topic=t_jstx_gkzb +gk.post.mail.topic=t_mail_gkzb +gk.post.ssl.topic=t_ssl_gkzb +gk.post.vpn.topic=t_vpn_gkzb +gk.post.wygjc.topic=t_wygjc_gkrz + + +jc.post.dns.topic=t_dns_jczb +jc.post.ftp.topic=t_ftp_jczb +jc.post.http.topic=t_http_jczb +jc.post.ip.topic=t_ip_jczb +jc.post.jstx.topic=t_jstx_jczb +jc.post.mail.topic=t_mail_jczb +jc.post.ssl.topic=t_ssl_jczb +jc.post.vpn.topic=t_vpn_jczb +jc.post.wygjc.topic=t_wygjc_jcrz +jc.post.pic.topic=t_pic_jczb +jc.post.media.topic=t_media_jczb + + + + + +http.heard.content.type=utf-8 +http.hearder.user=lt_xgs_source +http.hearder.password=lt_xgs_source@2021 +http.hearder.format=avro +http.hearder.conection=keep-alilve + +http.post.flooding.ip=10.111.208.1,10.111.208.2,10.111.208.3,10.111.208.4,10.111.208.5,10.111.208.6,10.111.208.7,10.111.216.1,10.111.216.2,10.111.216.3 + +http.post.port=10080 + +#count\u51FA\u6307\u6807\u7684\u65F6\u95F4\u95F4\u9694(\u5355\u4F4D\u4E3A\u79D2\uFF0C\u6307\u6807\u662F\u4EE5\u5206\u949F\u4E3A\u5355\u4F4D\u6700\u597D\u4E3A60\u7684\u500D\u6570) +count.topology.tick.tuple.freq.secs=10 + +#prometheus-httpserver +prometheus.pushgateway.address=10.111.200.5:9274 + + +#gk-schema +ip.gkrz.schema={"type":"record","name":"IP_GKRZ","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +dns.gkzb.schema={"type":"record","name":"DNS_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"DNS_NAME","type":["string","null"]},{"name":"DNS_VALUE","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":["int","null"]},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +http.gkzb.schema={"type":"record","name":"HTTP_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":"int"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"USER_AGENT","type":["string","null"]},{"name":"COOKIE","type":["string","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ssl.gkzb.schema={"type":"record","name":"SSL_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"ZSMC","type":["string","null"]},{"name":"BFZ","type":["string","null"]},{"name":"SYZ","type":["string","null"]},{"name":"FWQMC","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +wygjc.gkrz.schema={"type":"record","name":"WYGJC_GKRZ","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"JC_URL","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"SSYQ","type":["string","null"]},{"name":"GJZ","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ftp.gkzb.schema={"type":"record","name":"FTPGJZ_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":"int"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"FILE_NAME","type":["string","null"]},{"name":"FILE_CONTENT","type":["string","null"]},{"name":"GJZ","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +vpn.gkzb.schema={"type":"record","name":"VPN_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"URL","type":["string","null"]},{"name":"USERNAME","type":["string","null"]},{"name":"PWD","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +jstx.gkzb.schema={"type":"record","name":"JSTX_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"DZ_ID","type":["string","null"]},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"USER_AGENT","type":["string","null"]},{"name":"USER_ID","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"RESERVED","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +mail.gkzb.schema={"type":"record","name":"MAIL_GKZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"MAIL_SENDER","type":["string","null"]},{"name":"MAIL_RECEVER","type":["string","null"]},{"name":"RECEVER_NUM","type":["int","null"]},{"name":"MAIL_CC","type":["string","null"]},{"name":"CC_NUM","type":["int","null"]},{"name":"MAIL_SUBJECT","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"ACCESSORY","type":["int","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"FILE_CONTENT","type":["string","null"]},{"name":"PWD","type":["string","null"]},{"name":"FJFWS","type":["string","null"]},{"name":"FJFWS_SZD","type":["string","null"]},{"name":"SJFWS","type":["string","null"]},{"name":"SJFWS_SZD","type":["string","null"]},{"name":"XYLX","type":["string","null"]},{"name":"GJZ","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} + +#jc-schema +dns.jczb.schema={"type":"record","name":"DNS_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"DNS_NAME","type":["string","null"]},{"name":"DNS_VALUE","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ftp.jczb.schema={"type":"record","name":"FTPGJZ_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":"int"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"FILE_CONTENT","type":["string","null"]},{"name":"GJZ","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +http.jczb.schema={"type":"record","name":"HTTP_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":"int"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"USER_AGENT","type":["string","null"]},{"name":"COOKIE","type":["string","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ip.jczb.schema={"type":"record","name":"IP_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +jstx.jczb.schema={"type":"record","name":"JSTX_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"DZ_ID","type":["string","null"]},{"name":"HOST","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"USER_AGENT","type":["string","null"]},{"name":"USER_ID","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"RESERVED","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +ssl.jczb.schema={"type":"record","name":"TDZS_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"ZSMC","type":["string","null"]},{"name":"BFZ","type":["string","null"]},{"name":"SYZ","type":["string","null"]},{"name":"FWQMC","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +vpn.jczb.schema={"type":"record","name":"VPN_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"URL","type":["string","null"]},{"name":"USERNAME","type":["string","null"]},{"name":"PWD","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +wygjz.jczb.schema={"type":"record","name":"WYGJC_JCRZ","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":"int"},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"JC_URL","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"SSYQ","type":["string","null"]},{"name":"GJZ","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +pic.jczb.schema={"type":"record","name":"PIC_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"YYZL","type":["int","null"]},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"PIC_NAME","type":["string","null"]},{"name":"PIC_URL","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"PIC_TYPE","type":["string","null"]},{"name":"PIC_CONTENT","type":["bytes","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +media.jczb.schema={"type":"record","name":"MEDIA_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"YYZL","type":["int","null"]},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"MEDIA_NAME","type":["string","null"]},{"name":"MEDIA_URL","type":["string","null"]},{"name":"URL","type":["string","null"]},{"name":"MEDIA_TYPE","type":["string","null"]},{"name":"MEDIA_CONTENT","type":["bytes","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} +mail.jczb.schema={"type":"record","name":"MAILGJZ_JCZB","fields":[{"name":"BHSJ","type":"long"},{"name":"PZID","type":"string"},{"name":"FLID","type":"int"},{"name":"XZID","type":"int"},{"name":"LHID","type":"int"},{"name":"YDY","type":"string"},{"name":"MDDY","type":"string"},{"name":"PZLX","type":"int"},{"name":"GKLB","type":["int","null"]},{"name":"YYZL","type":["int","null"]},{"name":"QDJIP","type":"int"},{"name":"SIP","type":"string"},{"name":"DIP","type":"string"},{"name":"SPORT","type":"int"},{"name":"DPORT","type":"int"},{"name":"PROTOCOL","type":"int"},{"name":"PROTO_ID","type":"string"},{"name":"DETAIL_ID","type":"string"},{"name":"CS_PKTS","type":["int","null"]},{"name":"CS_BYTES","type":["long","null"]},{"name":"SC_PKTS","type":["int","null"]},{"name":"SC_BYTES","type":["long","null"]},{"name":"MAIL_SENDER","type":["string","null"]},{"name":"MAIL_RECEVER","type":["string","null"]},{"name":"RECEVER_NUM","type":["int","null"]},{"name":"MAIL_CC","type":["string","null"]},{"name":"CC_NUM","type":["int","null"]},{"name":"MAIL_SUBJECT","type":["string","null"]},{"name":"CONTENT","type":["string","null"]},{"name":"ACCESSORY","type":["int","null"]},{"name":"FILE_NAME","type":["string","null"]},{"name":"FILE_CONTENT","type":["string","null"]},{"name":"PWD","type":["string","null"]},{"name":"FJFWS","type":["string","null"]},{"name":"FJFWS_SZD","type":["string","null"]},{"name":"SJFWS","type":["string","null"]},{"name":"SJFWS_SZD","type":["string","null"]},{"name":"XYLX","type":["string","null"]},{"name":"GJZ","type":["string","null"]},{"name":"YYS","type":["int","null"]},{"name":"YL1","type":"int"},{"name":"YL2","type":["int","null"]},{"name":"YL3","type":["string","null"]},{"name":"YL4","type":["string","null"]},{"name":"YL5","type":["string","null"]}]} + + + + + + + diff --git a/target/test-classes/People.class b/target/test-classes/People.class Binary files differnew file mode 100644 index 0000000..391dd9c --- /dev/null +++ b/target/test-classes/People.class diff --git a/target/test-classes/TestYdy.class b/target/test-classes/TestYdy.class Binary files differnew file mode 100644 index 0000000..eeeb2e7 --- /dev/null +++ b/target/test-classes/TestYdy.class diff --git a/target/test-classes/conntest/TestFtp.class b/target/test-classes/conntest/TestFtp.class Binary files differnew file mode 100644 index 0000000..f89f1bc --- /dev/null +++ b/target/test-classes/conntest/TestFtp.class diff --git a/target/test-classes/conntest/TestJstx.class b/target/test-classes/conntest/TestJstx.class Binary files differnew file mode 100644 index 0000000..213983f --- /dev/null +++ b/target/test-classes/conntest/TestJstx.class diff --git a/target/test-classes/conntest/TestMail.class b/target/test-classes/conntest/TestMail.class Binary files differnew file mode 100644 index 0000000..83e200a --- /dev/null +++ b/target/test-classes/conntest/TestMail.class diff --git a/target/test-classes/conntest/TestSSL.class b/target/test-classes/conntest/TestSSL.class Binary files differnew file mode 100644 index 0000000..c626dd4 --- /dev/null +++ b/target/test-classes/conntest/TestSSL.class diff --git a/target/test-classes/conntest/TestVpn.class b/target/test-classes/conntest/TestVpn.class Binary files differnew file mode 100644 index 0000000..ee136d0 --- /dev/null +++ b/target/test-classes/conntest/TestVpn.class diff --git a/target/test-classes/gktest/TestDns.class b/target/test-classes/gktest/TestDns.class Binary files differnew file mode 100644 index 0000000..126af00 --- /dev/null +++ b/target/test-classes/gktest/TestDns.class diff --git a/target/test-classes/gktest/TestFtp.class b/target/test-classes/gktest/TestFtp.class Binary files differnew file mode 100644 index 0000000..edf8f35 --- /dev/null +++ b/target/test-classes/gktest/TestFtp.class diff --git a/target/test-classes/gktest/TestHttp.class b/target/test-classes/gktest/TestHttp.class Binary files differnew file mode 100644 index 0000000..98a640b --- /dev/null +++ b/target/test-classes/gktest/TestHttp.class diff --git a/target/test-classes/gktest/TestIP.class b/target/test-classes/gktest/TestIP.class Binary files differnew file mode 100644 index 0000000..ca4acfb --- /dev/null +++ b/target/test-classes/gktest/TestIP.class diff --git a/target/test-classes/gktest/TestMail.class b/target/test-classes/gktest/TestMail.class Binary files differnew file mode 100644 index 0000000..d8d74df --- /dev/null +++ b/target/test-classes/gktest/TestMail.class diff --git a/target/test-classes/gktest/TestSsl.class b/target/test-classes/gktest/TestSsl.class Binary files differnew file mode 100644 index 0000000..ac2691d --- /dev/null +++ b/target/test-classes/gktest/TestSsl.class diff --git a/target/test-classes/gktest/TestVpn.class b/target/test-classes/gktest/TestVpn.class Binary files differnew file mode 100644 index 0000000..8eb0026 --- /dev/null +++ b/target/test-classes/gktest/TestVpn.class diff --git a/target/test-classes/gktest/TestWygjc.class b/target/test-classes/gktest/TestWygjc.class Binary files differnew file mode 100644 index 0000000..87b7c1a --- /dev/null +++ b/target/test-classes/gktest/TestWygjc.class diff --git a/target/test-classes/gktest/Testjstx.class b/target/test-classes/gktest/Testjstx.class Binary files differnew file mode 100644 index 0000000..2eed838 --- /dev/null +++ b/target/test-classes/gktest/Testjstx.class diff --git a/target/test-classes/jctest/JCIp.class b/target/test-classes/jctest/JCIp.class Binary files differnew file mode 100644 index 0000000..361fd79 --- /dev/null +++ b/target/test-classes/jctest/JCIp.class diff --git a/target/test-classes/jctest/JcHttp.class b/target/test-classes/jctest/JcHttp.class Binary files differnew file mode 100644 index 0000000..bbc7be4 --- /dev/null +++ b/target/test-classes/jctest/JcHttp.class diff --git a/target/test-classes/jctest/JcPic.class b/target/test-classes/jctest/JcPic.class Binary files differnew file mode 100644 index 0000000..6d0be59 --- /dev/null +++ b/target/test-classes/jctest/JcPic.class diff --git a/target/test-classes/jctest/JcSsl.class b/target/test-classes/jctest/JcSsl.class Binary files differnew file mode 100644 index 0000000..a1d9657 --- /dev/null +++ b/target/test-classes/jctest/JcSsl.class diff --git a/target/test-classes/jctest/TestDns.class b/target/test-classes/jctest/TestDns.class Binary files differnew file mode 100644 index 0000000..d55a02b --- /dev/null +++ b/target/test-classes/jctest/TestDns.class diff --git a/target/test-classes/jctest/TestFTP.class b/target/test-classes/jctest/TestFTP.class Binary files differnew file mode 100644 index 0000000..c52e795 --- /dev/null +++ b/target/test-classes/jctest/TestFTP.class diff --git a/target/test-classes/jctest/TestJstx.class b/target/test-classes/jctest/TestJstx.class Binary files differnew file mode 100644 index 0000000..39d2408 --- /dev/null +++ b/target/test-classes/jctest/TestJstx.class diff --git a/target/test-classes/jctest/TestMail.class b/target/test-classes/jctest/TestMail.class Binary files differnew file mode 100644 index 0000000..149feb0 --- /dev/null +++ b/target/test-classes/jctest/TestMail.class diff --git a/target/test-classes/jctest/TestMedia.class b/target/test-classes/jctest/TestMedia.class Binary files differnew file mode 100644 index 0000000..50897bf --- /dev/null +++ b/target/test-classes/jctest/TestMedia.class diff --git a/target/test-classes/jctest/TestVPN.class b/target/test-classes/jctest/TestVPN.class Binary files differnew file mode 100644 index 0000000..f2ca6e8 --- /dev/null +++ b/target/test-classes/jctest/TestVPN.class diff --git a/target/test-classes/jctest/TestWygjc.class b/target/test-classes/jctest/TestWygjc.class Binary files differnew file mode 100644 index 0000000..c6e8509 --- /dev/null +++ b/target/test-classes/jctest/TestWygjc.class |