我是一个反应式编程的新手，我也是Spring Webflux的新手，我有一个方法可以从Redis获取一些键，如果这个键是空的或者不等于指定的字符串，我想抛出一个异常，但是嵌套的donOnNext方法不会被调用，customerRepository.save(customer)会被触发，而异常必须被抛出并中断链。verifyCustomerAndGenerateToken(Mono<VerifyOtpReqDTO> verifyOtpReqDTO) {
return verifyOtpR
浏览 85提问于2020-03-04得票数 2
1回答
当我在反应链之外调用subscribe()调用时。它不遵循spring webflux的溢出策略吗？fooRepository.findOne() .flatMap { ... } 我有一个奇怪的行为当服务器繁忙时，可以删除doOnNext内部的subscribe()调用吗？ This post说默认的溢出策略是BUFFER。 doOnNext</
浏览 19提问于2021-01-15得票数 0
我已经尝试了doOnComplete和doOnFinally的外部通量，它不是等待所有内部非阻塞调用完成。因为doOnComplete()方法是在完成所有内部Mono之前调用的。请求机构：-
[{ "content":"Intro to React and operators", "author":"Josh Long", "name":"Spring WebFlux" },{"content&
浏览 0提问于2018-08-16得票数 1
回答已采纳
下面的Kotlin代码成功地连接到Spring WebFlux服务器，发送一条消息并打印通过返回的流发送的每条消息。.then()}
在以前的反应性编程经验中，我总是使用、订阅、或subscribeWith来调用doOnNext。我的问题是，调用doOnNext是否真的是添加处理程序来处理传入消息的正确方式？大多数Spring5教程都显示了代码，这些代码或者称为subscribeWith(outp
浏览 1提问于2018-03-31得票数 0
Reactor提供了将执行上下文转移到不同调度器的可能性，如下所示： Mono.just("test") .publishOn(MY_SCHEDULER)
浏览 55提问于2021-01-25得票数 0
我正在尝试打印一个计数器，它从doOnNext()函数中递增。final AtomicInteger counter = new AtomicInteger(); .doOnNext(i -> System.out.println("doOnNext " + counter.incrementAndGet()))
.map(i -> {因此，我应该期望doOnNext(
浏览 9提问于2021-01-27得票数 1
回答已采纳
我正在使用咖啡因缓存来存储使用webClient WebFlux获得的授权令牌。我在application.yml文件中将expireAfterWrite设置为硬编码值，如下所示： spring: cache-names: accessTokenscaffeine: varput("tokens",
浏览 465提问于2021-01-21得票数 0
@Bean IntegrationFlows
.from(WebFlux.inboundGateway
浏览 29提问于2019-06-24得票数 2
回答已采纳
我有一个具有不同@RestController的现有spring-mvc应用程序。现在我想添加一个Mono<String>端点，并记录带有url路径的请求时间戳以及响应时间戳。 但是怎么做呢？我不能简单地使用@EnableWebFlux，因为我必须为此禁用spring-mvc。 我如何为webflux端点注册显式过滤器，该端点在调用时捕获，并且就在响应被异步写回之前？
浏览 26提问于2020-03-31得票数 1
1回答
我是Spring的新手，我正在读一本书"Pro Spring boot 2“。这里说Spring在每个请求上都有一些阻塞，Spring是一个完全非阻塞的堆栈。
为什么Spring WebFlux不阻止线程？
浏览 9提问于2022-02-05得票数 5
回答已采纳
我使用Spring和Webflux。tuple.getT1())) //
// .doOnNext(agentDataServiceApi::setProtectedResources)
浏览 0提问于2020-07-14得票数 0
回答已采纳
我不断地获得NestedServletException，同时尝试调用接受ServerWebExchange的rest控制器方法。
浏览 2提问于2018-07-15得票数 7
回答已采纳
下面是Spring和WebFlux的代码片段：
return mongoTemplateReactive.find(query, Document.class, COLLECTIONNAME).doOnNext(value -> ctr.incrementAndGet()).因为doOncomplete()被多次调用，所以当它第一次被调用时，它工作得很好，但是在那之后，该块中的任何对象都被空化，我得到了NullPointerException。根据我的理解，doOncomplete()最终只应该被
浏览 10提问于2022-06-07得票数 0
回答已采纳
1回答
反应堆中特殊异常的重试
、、、、
我知道，缺省情况下，spring使用乐观锁。但是，如果这种方法不是由用户调用的，而是由另一个服务调用的(在我的示例中有验证服务，可以将对象的状态更新为有效或非有效)，我希望处理异常并重试更新对象。另外，我还必须在这个微服务上使用webflux堆栈。public void updateStatus(String id, EventStatus status) { .doOnNext
浏览 1提问于2021-10-22得票数 3
回答已采纳
1回答
我有一个旧版本的spring-framework项目。spring-框架版本是3.1.1.RELEASE。我需要导入webflux，但是版本不兼容，所以如果我在pom.xml中添加以下代码： <dependency> <artifactId>spring-webflux</artifactId>
浏览 22提问于2020-08-11得票数 0
控制器被配置为具有spring反应性安全性的服务开发，并且添加了@PreAuthorize注释，使某些端点仅可供满足需求的用户访问。
浏览 1提问于2022-08-04得票数 1
我用Kotlin语言编写了Spring WebFlux的测试客户端和服务器。客户端向服务器发送一个数字(例如4)，并返回多个数字(例如0、1、2和3)。return session.receive() .doOnNextReduce called with $a and $b") }
浏览 1提问于2018-04-03得票数 0
回答已采纳
java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)spring最初创建org.springframework.http.server.reactive.ServletServerHttpResponse并调用response.getOutputStream()时，问题还记录到spring jira以供讨论-
浏览 4提问于2019-01-04得票数 0
我正试图通过webflux将文件传输到第三方服务，并将文件in存储在elasticsearch中。文件被传输和保存，但是id没有附加到实体上。image={}", id, image); .findById(id) })
.flatMap(this::crea
浏览 3提问于2022-06-08得票数 1
回答已采纳
我想要更改spring boot 2的上下文路径，例如，我想在上提供服务它只适用于spring-boot-starter-web
浏览 2提问于2018-03-09得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
