我将 Spring Cloud Gateway 与 Spring 5、Spring Reactor 和 Netty 一起用于一个项目。对于发送到网关的每个请求,我想在响应发送到客户端之前做一些事情。我发现最好的方法是使用 beforeCommit 方法向响应中添加一个操作。
我首先尝试了这种方法:
exchange.getResponse().beforeCommit(() -> {
ServerHttpResponse response = exchange.getResponse();
try {
myActionDoneHere();
response.setStatusCode(OK);
return Mono.empty();
} catch (Exception ex) {
return Mono.error(new MyException(ex));
}
});
并尝试在异常处理程序中处理异常:
public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
if (isMyException(ex)) {
exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
exchange.getResponse().getHeaders().setContentLength(MSG.length());
exchange.getResponse().getHeaders().setContentType(MediaType.APPLICATION_JSON_UTF8);
return exchange.getResponse().writeWith(Mono.just(exchange.getResponse().bufferFactory().wrap(MSG.getBytes())));
}
return Mono.error(ex);
}
当我这样做时,当我尝试修改内容长度时会出现异常。如果我了解情况。我不能再在我的处理程序中修改响应,因为它已经提交了。所以我尝试了另一种解决方案,并尝试在提交之前修改我执行的操作中的响应:
exchange.getResponse().beforeCommit(() -> {
ServerHttpResponse response = exchange.getResponse();
try {
myActionDoneHere();
response.setStatusCode(OK);
return Mono.empty();
} catch (Exception ex) {
response.setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
response.getHeaders().setContentLength(MSG.length());
response.getHeaders().setContentType(MediaType.APPLICATION_JSON_UTF8);
return exchange.getResponse().writeWith(Mono.just(exchange.getResponse().bufferFactory().wrap(MSG.getBytes())));
}
});
这次我没有任何异常,我可以修改内容长度但我不能修改响应的正文。
那么有人知道是否可以这样做以及如何?