Pārlūkot izejas kodu

引入了打印请求与返回值的拦截器

lifuquan 1 gadu atpakaļ
vecāks
revīzija
cebf9ca013

+ 1 - 1
doc/开发部署文档/esb_socket放开的http接口.md

@@ -8,7 +8,7 @@ Content-Type: application/json
 
 {
   "city": "111",
-  "kfsn": "kfsn202305221002",
+  "kfsn": "kfsn202305241127",
   "acceptNo": "1",
   "custLevel": "2",
   "pkgName": "3",

+ 5 - 0
pom.xml

@@ -29,6 +29,11 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.nokia</groupId>
+            <artifactId>request-log-interceptor-starter</artifactId>
+            <version>1.0</version>
+        </dependency>
         <!-- 引入netty框架 -->
         <dependency>
             <groupId>io.netty</groupId>

+ 1 - 1
src/main/java/com/nokia/EsbSocketApplication.java → src/main/java/com/nokia/esb_socket/EsbSocketApplication.java

@@ -1,4 +1,4 @@
-package com.nokia;
+package com.nokia.esb_socket;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

+ 1 - 1
src/main/java/com/nokia/common/http/R.java → src/main/java/com/nokia/esb_socket/common/http/R.java

@@ -1,4 +1,4 @@
-package com.nokia.common.http;
+package com.nokia.esb_socket.common.http;
 
 import java.util.HashMap;
 import java.util.Map;

+ 33 - 0
src/main/java/com/nokia/esb_socket/config/RequestLogConfiguration.java

@@ -0,0 +1,33 @@
+package com.nokia.esb_socket.config;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.autoconfigure.web.servlet.DispatcherServletAutoConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.DispatcherServlet;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+import com.nokia.request_log.interceptor.RequestLogHandlerInterceptor;
+import com.nokia.request_log.servlet.RequestLogDispatcherServlet;
+
+@Configuration
+public class RequestLogConfiguration implements WebMvcConfigurer {
+    /**
+     * 添加拦截器
+     */
+    @Override
+    public void addInterceptors(InterceptorRegistry registry) {
+        // 添加日志拦截器
+        registry.addInterceptor(new RequestLogHandlerInterceptor()).addPathPatterns("/**");
+    }
+
+    /**
+     * 注入自定义的RequestLogDispatcherServlet替代默认的DispatcherServlet
+     */
+    @Bean
+    @Qualifier(DispatcherServletAutoConfiguration.DEFAULT_DISPATCHER_SERVLET_BEAN_NAME)
+    public DispatcherServlet dispatcherServlet() {
+        return new RequestLogDispatcherServlet();
+    }
+}

+ 4 - 4
src/main/java/com/nokia/controller/EsbSocketController.java → src/main/java/com/nokia/esb_socket/controller/EsbSocketController.java

@@ -1,13 +1,13 @@
-package com.nokia.controller;
+package com.nokia.esb_socket.controller;
 
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import com.nokia.common.http.R;
-import com.nokia.pojo.TousuSheet;
-import com.nokia.service.EsbNettyService;
+import com.nokia.esb_socket.common.http.R;
+import com.nokia.esb_socket.pojo.TousuSheet;
+import com.nokia.esb_socket.service.EsbNettyService;
 
 @RestController
 @RequestMapping("/esb/socket")

+ 1 - 1
src/main/java/com/nokia/pojo/TousuSheet.java → src/main/java/com/nokia/esb_socket/pojo/TousuSheet.java

@@ -1,4 +1,4 @@
-package com.nokia.pojo;
+package com.nokia.esb_socket.pojo;
 
 import lombok.Data;
 

+ 5 - 5
src/main/java/com/nokia/service/EsbNettyService.java → src/main/java/com/nokia/esb_socket/service/EsbNettyService.java

@@ -1,4 +1,4 @@
-package com.nokia.service;
+package com.nokia.esb_socket.service;
 
 import java.nio.charset.StandardCharsets;
 import java.util.concurrent.CompletableFuture;
@@ -12,10 +12,10 @@ import org.springframework.stereotype.Service;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.nokia.pojo.TousuSheet;
-import com.nokia.service.handler.AuthHandler;
-import com.nokia.service.handler.HeartbeatHandler;
-import com.nokia.service.handler.MessagePrintHandler;
+import com.nokia.esb_socket.pojo.TousuSheet;
+import com.nokia.esb_socket.service.handler.AuthHandler;
+import com.nokia.esb_socket.service.handler.HeartbeatHandler;
+import com.nokia.esb_socket.service.handler.MessagePrintHandler;
 
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.Channel;

+ 1 - 1
src/main/java/com/nokia/service/handler/AuthHandler.java → src/main/java/com/nokia/esb_socket/service/handler/AuthHandler.java

@@ -1,4 +1,4 @@
-package com.nokia.service.handler;
+package com.nokia.esb_socket.service.handler;
 
 import java.util.concurrent.CompletableFuture;
 

+ 1 - 1
src/main/java/com/nokia/service/handler/HeartbeatHandler.java → src/main/java/com/nokia/esb_socket/service/handler/HeartbeatHandler.java

@@ -1,4 +1,4 @@
-package com.nokia.service.handler;
+package com.nokia.esb_socket.service.handler;
 
 import io.netty.channel.ChannelDuplexHandler;
 import io.netty.channel.ChannelHandlerContext;

+ 1 - 1
src/main/java/com/nokia/service/handler/MessagePrintHandler.java → src/main/java/com/nokia/esb_socket/service/handler/MessagePrintHandler.java

@@ -1,4 +1,4 @@
-package com.nokia.service.handler;
+package com.nokia.esb_socket.service.handler;
 
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;

+ 2 - 2
src/test/java/com/nokia/EsbSocketApplicationTest.java

@@ -10,8 +10,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.nokia.pojo.TousuSheet;
-import com.nokia.service.EsbNettyService;
+import com.nokia.esb_socket.pojo.TousuSheet;
+import com.nokia.esb_socket.service.EsbNettyService;
 
 @SpringBootTest
 public class EsbSocketApplicationTest {