# webflux-sample

**Repository Path**: coolhank/webflux-sample

## Basic Information

- **Project Name**: webflux-sample
- **Description**: webflux 修改request和Response
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2024-02-10
- **Last Updated**: 2024-02-10

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 揭秘 WebFlux 中如何修改 request/response body

我们的一些企业对于HTTP服务有一些非正常的做法，它们客户端的请求body是加密的，即在服务端需要对请求body进行解密，而服务端响应的body也要求加密。本文就来揭秘这一需求在 WebFlux 中如何实现，我们给 request/response body 均增加一个表示时间戳的字段 start/end 来模拟请求数据解密和响应数据加密，思路如下。

首先我们需要知道，WebFlux 的过滤器/拦截器是统一用 WebFilter 来表示的，与 Spring MVC 类似，对于 application/json 请求，WebFlux 读取 body inputstream 也只能读取一次，对于query params / form-data / form-x-www 请求，可以反复获取。 所以，怎么修改 application/json 请求的 request/response body 是一个难点。网上找遍了例子，大都是错误的例子或是hello demo，完全没法解决本文的需求。经过苦心探索，本人终于找到了解决方案，代码如下。
————————————————

                            版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。

原文链接：https://blog.csdn.net/javahongxi/article/details/116444104

# WebFlux Sample
## Concurrency Model
Both Spring MVC and Spring WebFlux support annotated controllers, but there is a key difference in the concurrency model and the default assumptions for blocking and threads.

In Spring MVC (and servlet applications in general), it is assumed that applications can block the current thread, (for example, for remote calls). For this reason, servlet containers use a large thread pool to absorb potential blocking during request handling.

In Spring WebFlux (and non-blocking servers in general), it is assumed that applications do not block. Therefore, non-blocking servers use a small, fixed-size thread pool (event loop workers) to handle requests.

```
“To scale” and “small number of threads” may sound contradictory but to never block the 
current thread (and rely on callbacks instead) means that you do not need extra threads, 
as there are no blocking calls to absorb.
```

© [hongxi.org](http://hongxi.org) | [web.hongxi.org](http://web.hongxi.org)