SpringBoot获取http数据、打印HTTP参数的4种方式

更新时间：2024年03月13日 11:17:24 作者：澄风

Java的话本地打断点可以调试获取rest入参,但是在生产环境可能我们获取入参（Http header/parameter）可能就没有那么的轻松了,所以本文给大家介绍了SpringBoot获取http数据、打印HTTP参数的4种方式,需要的朋友可以参考下

Java的话本地打断点可以调试获取rest入参（http header），但是在生产环境可能我们获取入参（Http header/parameter）可能就没有那么的轻松了。我们可能在header中放置了很多自定的参数用来鉴权或者其他用途。如果排查问题的时候需要这些参数，我们有很多种选择去获取这些参数。

输出到应用日志中，比如使用logback,log.error(xxx)
借助nginx 输出到access.log日志中
借助Skywalking/zipkin等中间件输出到链路中
网关日志中输出

1. 输出到应用日志中

我们可以借助Springboot的拦截器在进入rest controller 之前将request header / param 输出出来，在rest controller调用结束之后将response header / param输出。

LogInterceptor
拦截器，注意拦截器和过滤器的区别，过滤器属于Tomcat/Jetty/… Servlet 容器的生命周期维护的，要早于拦截器。过滤器是Springboot维护的拦截，在handler mapping 映射之后先去调用拦截器之后在调用controller。

在这里插入图片描述

拦截器拦截的就是上图4的这部分。

@Component
@Slf4j
public class LogInterceptor extends HandlerInterceptorAdapter {

    private static ThreadLocal<Long> threadLocal = new ThreadLocal<>();

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        threadLocal.set(System.currentTimeMillis());
        log.info("Request uri = [{}], method is: [{}]", request.getRequestURI(), request.getMethod());
        log.info("Request header is : [{}]", parseRequestHeaders(request));
        log.info("Request param is : [{}]", parseParams(request));

        if (request instanceof RequestCustomWrapper) {
            RequestCustomWrapper requestCustomWrapper = (RequestCustomWrapper) request;
            byte[] body = requestCustomWrapper.getBody();
            log.info("Request body is : [{}]", new String(body));
        }

        return super.preHandle(request, response, handler);
    }

    public static String parseParams (HttpServletRequest request) {
        StringBuilder stringBuilder = new StringBuilder();
        Enumeration<String> parameterNames = request.getParameterNames();
        while (parameterNames.hasMoreElements()) {
            String name = parameterNames.nextElement();
            request.getParameter(name);
            stringBuilder.append(name).append("=").append(";");
        }
        return stringBuilder.toString();
    }

    public static String parseRequestHeaders (HttpServletRequest request) {
        StringBuilder stringBuilder = new StringBuilder();
        Enumeration<String> headerNames = request.getHeaderNames();
        while (headerNames.hasMoreElements()) {
            String name  = headerNames.nextElement();
            String value = request.getHeader(name);
            stringBuilder.append(name).append("=").append(value).append(";");
        }
        return stringBuilder.toString();
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        super.afterCompletion(request, response, handler, ex);
    }
}

RequestCustomWrapper
因为Springboot框架规定,Request getInputStream只能获取一次，获取第二次的时候就会报错。所以这个时候需要实现RequestWrapper去包裹Request重写getInputStream实现可重复获取Request Stream。

@Slf4j
public class RequestCustomWrapper extends HttpServletRequestWrapper {

    private byte[] body;

    public byte[] getBody() {
        return body;
    }

    public RequestCustomWrapper(HttpServletRequest request) {
        super(request);
        try {
            body = readBytes(request.getReader());
        } catch (IOException e) {
            log.error("读取request input stream失败..");
        }
    }

    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(getInputStream()));
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {
        try (final ByteArrayInputStream bais = new ByteArrayInputStream(body)) {
            return new ServletInputStream() {
                @Override
                public boolean isFinished() {
                    return false;
                }

                @Override
                public boolean isReady() {
                    return false;
                }

                @Override
                public void setReadListener(ReadListener readListener) {

                }

                @Override
                public int read() throws IOException {
                    return bais.read();
                }
            };
        }

    }

    public byte[] readBytes (BufferedReader br) throws IOException {
        byte[] emptyBytes = new byte[0];
        String str;
        StringBuilder sb = new StringBuilder();
        while ((str = br.readLine()) != null) {
            sb.append(str);
        }

        if (StringUtils.isNotBlank(sb.toString())) {
            return sb.toString().getBytes(StandardCharsets.UTF_8);
        }

        return emptyBytes;
    }
}

RequestCustomFilter
全局过滤器到，在执行到RequestCustomFilter这一层的时候，将ServletRequest包裹替换成自己的Request,实现可重复获取Request Stream.

public class RequestCustomFilter implements Filter {
    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        if (servletRequest instanceof HttpServletRequest) {
            ServletRequest requestWrapper = new RequestCustomWrapper((HttpServletRequest) servletRequest);
            filterChain.doFilter(requestWrapper, servletResponse);
        } else {
            filterChain.doFilter(servletRequest, servletResponse);
        }
    }
}

WebMvcConfig
注册过滤器和拦截器

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new LogInterceptor())
                .addPathPatterns("/**");
    }

    @Bean
    public FilterRegistrationBean<RequestCustomFilter> requestCustomFilter () {
        FilterRegistrationBean<RequestCustomFilter> registrationBean = new FilterRegistrationBean<>();
        RequestCustomFilter requestCustomFilter = new RequestCustomFilter();
        registrationBean.setFilter(requestCustomFilter);
        registrationBean.addUrlPatterns("/*");
        registrationBean.setOrder(1);
        return registrationBean;
    }
}

