public class RequestBodyRoutePredicateFactory extends AbstractRoutePredicateFactory<RequestBodyRoutePredicateFactory.Config> { protected static final Log LOGGER = LogFactory.getLog(RequestBodyRoutePredicateFactory.class); private final List<HttpMessageReader<?>> messageReaders; public RequestBodyRoutePredicateFactory() { super(RequestBodyRoutePredicateFactory.Config.class); this.messageReaders = HandlerStrategies.withDefaults().messageReaders(); } public RequestBodyRoutePredicateFactory(List<HttpMessageReader<?>> messageReaders) { super(RequestBodyRoutePredicateFactory.Config.class); this.messageReaders = messageReaders; } public static final String REQUEST_BODY_ATTR = "requestBodyAttr"; @Override public AsyncPredicate<ServerWebExchange> applyAsync(Config config) { return exchange -> { if (!"POST".equals(exchange.getRequest().getMethodValue())&&!"PUT".equals(exchange.getRequest().getMethodValue())) { return Mono.just(true); } Object cachedBody = exchange.getAttribute(REQUEST_BODY_ATTR); if (cachedBody != null) { try { return Mono.just(true); } catch (ClassCastException e) { if (LOGGER.isDebugEnabled()) { LOGGER.debug("Predicate test failed because class in predicate does not match the cached body object", e); } } return Mono.just(true); } else { return ServerWebExchangeUtils.cacheRequestBodyAndRequest(exchange, (serverHttpRequest) -> ServerRequest.create(exchange.mutate().request(serverHttpRequest).build(), this.messageReaders).bodyToMono(String.class).defaultIfEmpty("").doOnNext((objectValue) -> { if(StringUtils.isBlank(objectValue)){ exchange.getAttributes().put(REQUEST_BODY_ATTR, JSON.toJSONString(exchange.getRequest().getQueryParams())); }else { exchange.getAttributes().put(REQUEST_BODY_ATTR, objectValue); } }).map((objectValue) -> true)); } };
时间: 2024-02-14 20:32:56 浏览: 292
这段代码是一个 Spring Cloud Gateway 的请求体谓词工厂类,用于判断请求的 HTTP 方法是否为 POST 或 PUT,并处理请求的 body 数据。具体可以分为以下几个部分:
1. 继承了 Spring Cloud Gateway 的 AbstractRoutePredicateFactory 抽象类,并实现了 Config 配置类。
2. 在构造函数中初始化了默认的 HttpMessageReader 集合,用于读取请求体中的数据。
3. applyAsync 方法是该类的核心方法,通过异步的方式判断是否满足条件。
4. 判断 HTTP 方法是否为 POST 或 PUT,如果不是则直接返回 true。
5. 如果请求体已经被缓存,则直接返回 true。
6. 如果请求体还没有被缓存,则通过 ServerWebExchangeUtils.cacheRequestBodyAndRequest 方法缓存请求体,并将其转化为 String 类型。
7. 判断请求体是否为空,如果为空,则将请求参数转化为 JSON 字符串并缓存到 REQUEST_BODY_ATTR 中。
8. 如果请求体不为空,则将其缓存到 REQUEST_BODY_ATTR 中。
9. 最后返回 true 表示请求满足条件。
阅读全文
相关推荐
















资源下载链接为:
https://pan.quark.cn/s/d9ef5828b597
在Web开发中,将Canvas内容保存为图片或直接保存页面上的图片是一个常见需求。本文将介绍如何通过JavaScript实现这两种功能。
Canvas是HTML5提供的一个强大的绘图工具,允许开发者通过JavaScript动态绘制图形、文字和图片等。它支持复杂的图形操作,如变换、渐变和阴影等。要将Canvas内容保存为图片,可以使用toDataURL()方法。该方法会将Canvas内容转换为一个数据URL,通常是一个base64编码的PNG或JPEG图像。
以下是一个将Canvas内容保存为图片的函数示例:
在这个函数中,canvas参数是Canvas元素的DOM对象,name参数是保存的图片名称。通过调用toDataURL()方法,我们获取Canvas的图像数据,并创建一个元素。设置href属性为图像数据URL,download属性为文件名,然后模拟点击该链接,浏览器便会开始下载图片。
如果需要保存页面上的一张图片,可以直接操作
元素。假设页面中有一个
元素,其src属性指向要保存的图片,可以使用以下方法:
在这个函数中,img参数是
元素的DOM对象,name是保存的图片名称。通过将a.href设置为图片的src属性,然后触发点击事件,即可实现图片的下载。
需要注意的是,toDataURL()默认生成PNG格式的图片,但也可以通过指定MIME类型(如image/jpeg)来生成其他格式的图片。此外,由于同源策略的限制,如果Canvas绘制的内容来自跨域资源,可能无法正确转换为数据URL。同时,浏览器的安全策略可能会限制download属性的使用,例如在某些情况下不允许非用户交互式触发下载。
总之,JavaScript提供了简单的方法来将Canvas内容



