我的控制器将一个Mono (称为"limit")作为服务参数传递给我的服务。Mono在订阅时发出一个Integer，服务使用该Integer完成其工作，该Integer返回一个Flux。在我的服务方法中，我需要订阅mono --但我需要“在”我的服务方法(它对其他端点进行web客户端REST调用)之前这样做，因为在REST<e
浏览 94提问于2021-04-21得票数 0
Repository}
问题是，在执行save()方法之后，对象中没有任何更改我设法修复了save().block()的问题，但我不知道为什么第一次保存在另一个存储库上，而这个存储库不起作用。为什么需要这个block()？
浏览 0提问于2018-03-07得票数 4
回答已采纳
authentication, String targetType,)
只要您不需要在WebFlux方法中调用反应性服务如果您无论如何都要在此方法中调用一个反应性服务，那么您将需要在某个时候在某些Mono上调用Mono，从而遇到麻烦，因为您是从一个反应性管道中调用的。在关于S
浏览 2提问于2018-05-20得票数 6
我有一个Spring应用程序，在这个应用程序中，我希望为一个耗时的操作生成一个新线程，并且在新线程产生后，立即返回主线程，这样客户端就不会一直等待private Mono</e
浏览 4提问于2022-02-08得票数 0
我是spring data reactive Cassandra的新手。在我的服务类中，我注入了ReactiveCassandraRepository的实现，如果它通过给定的id找到我的pojo，它将返回我的pojo的Mono。private Mono<?我没有得到任何返回任何异常的日志。 上面的getResult方法由我的spri
浏览 128提问于2019-02-07得票数 0
回答已采纳
我有一个存储库调用，它将为我提供Mono。例如： private User getUserData (User user) Mono<User> monoUser=userRepository.insert(user);return user;
} 如何在spring reactive中不阻塞的情况下实现这一点。我不想做monoUser.block来获取用户对象。在获
浏览 696提问于2020-09-08得票数 0
我想通过Spring WebFlux和给定的REST来完成以下操作：
public Mon
浏览 1提问于2019-03-17得票数 5
回答已采纳
1回答
我们正在使用Springboot2.0和reactive spring data cassandra模块。protected void hookOnNext(List<Data> value) { } //cassandra reactive call to get List of data我们面临的问题是，即使
浏览 0提问于2018-03-16得票数 1
我想同时执行3个调用，并在它们都完成后处理结果。但是，AsyncRestTemplate不赞成WebClient。我必须在项目中使用Spring，但我感兴趣的是我是否可以使用WebClient来执行同步调用。有人能建议如何使用WebClient正确地完成这一任务吗？
浏览 12提问于2018-05-06得票数 19
回答已采纳
1回答
我在一个使用spring流量的微服务项目上工作，下面是一些服务：
@PostMapping("/create")
//@PostMapping(produces> orderRequest)
浏览 1提问于2021-05-23得票数 0
回答已采纳
我正在使用Java 8和Spring调用一个基于REST的外部服务器，该服务器也有一个备份服务器。当前，如果在调用服务器时出现故障，则会在没有重试机制的情况下访问备份服务器： MyRestClient myRestClientClientConfig config;
// Getters a
浏览 7提问于2022-09-25得票数 1
回答已采纳
1回答
我有以下类，用于通过web服务调用耗时的操作：public class InferenceService {
private final WebClient(); }如果在web服务调用过程中发生异常，如UnknownHostException，则将其包装在ReactiveException中。我希望我的类捕获原始异常并将其作为HttpEx
浏览 3提问于2018-10-18得票数 3
如何在Spring Webflux中确定抛出哪个异常并从中获取状态代码。这是我的控制器代码的结构。@GetMapping("/") return Service.getResult} 这里我可以得到抛出的自定义消息，但是如何获得状态码呢？而不是HttpStatus.NOT
浏览 49提问于2021-07-05得票数 2
回答已采纳
2回答
我正在编写一个小框架，它将获得jvm中加载的类并调用它的方法。方法参数是基于形参名称生成的。我正在尝试使用反射来获取它的名称。param : params) { }我知道这在jdk8中是可能的如何在jdk6或7中实现这一点？因为，我们的</e
浏览 3提问于2014-09-26得票数 3
1回答
我正在使用spring来消耗彼此的服务，并试图将结果添加到不同输入组合的列表中。但是有一点我无法订阅并将结果转换成列表
输入：
公共Mono<List> getAPrice() {返回Mono.create(monoSink ->
浏览 2提问于2019-10-31得票数 0
回答已采纳
我目前正在做Spring Cloud Gateway，使用自定义的JWT身份验证。在身份验证之后，我想使用GlobalFilter将头部中的JWT令牌字符串传递到下游服务中： public int getOrder() { }JWT令牌字符串可
浏览 76提问于2019-11-23得票数 2
回答已采纳
1回答
最近，我们决定在我们的项目中使用与couchbase一起的spring，我们需要关于如何在反应性编程中解决下面的用例的帮助。在Bucket1 couchbase中验证和保存请求(我们使用了javax.validation和spring ReactiveCouchbaseRepository )。调用外部服务(我们使用webclient调用API。
浏览 0提问于2019-01-03得票数 1
1回答
我有一个类，其中令牌是它的实例变量。我使用的是Spring 5-reactive 8和SpringBoot2。我正在调用令牌服务并获取Mono，并将Mono的属性(accessToken)传递到另一个方法，即getToken()，使用map并尝试将其设置到这个实例变量' token ‘中。当我将此实例变量的值记录如下：
logger.info("Verifying Token:
浏览 1提问于2018-08-10得票数 0
1回答
从Mono返回Java对象
、、、、
我在试着从Mono那里得到Json字符串。我尝试使用block()方法来获取对象--它工作得很好，但是当我使用map/flatmap时，我没有看到下面的代码行是executed.And --我看到帐户Mono不是空的。private String getJsonString( Mono<Account> account) { **// call
浏览 0提问于2020-07-31得票数 5
我有两个微服务。第一个是简单的echo服务，它在延迟3秒后返回。第二个调用first over spring webclient。当我模拟501个并发用户请求第二个微服务时，前500个用户在3秒内得到响应，最后一个用户在6秒内得到响应。意味着spring webclient默认只支持500个并发连接。对应的值可以在apache客户端中配置。但是我找不到如何在spring webclient中
浏览 3提问于2019-12-05得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