2.Nginx 配置输出Log

配置方式：

在nginx的配置文件中有个变量：$http_cookie来获取cookie的信息。配置方式很简单，只需要在nginx配置文件的http段，新添加一个log_format就可以了：
nginx.conf

log_format  sendfile  '$remote_addr - $remote_user [$time_local] "$request" '
              '$status $body_bytes_sent "$http_referer" '
              '"$http_user_agent" "$http_x_forwarded_for" "$http_cookie"';

在server.conf中加入

access_log  /var/log/php/access.log sendfile;

配置层级结构

在这里插入图片描述

sendfile 就是上面定义的log_format 的名字，只要acces_log 后面带这个名字的日志，就会按照定义的格式输出日志。

reload一下nginx就可以在日志里面看到cookie信息

nginx  -s  reload

Nginx 变量参考

$remote_addr #存放了客户端的地址，注意是客户端的公⽹IP
$args #变量中存放了URL中的指令http://www.magedu.net/main/index.do?id=090&partner=search以上：id=090&partner=search 即为 $args
$document_root #保存了针对当前资源的请求的系统根⽬录，如/apps/nginx/html
$cookie_name #表⽰key为 name 的cookie值
$document_uri #保存了当前请求中不包含指令的URI，注意是不包含请求的指令，如http://www.magedu.net/main/index.do?id=090&partner=search会被定义为/main/index.do
$host；#存放了请求的host名称
$http_user_agent #客户端浏览器的详细信息
$http_cookie #客户端的cookie信息
$limit_rate #如果nginx服务器使⽤limit_rate配置了显⽰⽹络速率，则会显⽰，如果没有设置，则显⽰0
$remote_port #客户端请求Nginx服务器时客户端随机打开的端⼝
$remote_user #已经经过Auth Basic Module验证的⽤户名
$request_body_file #做反向代理时发给后端服务器的本地资源的名称
$request_method #请求资源的⽅式，GET/PUT/DELETE等
$request_filename #当前请求的资源⽂件的路径名称，由root或alias指令与URI请求⽣成的⽂件绝对路径，

3. 借助Skywalking/zipkin等中间件输出到链路中

4. 网关日志中输出

这里只简单贴一下代码介绍网管如何打印Http信息

@Component
@Slf4j
public class LoggingFilter implements GlobalFilter, Ordered {

    private static final String START_TIME = "START_TIME";

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        String info = String.format("Method: {%s} Host: {%s} Path: {%s} Query: {%s}",
                request.getMethod().name(),
                request.getURI().getHost(),
                request.getURI().getPath(),
                request.getQueryParams());
        log.info(info);
        exchange.getAttributes().put(START_TIME, System.currentTimeMillis());
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            Long start = exchange.getAttribute(START_TIME);
            if (start != null) {
                long executeTime = System.currentTimeMillis() - start;
                log.info(exchange.getRequest().getURI().getRawPath() + ":" + executeTime + "ms");
            }
        }));
    }

    @Override
    public int getOrder() {
        return Ordered.LOWEST_PRECEDENCE;
    }
}

以上就是SpringBoot获取http数据、打印HTTP参数的4种方式的详细内容，更多关于SpringBoot获取、打印http参数的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

IntelliJ IDEA中SpringBoot项目通过devtools实现热部署的方法
这篇文章主要介绍了IntelliJ IDEA中SpringBoot项目通过devtools实现热部署的方法,本文分步骤给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下
2018-08-08
Java四个线程常用函数超全使用详解
这篇文章主要为大家介绍了线程中常用的四个函数：wait()、join()、sleep() 和 yield()，以及这四个函数的使用方法和相互之间的区别，需要的可以参考一下
2022-03-03
分布式框架Zookeeper api的使用介绍
Zookeeper作为⼀个分布式框架，主要用来解决分布式⼀致性问题，它提供了简单的分布式原语，并且对多种编程语⾔提供了API，所以接下来重点来看下Zookeeper的java客户端API使用方式
2022-09-09
SpringBoot中ApplicationEvent和ApplicationListener用法小结
这篇文章介绍SpringBoot中ApplicationEvent用法,注意ApplicationEvent和MQ队列虽然实现的功能相似，但是MQ还是有其不可替代性的，最本质的区别就是MQ可以用于不同系统之间的消息发布，而SpringEvent这种模式只能在一个系统中，需要的朋友可以参考下
2023-03-03
java split()使用方法解析
这篇文章主要介绍了java split()使用方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-02-02
SpringBoot中AOP的动态匹配和静态匹配详解
这篇文章主要介绍了SpringBoot中AOP的动态匹配和静态匹配详解,在创建代理的时候对目标类的每个连接点使用静态切点检查,如果仅通过静态切点检查就可以知道连接点是不匹配的,则在运行时就不再进行动态检查了,需要的朋友可以参考下
2023-09-09
springboot 启动如何修改application.properties的参数
这篇文章主要介绍了springboot 启动如何修改application.properties的参数方法，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-08-08
Java并发编程创建并运行线程的方法对比
这篇文章主要为大家详细介绍了Java并发编程创建并运行线程的方法，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-03-03
SpringBoot this调用@Bean效果详解
这篇文章主要介绍了在一个@Bean方法内，this调用同一个类的@Bean方法会有什么效果，我们可以通过bean的名称、bean的类型或者bean的名称+类型来获取容器中的bean
2023-02-02
如何设计一个安全的API接口详解
在日常开发中,总会接触到各种接口,前后端数据传输接口,第三方业务平台接口,下面这篇文章主要给大家介绍了关于如何设计一个安全的API接口的相关资料,需要的朋友可以参考下
2021-08-08