1回答
我使用的是spring boot的webflux框架，我试图实现的行为是在数据库中创建一个新客户，如果它还不存在(如果存在则抛出异常)，并维护另一个国家代码数据库(如果新客户来自新国家，则添加到数据库中，如果国家已经保存，则使用旧信息)。这是服务中的函数： public Mono<Customer> createNewCustomer(Customer customer) {
if(!Mono<Country> countryFromDB = countryDB.findByCoun
浏览 42提问于2020-07-05得票数 0
1回答
我想使用反应式编程将我的excel文件存储到数据库中。在非反应式中很容易做到，但我不能在反应式中做类似的事情，我应该写什么来将它存储到我的mongo数据库中？produces = MediaType.APPLICATION_STREAM_JSON_VALUE) return Service.save
浏览 5提问于2021-11-01得票数 1
1回答
作为其中的一部分，我应该跟踪一个简单的对象类型，它有两个字段: ActiveVersion和version。我在redis和mongo中持久化了这个对象。ActiveVersionCacheRepository是一个反应式redis存储库(使用reactiveRedisTemplate)，ActiveVersionRepository是一个反应式mongo(type)}
浏览 9提问于2020-04-27得票数 0
回答已采纳
我在一个项目中工作，其中DDD方法将用于开发，由于业务需求，将使用响应式编程方法。
我正在对域进行建模，当我在存储库的定义上工作时，出现了一些疑问。我在通过适配器实现存储库时看到了问题，因为使用反应式编程，所有方法都会返回Uni或Multi (Mutiny！将被使用)。这是一个问题，因为我在域中引入了与框架的依赖关系，这违反了DDD原则。
浏览 9提问于2021-06-01得票数 3
回答已采纳
我无法将Mono<List<Object>>处理为List<Object>。我在某处读到过可以使用flatmap，但我也不能这样做。我不想在这个场景中使用.block()方法。代码示例可以是：Mono<List<Address>> addressListMono =
Fl
浏览 5提问于2021-10-31得票数 0
1回答
我想实现WebFlux示例客户端，它可以使用http参数发出请求，并获得响应体和http响应代码。我试过这个： public ClientResponse execute(NotificationMessage nm)
Mono<String> transactionMono = Mono.just
浏览 23提问于2019-06-21得票数 1
当应用程序不使用反应式范式时，这个方面就起作用了。但当应用程序返回Mono或Flux时，它不能正常工作。@Around("@annotation(simpleEvent)") } catch (Excep
浏览 3提问于2018-11-04得票数 2
我在body中有一个对象MultiMeasurement，它有一个Status和1 to n测量。 multiMeasurement.map(MultiMeasurement::validate- statusFacade和measurementCollector都以反应式方式保存对象(mongo)并返回
浏览 3提问于2019-05-20得票数 0
我正在使用Spring Boot2.3.0、MongoDB和Kotlin开发一个反应式应用程序。不太可能，我需要使用ReactiveMongoTemplate对象开发一个自定义存储库。由于所有的应用程序都使用Kotlin协程，如果这个存储库也可以使用它们，我将非常高兴。例如，我在Mongo集合上开发了一个简单的更新： override suspend fun addQuantityToStockInAPortfolio(
浏览 21提问于2020-06-13得票数 0
回答已采纳
1回答
我有一大堆对象，我需要使用反应式方法来过滤它们。既然filter不支持反应式类型，我怎么才能做到这一点？Flux<Student> students = ... .filter(this::leavesNearby)
return addressService.isNearby(address);
} 考虑到addressService.isNe
浏览 17提问于2021-06-23得票数 0
回答已采纳
我对反应式编程很陌生。我想为一个反应性的mongo存储库编写一些测试用例。我试图存根一些查询方法，并使用步骤验证器来检查响应，但是我的测试失败了。ItemReactiveRepository.javaMonoItem("ABC", "Samsung TV", 405.0);
浏览 4提问于2020-10-22得票数 0
1回答
面临向反应式REST API添加分页的问题。虽然有一种方法可以将Pageable/PageRequest字段添加到我的请求查询对象中，但它的工作方式与您将页面/大小定义为查询参数的方式不同。只有一种可行的方法-显式地将页面和大小定义为request query对象的单独字段，然后使用PageRequest.of()将其转换为Pageable对象。问题:在Spring MVC中使用Pageable对象作为查询
浏览 2提问于2020-01-17得票数 0
我正在尝试使用Spring Boot中的MongoDB反应式模板以反应式的方式获取UpdateResult。问题是更新部分不会执行，因为我没有订阅它，但我真的不知道如何执行这两个操作，并使用reactive范例返回一个值。这就是我正在尝试的：public Mono<UpdateResult> updateTask(@RequestParam(name="taskId") {Mono
浏览 53提问于2019-07-13得票数 1
回答已采纳
我正在写一个简单的反应式应用程序，使用spring5和mongo反应式存储库。String expectedId = "54759ab3c090d83494e2d804"; Mono<Product> product = productRepository.findById(Mono.just("54759ab3c090d83494e2d
浏览 125提问于2020-02-20得票数 4
1回答
我是第一次接触反应式组件。我用webclient做了一个api调用，响应被包装在一个Mono组件中。有没有办法检查在接收到的单声道组件中分配给对象类的值。接收到的响应被包装在Mono<Abc.class>中。class Abc { private email;}
我想要获取消息、电子邮件、状态中的值。我尝试使用.block()，但收到错误块/blockfirst()/block
浏览 3提问于2020-07-09得票数 0
1回答
我要从Flux/Mono获取对象/对象。我使用 <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webf
浏览 0提问于2018-06-28得票数 1
回答已采纳
2回答
我正在探索使用Spring Webflux进行反应式编程，因此，我试图让我的代码完全无阻塞，以获得反应式应用程序的所有好处。目前，我将Json字符串解析为JsonNode以获取特定值(在本例中为elementId)的方法代码如下所示： }
final String elementId = jsonNode.get("elementId").asText(
浏览 5提问于2019-06-02得票数 1
在阅读了新的spring data casandra文档(here)后，它说现在有了对反应式cassandra的Mono<Slice<T>>支持。因此，我们很高兴从Flux<T>迁移到Mono<Slice<T>>，但有一个问题，我们使用flux.map对流量的数据进行转换，但如果没有分块，这似乎是不可能的。repository.searchLocations(searchFields).map(this::transformLocation); 其中，transf
浏览 11提问于2019-02-18得票数 0
回答已采纳
2回答
在spring数据中，我可以轻松地执行以下查询：在reactive Spring data (MongoDBMono<Page<MyClass>> findByX(String x, Pageable pageable);如果没有有效的方法可以做到这一点，有没有一种方法可以在没有Page的情况
浏览 0提问于2021-06-28得票数 0
嗨，我有一个spring boot webflux应用程序，并使用mongo db作为后端。我想删除与某个查询匹配的所有文档，所以我创建了一个方法然而，ThreadPoolExecutor.java:624)这是否意味着spring data DeleteBy..方法返回的内容不同
浏览 38提问于2019-11-06得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
