接入日志

authorize-api-service/pom.xml

@@ -62,5 +62,10 @@
             <version>1.0</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.xy</groupId>
+            <artifactId>xy-log</artifactId>
+            <version>1.0</version>
+        </dependency>
     </dependencies>
 </project>

authorize-start/pom.xml

@@ -29,6 +29,17 @@
             <artifactId>xy-logback</artifactId>
             <version>1.0</version>
         </dependency>
+
+        <dependency>
+            <groupId>org.elasticsearch.client</groupId>
+            <artifactId>elasticsearch-rest-high-level-client</artifactId>
+            <version>7.14.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.elasticsearch</groupId>
+            <artifactId>elasticsearch</artifactId>
+            <version>7.14.0</version>
+        </dependency>
     </dependencies>
 
     <build>

authorize-start/src/main/java/com/xy/StartCloud.java

@@ -1,10 +1,8 @@
 package com.xy;
 
-import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 
 @CloudApplication
-@MapperScan("com.xy.**.mapper")
 public class StartCloud {
 
     public static void main(String[] args) {

authorize-start/src/main/resources/bootstrap-uat.yml

@@ -1,3 +1,8 @@
+spring:
+  mqtt:
+    topics:
+      - {topic: "authorize-log", handler: com.xy.consumer.LogConsumer}
+
 #微服务相关配置
 cloud:
   service:

authorize-start/src/main/resources/bootstrap.yml

@@ -1,6 +1,9 @@
 spring:
   profiles:
     include: cloud
+  mqtt:
+    topics:
+      - {topic: "dev-authorize-log", handler: com.xy.consumer.LogConsumer}
 
 server:
   port: 9052
@@ -10,7 +13,7 @@ cloud:
   center:
     url: 119.96.213.127:9007
     config:
-      shared-configs: redis.yaml,mysql.yaml
+      shared-configs: redis.yaml,mysql.yaml,mqtt.yaml,es.yaml
       name: authorize
   service:
     name: dev-authorize