模块划分

ldt-core/src/main/java/org/springblade/common/config/mq/RabbitConfig.java

@@ -12,7 +12,7 @@ import org.springframework.context.annotation.Configuration;
  * @description:
  * @since: 10/25/21 -- 2:29 PM
  */
-@Configuration
+//@Configuration
 public class RabbitConfig {
 
 	@Bean

ldt-core/src/main/java/org/springblade/risk/log/listener/LdtLogListener.java

@@ -20,13 +20,13 @@ import org.springframework.stereotype.Component;
 @AllArgsConstructor
 public class LdtLogListener {
 
-	private  RabbitTemplate rabbitTemplate;
+//	private  RabbitTemplate rabbitTemplate;
 
 	@Async
 	@EventListener({UsualLogEvent.class})
 	public void saveApiLog(UsualLogEvent event) {
 		String data = JSON.toJSONString(event.getSource());
-		rabbitTemplate.send("LogDirectExchange","LogDirectRouting",new Message(data.getBytes()));
+//		rabbitTemplate.send("LogDirectExchange","LogDirectRouting",new Message(data.getBytes()));
 		System.out.println(data);
 	}
 }

ldt-risk/pom.xml

@@ -114,6 +114,18 @@ under the License.
             <artifactId>bson</artifactId>
             <version>${mongo.version}</version>
         </dependency>
+
+        <!--  糊涂工具包    -->
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.7.15</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.20</version>
+        </dependency>
     </dependencies>
 
     <build>

ldt-risk/src/main/java/org/springblade/resource/RabbitSource.java

@@ -0,0 +1,9 @@
+package org.springblade.resource;
+
+/**
+ * @author: lianghanqiang
+ * @description: rabbitmq connector configuration
+ * @since: 10/26/21 -- 3:56 PM
+ */
+public class RabbitSource {
+}

ldt-risk/src/main/java/org/springblade/sink/MongoSink.java

@@ -1,14 +1,12 @@
 package org.springblade.sink;
 
 import com.mongodb.MongoClient;
-import com.mongodb.MongoClientOptions;
 import com.mongodb.MongoCredential;
 import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
 import org.bson.Document;
-
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
@@ -41,7 +39,7 @@ public class MongoSink extends RichSinkFunction<String> {
 
 			//通过连接认证获取MongoDB连接
 			this.mongoClient = new MongoClient(addrs,credentials);
-			this.mongoDatabase = mongoClient.getDatabase("ldt");
+			
 		}
 		super.open(parameters);
 	}

ldt-risk/src/main/java/org/springblade/utils/MongoUtils.java

@@ -0,0 +1,31 @@
+package org.springblade.utils;
+
+import cn.hutool.core.io.resource.ClassPathResource;
+import com.mongodb.client.MongoClient;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import java.io.IOException;
+import java.util.Properties;
+
+/**
+ * @author: lianghanqiang
+ * @description: mongo 连接工具
+ * @since: 10/26/21 -- 3:53 PM
+ */
+@Data
+@Slf4j
+public class MongoUtils {
+
+	private static MongoClient mongoClient;
+
+	static {
+		ClassPathResource resource = new ClassPathResource("mongo.properties");
+		Properties properties = new Properties();
+
+		try {
+			properties.load(resource.getStream());
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+	}
+}

ldt-risk/src/main/resources/mongo.properties

@@ -0,0 +1,8 @@
+#连接端口
+port=27017
+#用户名
+userName=root
+#密码
+password=123456
+#数据库
+database=ldt