【情报二期】数据域服务 - 新增War包方式部署适配代码

src/main/java/com/hhwy/QBEQSJYApplication.java

@@ -3,18 +3,12 @@ package com.hhwy;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
-import org.springframework.boot.builder.SpringApplicationBuilder;
-import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 
+@EnableScheduling
 @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
-public class QBEQSJYApplication /*extends SpringBootServletInitializer*/ {
-
-    /*@Override
-    protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {
-        // 指向原始启动类
-        return builder.sources(QBEQSJYApplication.class);
-    }*/
+public class QBEQSJYApplication {
 
     public static void main(String[] args)
     {

src/main/java/com/hhwy/QBEQSJYServletInitializer.java

@@ -0,0 +1,18 @@
+package com.hhwy;
+
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+
+
+/**
+ * web容器中进行部署
+ */
+public class QBEQSJYServletInitializer extends SpringBootServletInitializer {
+
+    @Override
+    protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {
+        // 指向原始启动类
+        return builder.sources(QBEQSJYApplication.class);
+    }
+
+}

src/main/java/com/hhwy/qbeqsjy/kafka/service/ConsumeService.java

@@ -87,9 +87,8 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
             if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
                 try {
 //                    this.dataConsume();
-                    log.info("调用数据消费方法了......");
                 } catch (Exception e) {
-                    log.error("【QBEQSJYCTRL】 数据处理服务启动异常", e);
+                    log.error("【QBEQSJYCTRL】 数据消费服务发生异常", e);
                 }
             }
         });
@@ -103,7 +102,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                 log.info("kafka集群已开启安全模式");
                 AuthService.securityPrepare();
             } catch (IOException e) {
-                log.error("kafka集群安全认证失败，异常信息 : {}.", e);
+                log.error("kafka集群安全认证失败，异常信息：" + e);
                 return;
             }
             log.info("kafka集群安全认证成功");