From 79e23c1000f74c71673ee8449263e99426f47600 Mon Sep 17 00:00:00 2001
From: wangkuan <wangkuan@geedgenetworks.com>
Date: Fri, 16 Aug 2024 10:07:24 +0800
Subject: [PATCH] =?UTF-8?q?Attack=20Type=E4=B8=BACustom=20Attack=20Type?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8CConditions=E7=9A=84=E5=80=BC=E6=9C=89?=
 =?UTF-8?q?=E8=AF=AF,=E8=A7=A3=E5=86=B3pom=E4=BE=9D=E8=B5=96=E5=86=B2?=
 =?UTF-8?q?=E7=AA=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       | 20 +++++++++++++++++--
 .../function/DosDetectionFunction.java        |  2 +-
 2 files changed, 19 insertions(+), 3 deletions(-)

diff --git a/pom.xml b/pom.xml
index 112a785..43a95bf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.zdjizhi</groupId>
     <artifactId>flink-dos-detection</artifactId>
-    <version>24-08-07</version>
+    <version>24-08-16</version>
 
     <name>flink-dos-detection</name>
     <url>http://www.example.com</url>
@@ -80,7 +80,7 @@
                         </goals>
 
                         <configuration>
-                            <finalName>flink-dos-detection-24-08-07</finalName>
+                            <finalName>flink-dos-detection-24-08-16</finalName>
                             <relocations>
                                 <relocation>
                                     <pattern>org.apache.http</pattern>
@@ -152,13 +152,29 @@
             <artifactId>json-path</artifactId>
             <version>${jsonpath.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.xerial.snappy</groupId>
+            <artifactId>snappy-java</artifactId>
+            <version>1.1.8.3</version>
+        </dependency>
 
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-connector-kafka_2.12</artifactId>
             <version>${flink.version}</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>slf4j-log4j12</artifactId>
+                    <groupId>org.slf4j</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>snappy-java</artifactId>
+                    <groupId>org.xerial.snappy</groupId>
+                </exclusion>
+            </exclusions>
         </dependency>
 
+
       <!--  <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-runtime-web_2.12</artifactId>
diff --git a/src/main/java/com/zdjizhi/function/DosDetectionFunction.java b/src/main/java/com/zdjizhi/function/DosDetectionFunction.java
index 190c20b..9db50b9 100644
--- a/src/main/java/com/zdjizhi/function/DosDetectionFunction.java
+++ b/src/main/java/com/zdjizhi/function/DosDetectionFunction.java
@@ -88,7 +88,7 @@ public class DosDetectionFunction extends ProcessFunction<DosSketchLog, DosEvent
                 }
             }
             else{
-                finalResult = getResult(value,0,0,Severity.MAJOR,0.0,0,"DoS Protection [12]");
+                finalResult = getResult(value,0,0,Severity.MAJOR,0.0,0,"DoS Protection ["+value.getRule_id()+"]");
             }
             } catch(Exception e){
                 logger.error("判定失败\n {} \n{}", value, e);