3 files changed, 96 insertions, 0 deletions
diff --git a/src/test/java/com/zdjizhi/FIleTypeTest.java b/src/test/java/com/zdjizhi/FIleTypeTest.java
new file mode 100644
index 0000000..031bccd
--- /dev/null
+++ b/src/test/java/com/zdjizhi/FIleTypeTest.java
@@ -0,0 +1,13 @@
+package com.zdjizhi;
+
+import static com.zdjizhi.utils.general.FileEdit.getFileType;
+import static com.zdjizhi.utils.system.FlowWriteConfigurations.judgeFileType;
+
+public class FIleTypeTest {
+    public static void main(String[] args) {
+        String fileType = getFileType("http://10.3.60.3:9098/hos/firewall_hos_bucket/http_response_body_10.11.36.187.49310-203.205.219.105.80_869195700602659293_1.html");
+        System.out.println(fileType);
+        boolean b = judgeFileType(fileType);
+        System.out.println(b);
+    }
+}
diff --git a/src/test/java/com/zdjizhi/KafkaTest.java b/src/test/java/com/zdjizhi/KafkaTest.java
new file mode 100644
index 0000000..4b034a3
--- /dev/null
+++ b/src/test/java/com/zdjizhi/KafkaTest.java
@@ -0,0 +1,55 @@
+package com.zdjizhi;
+
+import cn.hutool.log.Log;
+import cn.hutool.log.LogFactory;
+import org.apache.kafka.clients.producer.*;
+import org.apache.kafka.common.config.SslConfigs;
+
+import java.util.Properties;
+
+/**
+ * @author qidaijie
+ * @Package com.zdjizhi
+ * @Description:
+ * @date 2021/8/217:39
+ */
+public class KafkaTest {
+    private static final Log logger = LogFactory.get();
+
+    public static void main(String[] args) {
+        Properties properties = new Properties();
+        properties.put("bootstrap.servers", "192.168.44.12:9091");
+        properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+        properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+        properties.put("acks", "1");
+//        properties.put("retries", DefaultProConfig.RETRIES);
+//        properties.put("linger.ms", DefaultProConfig.LINGER_MS);
+//        properties.put("request.timeout.ms", DefaultProConfig.REQUEST_TIMEOUT_MS);
+//        properties.put("batch.size", DefaultProConfig.BATCH_SIZE);
+//        properties.put("buffer.memory", DefaultProConfig.BUFFER_MEMORY);
+//        properties.put("max.request.size", DefaultProConfig.MAX_REQUEST_SIZE);
+
+        properties.put("security.protocol", "SSL");
+//        properties.put("ssl.keystore.location", "D:\\K18-Phase2\\tsgSpace\\dat\\kafka\\client.keystore.jks");
+        properties.put("ssl.keystore.location", "D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\keystore.jks");
+        properties.put("ssl.keystore.password", "galaxy2019");
+//        properties.put("ssl.truststore.location", "D:\\K18-Phase2\\tsgSpace\\dat\\kafka\\client.truststore.jks");
+        properties.put("ssl.truststore.location", "D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\truststore.jks");
+        properties.put("ssl.truststore.password", "galaxy2019");
+        properties.put("ssl.key.password", "galaxy2019");
+        properties.put(SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, "");
+
+        Producer<String, String> producer = new KafkaProducer<String, String>(properties);
+
+        producer.send(new ProducerRecord<>("test", "hello!"), new Callback() {
+            @Override
+            public void onCompletion(RecordMetadata metadata, Exception exception) {
+                if (exception != null) {
+                    logger.error("写入test出现异常", exception);
+                }
+            }
+        });
+
+        producer.close();
+    }
+}
diff --git a/src/test/java/com/zdjizhi/LocationTest.java b/src/test/java/com/zdjizhi/LocationTest.java
new file mode 100644
index 0000000..e7b2d15
--- /dev/null
+++ b/src/test/java/com/zdjizhi/LocationTest.java
@@ -0,0 +1,28 @@
+package com.zdjizhi;
+
+import com.zdjizhi.common.FlowWriteConfig;
+import com.zdjizhi.utils.IpLookup;
+import org.junit.Test;
+
+/**
+ * @author qidaijie
+ * @Package com.zdjizhi
+ * @Description:
+ * @date 2021/8/1811:34
+ */
+public class LocationTest {
+    private static IpLookup ipLookup = new IpLookup.Builder(false)
+            .loadDataFileV4("D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\ip_v4.mmdb")
+            .loadDataFileV6("D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\ip_v6.mmdb")
+            .loadDataFilePrivateV4("D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\ip_private_v4.mmdb")
+            .loadDataFilePrivateV6("D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\ip_private_v6.mmdb")
+            .build();
+
+    @Test
+    public void IpLocationTest() {
+        System.out.println(ipLookup.cityLookupDetail("24.241.112.0"));
+        System.out.println(ipLookup.cityLookupDetail("1.1.1.1"));
+        System.out.println(ipLookup.cityLookupDetail("192.168.50.58"));
+        System.out.println(ipLookup.cityLookupDetail("2600:1700:9010::"));
+    }
+}