您的位置:首页 > 汽车 > 新车 > 社交app定制_建筑设计加盟分公司_广告推广渠道有哪些_seo需要付费吗

社交app定制_建筑设计加盟分公司_广告推广渠道有哪些_seo需要付费吗

2025/5/1 21:32:20 来源:https://blog.csdn.net/endergo/article/details/147641045  浏览:    关键词:社交app定制_建筑设计加盟分公司_广告推广渠道有哪些_seo需要付费吗
社交app定制_建筑设计加盟分公司_广告推广渠道有哪些_seo需要付费吗

说明

在「使用 Solon Cloud Gateway 替换Spring Cloud Gateway 」的文章中,有评论说不知道响应式。当时看的是

Solon Cloud Gateway 使用响应式接口,由 Solon-Rx 来实现,是基于 reactive-streams 封装的 RxJava 极简版。目前仅一个接口 Completable,所以当时以为实现了 ExFilter 返回 Completable 就是响应式了。后续 Solon Cloud Gateway 继续更新文档之后才发现,虽然网关是响应式了,但如果逻辑涉及 IO 或者比较慢的操作,需要在 ExFilter 中开启异步接口,这样才是真正的异步,从而避免对网关的事件循环器造成影响,减少对响应式的性能的伤害。

为了对接同步 IO 接口,Solon 3.2.1 提供了 CloudGatewayFilterSync,用于简化异步调用的编写。

基础版

//同步过滤器(会自动转异步)
@FunctionalInterfacepublic interface ExFilterSync extends ExFilter {@Overridedefault Completable doFilter(ExContext ctx, ExFilterChain chain) {return Completable.create(emitter -> {//暂停接收流ctx.pause();//开始异步RunUtil.async(() -> {try {//开始同步处理boolean isContinue = doFilterSync(ctx);if (isContinue) {//继续chain.doFilter(ctx).subscribe(emitter);} else {//结束emitter.onComplete();}} catch (Throwable ex) {emitter.onError(ex);}});});}/*** 执行过滤同步处理(一般用于同步 io)** @param ctx 上下文* @return 是否继续*/boolean doFilterSync(ExContext ctx) throws Throwable;
}

这个 doFilter 的过程中需要自己先处理 ctx.pause,然后开启异步,并在开启的过程中判断是否异常的提交等等,需要写好这个 ExFitler 的扩展还是有点不容易的。

于是作者又贴心的提供了CloudGatewayFilterSync

简化版

@Component(index = -9)
public class AuthFilterSync implements CloudGatewayFilterSync {@InjectAuthJdbcService authService;@Overridepublic boolean doFilterSync(ExContext ctx) throws Throwable {String userId = ctx.rawQueryParam("userId");//检测路径权限return authService.check(userId, ctx.rawPath());}
}

在简化的版本中,只需要在 doFilterSync 中编写具体的逻辑,而不要关心流的暂停和开启异步等。如果已经处理完毕,不需要继续执行返回 ture,否则返回 false。

参考

https://solon.noear.org/article/813

https://solon.noear.org/article/1005

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com