From 046b7fea8072e12f6d0738c81e9d4a5bddec9fa8 Mon Sep 17 00:00:00 2001
From: wangchengcheng <wangchengcheng@geedgenetworks.com>
Date: Tue, 23 Jan 2024 18:12:25 +0800
Subject: [PATCH] fix:fixed the problem of reporting NoClass in session mode

---
 pom.xml                                       |  9 ++++-
 .../java/com/zdjizhi/conf/DosConfigs.java     |  5 +++
 .../zdjizhi/main/DosDetectionApplication.java |  2 +-
 .../resources/detection_dos_attack.properties | 40 +++++++++++++------
 4 files changed, 42 insertions(+), 14 deletions(-)

diff --git a/pom.xml b/pom.xml
index 9d0cb68..89a711c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.zdjizhi</groupId>
     <artifactId>flink-dos-detection</artifactId>
-    <version>23.12</version>
+    <version>1.0</version>
 
     <name>flink-dos-detection</name>
     <url>http://www.example.com</url>
@@ -64,6 +64,7 @@
                         <!-- Prevents recompilation due to missing package-info.class, see MCOMPILER-205 -->
                         <arg>-Xpkginfo:always</arg>
                     </compilerArgs>
+
                 </configuration>
             </plugin>
 
@@ -80,6 +81,12 @@
 
                         <configuration>
                             <finalName>flink-dos-detection</finalName>
+                            <relocations>
+                                <relocation>
+                                    <pattern>org.apache.http</pattern>
+                                    <shadedPattern>shade.org.apache.http</shadedPattern>
+                                </relocation>
+                            </relocations>
                             <filters>
                                 <filter>
                                     <!-- Do not copy the signatures in the META-INF folder.
diff --git a/src/main/java/com/zdjizhi/conf/DosConfigs.java b/src/main/java/com/zdjizhi/conf/DosConfigs.java
index 03edd60..9614ed3 100644
--- a/src/main/java/com/zdjizhi/conf/DosConfigs.java
+++ b/src/main/java/com/zdjizhi/conf/DosConfigs.java
@@ -255,5 +255,10 @@ public class DosConfigs {
                     .longType()
                     .defaultValue(60L);
 
+    public static final ConfigOption<String> JOB_NAME =
+            ConfigOptions.key("job.name")
+                    .stringType()
+                    .defaultValue("detection_dos_attack")
+                    .withDescription("The flink job name.");
 
 }
\ No newline at end of file
diff --git a/src/main/java/com/zdjizhi/main/DosDetectionApplication.java b/src/main/java/com/zdjizhi/main/DosDetectionApplication.java
index 3b5d770..152cb0f 100644
--- a/src/main/java/com/zdjizhi/main/DosDetectionApplication.java
+++ b/src/main/java/com/zdjizhi/main/DosDetectionApplication.java
@@ -79,6 +79,6 @@ public class DosDetectionApplication {
                 .addSink(KafkaProducer.getKafkaProducer(config.get(KAFKA_SINK_METRIC_TOPIC), DosConfiguration.getProperties(SINK_KAFKA_PROPERTIES_PREFIX)))
                 .setParallelism(config.get(KAFKA_SINK_METRIC_PARALLELISM));
 
-        env.execute(args[0]);
+        env.execute(config.get(JOB_NAME));
     }
 }
diff --git a/src/main/resources/detection_dos_attack.properties b/src/main/resources/detection_dos_attack.properties
index 8596b99..bf97608 100644
--- a/src/main/resources/detection_dos_attack.properties
+++ b/src/main/resources/detection_dos_attack.properties
@@ -1,24 +1,41 @@
-#kafka source
 source.kafka.topic=DOS-SKETCH-RECORD
-source.kafka.props.bootstrap.servers=192.168.44.11:9094,192.168.44.14:9094,192.168.44.15:9094
-source.kafka.props.group.id=dsadsadsad
-
+source.kafka.props.bootstrap.servers=192.168.45.102:9094
+source.kafka.props.group.id=dos-detection-job-20240116
+source.kafka.props.session.timeout.ms=60000
+source.kafka.props.max.poll.records=5000
+source.kafka.props.max.partition.fetch.bytes=31457280
 source.kafka.props.security.protocol=SASL_PLAINTEXT
 source.kafka.props.sasl.mechanism=PLAIN
 source.kafka.props.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin"password="galaxy2019";
+
 #kafka sink
-kafka.sink.event.topic.name=dos-test
-kafka.sink.metric.topic=test
-sink.kafka.props.bootstrap.servers=192.168.44.12:9092
+kafka.sink.event.topic.name=DOS-EVENT
+kafka.sink.metric.topic=TRAFFIC-TOP-DESTINATION-IP-METRIC
+sink.kafka.props.bootstrap.servers=192.168.45.102:9094
+sink.kafka.props.security.protocol=SASL_PLAINTEXT
+sink.kafka.props.sasl.mechanism=PLAIN
+sink.kafka.props.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="galaxy2019";
+sink.kafka.props.acks=1
+sink.kafka.props.retries=0
+sink.kafka.props.linger.ms=10
+sink.kafka.props.request.timeout.ms=30000
+sink.kafka.props.batch.size=262144
+sink.kafka.props.buffer.memory=134217728
+sink.kafka.props.max.request.size=10485760
+sink.kafka.props.compression.type=snappy
 
 #zookeeper地址
-hbase.zookeeper.quorum=192.168.44.12:2181
+hbase.zookeeper.quorum=192.168.45.102:2181
+
 flink.watermark.max.orderness=300
+
 #计算窗口大小，默认600s
 flink.window.max.time=600
-#bifang服务访问地址
-bifang.server.uri=http://192.168.44.72
-knowledge.base.uri=http://192.168.44.67:9999
+
+#cm服务访问地址
+bifang.server.uri=http://192.168.44.3
+
+knowledge.base.uri=http://192.168.45.102:9999
 ############################## 阈值 配置 ######################################
 static.sensitivity.threshold=1
 #基线敏感阈值
@@ -32,4 +49,3 @@ baseline.sessions.critical.threshold=8
 
 
 
-