ServerWebExchange exchange 进行初始复制

在使用Spring WebFlux时，可以通过ServerWebExchange对象来访问和操作HTTP请求和响应的相关信息。在处理请求之前，exchange对象会被创建并进行初始复制，以便在整个请求-响应周期中传递和使用。

ServerWebExchange的初始复制是为了确保在不同的处理器函数或过滤器中使用相同的请求和响应对象，以便进行统一的处理和修改。这样可以保证各个处理器函数或过滤器之间的数据一致性，并且可以避免并发访问时的竞态条件。

初始复制的过程会创建一个新的ServerWebExchange对象，该对象包含了原始的HTTP请求和响应对象的副本。这个副本可以在处理链中的各个环节中传递和修改，而不会影响到原始的请求和响应对象。

在Spring WebFlux中，可以通过exchange对象来获取请求信息、设置响应信息、获取请求头和参数、获取路径变量等操作。通过对exchange对象的操作，可以实现对HTTP请求和响应的灵活控制和处理。

需要注意的是，ServerWebExchange对象是不可变的，即一旦创建就不能再直接修改其内部状态。如果需要对exchange对象进行修改，需要使用一些辅助类或方法来创建一个新的ServerWebExchange对象，并在新对象上进行修改操作。

相关问题

重写DefaultErrorAttributes的storeErrorInformation(Throwable error, ServerWebExchange exchange)方法，怎么获取http响应状态码

要获取Http响应状态码，可以通过ServerWebExchange对象的getResponse()方法获取到响应对象，然后再通过响应对象的getStatusCode()方法获取到状态码。具体可以参考以下代码：

import org.springframework.boot.web.error.ErrorAttributeOptions;
import org.springframework.boot.web.reactive.error.DefaultErrorAttributes;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.server.ServerWebExchange;

import java.util.Map;

@Component
public class CustomErrorAttributes extends DefaultErrorAttributes {

    @Override
    public Map<String, Object> getErrorAttributes(ServerRequest request, ErrorAttributeOptions options) {
        Map<String, Object> errorAttributes = super.getErrorAttributes(request, options);
        // 自定义错误属性
        errorAttributes.put("custom", "custom");
        return errorAttributes;
    }

    @Override
    public void storeErrorInformation(Throwable error, ServerWebExchange exchange) {
        super.storeErrorInformation(error, exchange);
        // 获取响应状态码
        HttpStatus httpStatus = exchange.getResponse().getStatusCode();
        // 在控制台输出状态码
        System.out.println("响应状态码：" + httpStatus.value());
        // 在自定义的错误属性中添加状态码
        exchange.getAttributes().put("status", httpStatus.value());
    }
}

在以上代码中，重写了DefaultErrorAttributes的storeErrorInformation方法，通过ServerWebExchange对象获取到响应对象，再通过响应对象的getStatusCode()方法获取到状态码。然后将状态码添加到自定义的错误属性中，以便后续处理。

ServerWebExchange

要获取HTTP请求的body，可以使用以下步骤：

1. 从HTTP请求中获取请求体的长度（Content-Length）。

2. 读取请求体的内容。

3. 将请求体的内容转换为字符串或其他格式。

在使用ServerWebExchange获取HTTP请求的body时，可以使用以下代码：

public Mono<Void> handle(ServerWebExchange exchange) {
    return exchange.getRequest().getBody()
            .map(dataBuffer -> {
                byte[] bytes = new byte[dataBuffer.readableByteCount()];
                dataBuffer.read(bytes);
                DataBufferUtils.release(dataBuffer);
                return bytes;
            })
            .map(bytes -> {
                String body = new String(bytes, StandardCharsets.UTF_8);
                // 处理请求体
                return body;
            })
            .then();
}

这段代码中，我们使用`exchange.getRequest().getBody()`方法获取请求体的`Flux<DataBuffer>`，然后使用`map`操作符将`DataBuffer`转换为字节数组，再将字节数组转换为字符串。最后，我们可以在`map`操作符中处理请求体的内容。