Tag: spring webflux

如何在spring-webflux WebFilter中正确使用slf4j MDC: 我引用了文章Postual Logging with Reactor Context and MDC但我不知道如何在WebFilter中访问reactor上下文。 @Component public class RequestIdFilter implements WebFilter { @Override public Mono filter(ServerWebExchange exchange, WebFilterChain chain) { List myHeader = exchange.getRequest().getHeaders().get(“X-My-Header”); if (myHeader != null && !myHeader.isEmpty()) { MDC.put(“myHeader”, myHeader.get(0)); } return chain.filter(exchange); } }

如何在Spring Webflux / WebClient中设置事件循环池大小？: 在Vert.X等多反应堆框架中，我们可以设置事件循环线程的数量，例如： final VertxOptions vertxOptions = new VertxOptions(); vertxOptions.setEventLoopPoolSize(16); final Vertx myVertx = Vertx.vertx(vertxOptions); 如何在Spring Boot 2 WebFlux / WebClient中进行等效操作？

WebFlux的证书认证？: 在Spring Boot Web的常规Servlet API中，有HttpSecurity配置的.x509() 。但是在WebFlux的ServerHttpSecurity我找不到类似的东西。 .x509().subjectPrincipalRegex(…)等效的.x509().subjectPrincipalRegex(…) 最终目标是将证书主题作为发送到ReactiveUserDetailsService的用户名获取。

在Spring WebFlux webclient中设置超时: 我正在使用Spring Webflux WebClient从我的Spring启动应用程序进行REST调用。并且每次在30秒内超时。这是我试图在Spring webfulx的WebClient中设置套接字超时的一些代码。 – ReactorClientHttpConnector connector = new ReactorClientHttpConnector(options -> options .option(ChannelOption.SO_TIMEOUT, 600000).option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 600000)); – ReactorClientHttpConnector connector = new ReactorClientHttpConnector( options -> options.afterChannelInit(chan -> { chan.pipeline().addLast(new ReadTimeoutHandler(600000)); })); – ReactorClientHttpConnector connector1 = new ReactorClientHttpConnector(options -> options .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 600000).afterNettyContextInit(ctx -> { ctx.addHandlerLast(new ReadTimeoutHandler(600000, TimeUnit.MILLISECONDS)); })); 并尝试使用“clientConnector”方法在“WebClient”中添加上面的连接器设置。并且还尝试将超时设置如下： webClient.get().uri(builder -> builder.path(“/result/{name}/sets”) .queryParam(“q”, “kind:RECORDS”) .queryParam(“offset”, […]

Spring MVC（async）vs Spring WebFlux: 我正在尝试了解Spring WebFlux。到目前为止我发现的东西都是内核反应，没有Servlet API，每个请求没有线程，HTTP 2，服务器推送，应用程序/流+ json。但是Spring MVC中的异步调用有什么区别？我的意思是在Spring MVC中，当你返回Future，DefferedResult等时，你会在一个单独的线程中执行请求处理程序（控制器方法）中的逻辑，因此你也可以从保存线程池资源中获益，以便调度请求。那么请你强调与此相关的差异？为什么WebFlux在这里更好？非常感谢你的时间！