如何修改response的header和body

shenyu是基于 webflux 的响应式编程项目，由于之前没有接触过，我在开发 modifyResponse插件的时候，开始有点摸不着头脑，然后大佬推荐了一个链接：
https://htmlpreview.github.io/?https://github.com/get-set/reactor-core/blob/master-zh/src/docs/index.html

看完我对响应性编程有了初步的了解。

修改header

ServerHttpResponse response = exchange.getResponse();
HttpHeaders httpHeaders = response.getHeaders();
2.HttpHeaders提供了 add、set、addAll、remove 等函数来操作数据。
 
if (Objects.nonNull(modifyResponseRuleHandle.getAddHeaders()) && MapUtils.isNotEmpty(modifyResponseRuleHandle.getAddHeaders())) {
 	Map<String, String> addHeaderMap = modifyResponseRuleHandle.getAddHeaders();
    addHeaderMap.entrySet().stream().forEach(a -> httpHeaders.add(a.getKey(), a.getValue()));
if (Objects.nonNull(modifyResponseRuleHandle.getSetHeaders()) && MapUtils.isNotEmpty(modifyResponseRuleHandle.getSetHeaders())) {
    Map<String, String> setHeaderMap = modifyResponseRuleHandle.getSetHeaders();
    setHeaderMap.entrySet().stream().forEach(a -> httpHeaders.set(a.getKey(), a.getValue()));
if (Objects.nonNull(modifyResponseRuleHandle.getReplaceHeaderKeys()) && MapUtils.isNotEmpty(modifyResponseRuleHandle.getReplaceHeaderKeys())) {
    Map<String, String> replaceHeaderMap = modifyResponseRuleHandle.getReplaceHeaderKeys();
    replaceHeaderMap.entrySet().stream().forEach(a -> {
        httpHeaders.addAll(a.getValue(), httpHeaders.get(a.getKey()));
        httpHeaders.remove(a.getKey());
    });
if (Objects.nonNull(modifyResponseRuleHandle.getRemoveHeaderKeys()) && !CollectionUtils.isEmpty(modifyResponseRuleHandle.getRemoveHeaderKeys())) {
    Set<String> removeHeaderList = modifyResponseRuleHandle.getRemoveHeaderKeys();
    removeHeaderList.stream().forEach(a -> httpHeaders.remove(a));
修改statusCode
 
1.获取ClientResponse
 
ClientResponse clientResponse = exchange.getAttribute(Constants.CLIENT_RESPONSE_ATTR);
2.设置code
 
response.setStatusCode(HttpStatus.valueOf(modifyResponseRuleHandle.getStatusCode()));
修改body
 
这一步是最难的，我也是请教了大佬才解决的问题。
 
关键点是自定义一个类 ModifyServerHttpResponse 继承 ServerHttpResponseDecorator ，然后重写 writeWith 函数。然后从 DataBuffer 里读出 body 的内容，修改完再写回去。
 
1.执行入口
 doExecute（）最后调用 ModifyServerHttpResponse 的初始化
 
 return chain.execute(exchange.mutate()
                .response(new ModifyServerHttpResponse(exchange, modifyResponseRuleHandle)).build());
2.WebClientMessageWriter 在 writeWith 的时候，会走到子类的重写函数里
 
 return response.writeWith(clientResponse.body(BodyExtractors.toDataBuffers())).doOnCancel(() -> clean(exchange));
3.重写 body ，这一块有参考 SpringCloudGateway
 
public Mono<Void> writeWith(@NonNull final Publisher<? extends DataBuffer> body) {
   HttpHeaders httpHeaders = new HttpHeaders();
   httpHeaders.setContentType(MediaType.APPLICATION_JSON);
 	//重新生成response
    ClientResponse clientResponse = prepareClientResponse(body, httpHeaders);
    //修改body里的内容，并返回Mono字节流
    Mono<byte[]> modifiedBody = clientResponse.bodyToMono(byte[].class)
            .flatMap(originalBody -> Mono.just(updateResponse(originalBody)));
	//生成BodyInserter
    BodyInserter<Mono<byte[]>, ReactiveHttpOutputMessage> bodyInserter =
            BodyInserters.fromPublisher(modifiedBody, byte[].class);
    //保存body的信息
    CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange,
            exchange.getResponse().getHeaders());
    //把body写回resposne        
    return bodyInserter.insert(outputMessage, new BodyInserterContext()).then(Mono.defer(() -> {
        Mono<DataBuffer> messageBody = DataBufferUtils.join(outputMessage.getBody());
        HttpHeaders headers = getDelegate().getHeaders();
        if (!headers.containsKey(HttpHeaders.TRANSFER_ENCODING)
                || headers.containsKey(HttpHeaders.CONTENT_LENGTH)) {
            //重写body的长度
            messageBody = messageBody.doOnNext(data -> headers.setContentLength(data.readableByteCount()));
        return getDelegate().writeWith(messageBody);
    }));
因为body的内容可能是多层级的，例如
 
    "code":0,
    "msg":"sucess",
    "data":{
        "nameInfo":{
            "name":"test"
        "body":{
            "age":"18"
所以修改 body 内容，用的是 JsonPath，需要在插件的 pom 文件里加上下面的依赖
 
<dependency>
            <groupId>com.jayway.jsonpath</groupId>
            <artifactId>json-path</artifactId>
            <version>2.4.0</version>
        </dependency>
具体代码，可以参考 shenyu 的代码仓库 https://github.com/apache/incubator-shenyu
 里面的 shenyu-plugin-modify-reponse 模块
                    如何修改response的header和body如何修改response的header和body修改header修改statusCode修改body如何修改response的header和bodyshenyu是基于 webflux 的响应式编程项目，由于之前没有接触过，我在开发 modifyResponse插件的时候，开始有点摸不着头脑，然后大佬推荐了一个链接：https://htmlpreview.github.io/?https://github.com/get-set/reactor-core/
				
BLE(Bluetooh Low Energy)蓝牙低能耗本身是为了尽可能的节省电池电量，因此采样间歇式的收发机制，每次传输的数据量非常小，对于ATT来说，典型的是20字节，虽然后续版本的数据量有所增加，但设备厂商有不同的实现方式，设备具体支持多长的数据发送，还是需要应用层做兼容适配，这无疑增加了开发的工作量。本文主要探讨的是如何提高BLE 4.0版本下的数据传输率。
通常情况下，BLE传输数据量非常小， 有时候几百毫秒、甚至几秒十几秒才会发送一次用户数据，例如实时温度监控，智能穿戴设备的心率，计步上传等，
Write without Response：
{XX_UUID, PERM(WRITE_COMMAND, ENABLE) | PERM(WR, ENABLE) , PERM(RI, ENABLE) | sizeof(uint8_t)*Length}
Write:
{XX_UUID, PERM(WR, ENABLE) |PERM(WRITE_REQ, ENABLE), PERM(RI, ENABLE) | sizeof(ui.
				
这篇博文的内容主要是一些数据包的格式，包括FPGA SRIO端最重要的逻辑层数据包格式HELLO格式，此外还有数据最终的格式，也就是通过高速串口发送出去的包的格式。
这篇博文在参考了数据手册以及博文：Xilinx RapidIO核仿真与包时序分析的基础之上，通过仿真提取时刻需要查询的内容而作。
在此十分干些上述博文的作者，他是我见过的对SRIO数据手册翻译的最好的作者。
这篇博文的最后，我也附上了他的链接，虽然素未蒙面，但是我真的很感谢他。
				
需求背景：与客户端通信内容需要加密。客户端将请求参数进行加密，服务端对响应结果进行加密。
那么对于后端而言，最方便的就是在过滤器里面对请求、响应进行统一处理了。这里需要涉及到HttpServletRequestWrapper与HttpServletResponseWrapper。
# 【1】请求处理
如下所示ParameterRequestWrapper 继承自HttpServletRequestWrapper ，重写获取参数的方法。
```java
 * Created by jianggc 
				
我们的一些企业对于HTTP服务有一些非正常的做法，它们客户端的请求body是加密的，即在服务端需要对请求body进行解密，而服务端响应的body也要求加密。本文就来揭秘这一需求在 WebFlux 中如何实现，我们给 request/response body 均增加一个表示时间戳的字段 start/end 来模拟请求数据解密和响应数据加密，思路如下。
首先我们需要知道，WebFlux 的过滤器/拦截器是统一用WebFilter 来表示的，与 Spring MVC 类似，对于 application/js.
				
1.我们在实际开发中由网关路由到业务系统处理后返回响应报文。对于返回小内容响应报文通过super.writeWith(fluxBody.map(dataBuffer -> {}))是没有问题的,
但有时业务系统需要返回过大的响应报文的时候就有问题了，fluxBody返回体会存在分段传输，从而导致返回的json报文只有一半，前端无法解析而导致错误。
解决方案如下：
既然返回内容过大存在分段传...
				
gateway获取、修改客户端请求Request的参数，我们在上一篇已经讲过了。那么网关发起请求后，微服务返回回来的response的值，还是要经过网关才发给客户端的。很多时候，我们希望能看到响应的值，或者修改它。那么怎么做呢？
import org.reactivestreams.Publisher;
import org.springframework.cloud.gateway.filt...
1. 使用 Nginx 的 ngx_http_lua_module 模块解析请求体
首先需要安装 ngx_http_lua_module 模块，然后在 Nginx 配置文件中添加以下配置：
location /test {
    content_by_lua_block {
        ngx.req.read_body()
        local args, err = ngx.req.get_post_args()
        if not args then
            ngx.say("failed to get post args: ", err)
            return
        ngx.say("args: ", cjson.encode(args))
上述配置中，`ngx.req.read_body()` 用于读取请求体，`ngx.req.get_post_args()` 用于解析请求体中的 POST 参数，如果是 JSON 格式的请求体，可以使用 `ngx.req.get_body_data()` 获取原始的请求体数据，然后使用 JSON 库进行解析。
2. 使用 Nginx 的 ngx_http_echo_module 模块解析请求体
ngx_http_echo_module 模块可以让 Nginx 支持类似于 PHP 中 $_POST 的功能。需要安装 ngx_http_echo_module 模块，然后在 Nginx 配置文件中添加以下配置：
location /test {
    echo_request_body;
上述配置中，`echo_request_body` 指令用于输出请求体中的所有参数。如果只想输出某个参数，可以使用 `echo_request_body_var` 指令，例如：
location /test {
    echo_request_body_var name; # 输出 name 参数的值
在 Java 的 Servlet 中，可以使用 HttpServletRequest 对象获取请求参数、请求头和请求体。以下是示例代码：
```java
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    // 获取参数
    String name = request.getParameter("name");
    String age = request.getParameter("age");
    // 获取请求头
    String userAgent = request.getHeader("User-Agent");
    // 获取请求体
    BufferedReader reader = request.getReader();
    StringBuilder sb = new StringBuilder();
    String line = null;
    while ((line = reader.readLine()) != null) {
        sb.append(line);
    String body = sb.toString();
    // 处理请求
    // ...
    // 返回响应
    response.setContentType("text/html;charset=utf-8");
    PrintWriter out = response.getWriter();
    out.println("Hello, " + name);
    out.flush();
    out.close();
在上述代码中，`request.getParameter()` 方法用于获取参数，`request.getHeader()` 方法用于获取请求头，`request.getReader()` 方法用于获取请求体的字符流，可以通过读取字符流获取请求体的内容。