在DTO响应中使用Flux
DTO是数据传输对象（Data Transfer Object）的缩写，是一种用于在不同层间传输数据的对象。它通常用于将数据库中的数据转换为前端或其他系统能够理解的形式，以便进行传输。
Flux是一种用于构建用户界面的应用程序架构，它由Facebook提出。它通过将应用程序的状态存储在一个中央存储区域（也称为store）中，并使用单向数据流来管理状态的变化和更新。Flux的核心概念包括动作（actions）、调度器（dispatcher）、存储区域（store）和视图（view）。
在DTO响应中使用Flux，意味着在数据传输对象的响应中，采用Flux架构来管理和更新数据状态。这样可以使得响应的数据更加可靠和一致，并提供了更好的用户体验。
使用Flux的优势包括：
- 简化数据流：Flux的单向数据流模型使数据流动更加可控和明确，减少了数据流的复杂性。
- 高效管理状态：Flux的中央存储区域（store）可以集中管理和更新应用程序的状态，提供了更高效的状态管理机制。
- 可扩展性：由于Flux的组件之间通过动作（actions）进行通信，各个组件之间的耦合度降低，使得应用程序更具可扩展性。
- 更好的调试和测试：Flux的单向数据流模型使得应用程序的调试和测试更加容易和可靠。
在实践中，可以使用以下腾讯云相关产品和服务来支持在DTO响应中使用Flux：
- 腾讯云服务器（CVM）：用于部署和运行应用程序后端。
- 腾讯云数据库（TencentDB）：用于存储和管理应用程序的数据。
- 腾讯云对象存储（COS）：用于存储和管理应用程序的静态资源文件。
- 腾讯云容器服务（TKE）：用于部署和管理应用程序的容器化组件。
- 腾讯云API网关（API Gateway）：用于构建和管理应用程序的API接口。
- 腾讯云CDN（Content Delivery Network）：用于加速应用程序的静态资源文件的分发。
- 腾讯云云函数（SCF）：用于实现应用程序的无服务器计算能力。
参考链接：
- 数据传输对象（DTO）：https://cloud.tencent.com/document/product/876/30603
- Flux架构：https://cloud.tencent.com/document/product/1219/44214
- 腾讯云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 腾讯云数据库（TencentDB）：https://cloud.tencent.com/product/cdb
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云API网关（API Gateway）：https://cloud.tencent.com/product/apigateway
- 腾讯云CDN（Content Delivery Network）：https://cloud.tencent.com/product/cdn
- 腾讯云云函数（SCF）：https://cloud.tencent.com/product/scf
相关·内容
我有一个DTO如下：
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import reactor.core.publisher.Flux;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class InternetPackageDto {
private String id;
private String name;
private String termsAndCondition
浏览 8提问于2021-05-13得票数 0
我有一个字符串流，应该转换为dto的Flux。解析可以用一个错误来完成，根据业务规则，我只需要跳过这样的条目
如果我使用"Kotlin's“null -我得到了NPE，因为按设计，反应堆不接受.map中的空值
fun toDtoFlux(source:Flux<String>):Flux<Dto>{
source.map(Parser::parse)
.filter(it!=null)
}
object Parser{
fun parse(line:String):Dto?{
..
}
}
我可以随意选择。但这
浏览 4提问于2021-01-12得票数 1
回答已采纳
1回答
我有多个列表作为Flux对象，它们来自不同的数据库查询。现在我想创建一个对象，我可以在其中放入我所有的Flux对象并将其返回给客户端。
示例：
public Mono<TestDto> getOverview() {
Flux<TestResult> a = repo.findA();
Flux<TestResult> b = repo.findB();
Flux<TestResult> c = repo.findC();
Flux<TestResult> d = repo.fi
浏览 18提问于2021-03-08得票数 0
回答已采纳
2回答
基本上，我尝试使用反应性/spring网络流量来执行嵌套循环。我将如何迭代一个Flux，获取子记录，并最终返回一个dto流(在每个用户dto中包含子记录)？
这是它的要点，虽然可能还很遥远。
public Flux<UserDTO> getUsers(String name) {
Flux<User> users = userRepo.findByNameLike(name);
return users.flatMap(u -> {
Flux<Phone> phoneNumbers = phone
浏览 8提问于2022-10-18得票数 0
我正在从mongo反应性存储库中获取数据并更新它。然后，我必须收集一个集合中的所有数据，并将其路径到另一个服务以获取更多信息。那我应该把它们画成一个通量图。我的代码是：
Flux<Views> views = someRepository.findAllByUsersIn(userId).doOnNext(v -> {
v.setInterlocutor(v.getUsers().stream().filter(u -> !userId.equals(u)).findFirst().orElse(null));
});
浏览 1提问于2020-08-23得票数 0
回答已采纳
对于反应性编程来说有些新的东西，而且找不到这方面的任何好例子。如何组合来自Mono和Flux (并发获取)的结果来返回DTO的Mono？
我知道下面的代码不会编译，但一般说来，我想做下面这样的事情。
提前谢谢。
public Mono<UserDto> getByName(String name) {
Mono<User> user = userRepo.findByName(name);
Flux<PhoneNumber> numbers = phoneNumbersRepo.findByName(name);
return Mo
浏览 7提问于2022-10-13得票数 0
回答已采纳
我有一个UserDto，它的相关项目取自基于项目反应堆的存储库，因此返回Flux/Mono发布者。
我的想法是将字段/getter添加到DTO中，DTO本身就是publishers，并且懒洋洋地按需评估它们(订阅)，但是有一个问题：
控制器返回Flux of DTOs，一切正常，除非spring不序列化内部Publisher的
简而言之，我想要达到的目标是：
@Repository
class RelatedItemsRepo {
static Flux<Integer> findAll() {
// simulates Flux of User relat
浏览 11提问于2022-11-07得票数 0
回答已采纳
我有一个验证方法，它包含Stream中的一些元素。
Task
例如，有一个序列，它有一系列数字(数字不重复)，每个数字比另一个大：
1，20，35，39，45，43
..。有必要检查此流中是否存在指定的范围，例如35 ...49。如果没有这样的范围，那么您需要抛出一个异常。
但是由于这是异步处理，所以通常的方法在这里不起作用。毕竟，我们在流中处理元素，不知道下一个元素是什么。
这个序列的元素需要折叠，加法应该逐步完成(一旦找到元素的初始范围)。
在服务期间，您需要检查在生成的序列中是否存在一个端点，以及何时接收到整个元素流，但这一点不是，然后请求一个异常，因为没有收到指定的范围的上限<c
浏览 1提问于2022-05-02得票数 0
我有一个关于春天WebFlux和反应堆的问题。我试图编写一个简单的场景，在GET端点中，我返回一个DTO代表实体的Flux，而这些实体中的每个实体都有一个代表另一个实体的其他DTO集合。下面是细节。
我有两个实体，Person和Song，定义如下：
@Data
public class Person {
@Id
private Long id;
private String firstName;
private String lastName;
}
@Data
public class Song {
@Id
private Long id;
浏览 2提问于2021-05-14得票数 1
回答已采纳
1回答
我有以下实体：
公共类EventCategoryEntity {
private UUID id;
@Column("category_name")
private String categoryName;
@Column("group_name")
private String groupName;
}
我通过Flux(一对多的关系)检索到的：
public Flux<EventCategoryEntity> findAllCategories() {
return eventRepository.findAll();
}
@Quer
浏览 8提问于2022-08-22得票数 0
回答已采纳
我刚开始使用反应性编程，就遇到了这个问题：
[
{
"customerDTO": {
"scanAvailable": true
},
"bankAccountDTOs": {
"scanAvailable": true,
"prefetch": -1
}
}
]
DTO：
public class ResponseClientDTO {
private M
浏览 12提问于2022-01-13得票数 1
回答已采纳
目前，我遇到了新的Spring 5 WebClient的问题，我需要一些帮助来解决它。问题是：
我请求使用内容类型text/html;charset=utf-8.返回json响应的url。
但不幸的是，我仍然得到一个例外：org.springframework.web.reactive.function.UnsupportedMediaTypeException:内容类型'text/html;charset=utf-8‘不支持。所以我不能将响应转换为DTO。
对于请求，我使用以下代码：
Flux<SomeDTO> response = WebClient.creat
浏览 1提问于2018-01-31得票数 7
回答已采纳
我看过，读过一些关于spring reactor的文章，但我不太理解它。
假设我已经激活了netty和spring reactor，那么让端点返回Flux/Mono实例(jacksonified)而不是直接返回dto对象(jacksonified)有什么好处？我最初假设，在http请求/响应上下文中，反应式流的工作方式更像websockets，其中服务器使用开放的通道将数据推送到接收器，但事实似乎并非如此。
另外，在反应式编程中，netty实际上比tomcat做得更好吗？
如果这些问题看起来很愚蠢，我很抱歉，但我不太理解这个新框架方向的目的。它为什么会出现，它是如何工作的，它解决了什么问题？
浏览 1提问于2016-12-05得票数 16
我的理解是，Mono<List<T>>是一个同步的Flux<T>，而Flux不能是rest响应。
我说的对吗？
如果不是，Mono<List<T>>和Flux<T>之间有什么不同，或者在某些地方，Flux可以是rest响应？
浏览 3提问于2018-10-22得票数 15
回答已采纳
我的数据库正在返回Flux，我需要将它转换为DTO的Mono，并将其返回给调用者方法。我的Fruit类已经有了一个构建器方法来将Fruit转换为FruitDto。 如果调用者方法的返回类型只有Mono，我可以很容易地将其映射为如下所示，但由于它是Mono，我面临着困难 public Mono<List<FruitDto>> findAllBySearchKeys(String id){ //期望将水果的Flux转换为FruitDto列表的单声道并返回给调用者 return fruitRepo.findAllById(bol, status)
浏览 50提问于2021-08-18得票数 0
2回答
我有一个用户实体和一个角色实体。除了用户实体有一个与其各自角色的id相对应的role_id字段之外，字段并不重要。由于Spring R2DBC没有在实体之间执行任何形式的关系，所以我转而使用DTO方法。作为一个整体，我对R2DBC和反应性编程非常陌生，我不知道如何将Flux<User> --我的存储库的findAll()方法--返回到Flux<UserDto>。我的UserDto类非常简单：
@Data
@RequiredArgsConstructor
public class UserDto
{
private final User user;
p
浏览 1提问于2019-11-04得票数 9
回答已采纳
我经常看到三种不同的响应返回类型：Flux<T>、ResponseEntity<Flux<T>>和Flux<ResponseEntity<T>>，它们在MVC风格的控制器中使用Spring。解释了ResponseEntity<Flux<T>>和Flux<ResponseEntity<T>>之间的区别。Spring会自动将Flux<T>包装为ResponseEntity<Flux<T>>还是Flux<ResponseEntity<T>&
浏览 19提问于2022-01-22得票数 1
我在Tomcat容器中使用Spring (spring starter+spring starter)，我想得到以下结果：
如果流通量立即失败，我希望发送到客户端响应代码400。
否则，我想发送响应代码200，并流流量。
我尝试过不同的解决方案，但没有人有效。v1和v2不发送预期的响应代码，如果失败场景，v3不流输出是愉快的场景。
我想在failFlux上“窥视”异常，并在发送响应代码200之前触发异常。
@RequestMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public class X {
Flux<S
浏览 0提问于2018-10-26得票数 0
我有一个LegacyAccountDto，我需要从两个不同的来源构建一个列表。一个是本地JPA存储库，另一个是web服务调用。web服务版本具有可用的accountStatus，而JPA数据源则没有。我需要并行执行两个调用作为Fluxes，然后当它们都完成时，我需要找到web服务列表的legacyId，并用从web服务中提取的accountStatus填充该列表。整个想法是返回一个包含完整DTO的列表。我不需要将其保存回web服务或JPA代码库 DTO： @Data
@JsonInclude(Include.NON_NULL)
public class LegacyAccountDto {
浏览 10提问于2020-06-16得票数 2
回答已采纳
1回答
我有订单模型
@Document(collection="order")
public class Order {
@Id
String id;
String desc;
String orgId;
}
并且每个OrgId都与组织对象相关联
@Document(collection="organization")
public class Organization {
@Id
String id;
String desc;
String ownerEmail;
}
我订购的DTO是
public clas
浏览 0提问于2018-07-06得票数 2
给定2个Flux- Flux<String> flux1 = ...
Flux<String> flux2 = ... 现在，我需要检查两个Flux中是否都存在一个公共字符串。检查后，响应可以是布尔值或List<String>
浏览 47提问于2020-08-28得票数 0
回答已采纳
如何在将DTO响应从字节转换为WebClient之前将其拦截？
我尝试添加exchangeStrategy，但是如何将DataBuffer转换为String，然后仍然调用super.decode()方法呢？
ExchangeStrategies.builder().codecs((configurer) -> {
configurer.defaultCodecs().jackson2JsonDecoder(new Jaxb2XmlDecoder() {
@Override
public Flux<Object> decode(Publi
浏览 12提问于2019-07-15得票数 0
我正在使用SSE与反应堆通量，以捕获linux系统度量和发布到浏览器(javascript事件源)。
目前，该问题无法向特定客户端发送特定数据。在浏览多个SO帖子之后，会被告知在事件源中使用事件侦听器，来自服务器的响应应该在响应中以事件作为键。
因为，我要从服务器返回一个对象，所以将事件作为响应json中的一个键就足够了，它将由事件源标识。
在客户端设置一个唯一的编号，这将在json响应中的事件键中返回。
谢谢你的帮助！
Javascript:
jsonStreamObjectHeap.addEventListener("197e08e-f9a4-4e6e-9a04-220ade08a
浏览 0提问于2020-04-02得票数 1
回答已采纳
1回答
Java异常处理？
、、、
有人能指导我，因为我是新的变化，并试图了解如何处理这一情况？
问题：I在下面的getResp()方法的一个流量响应中获得readTimeout异常，然后忽略所有先前的成功响应，并返回异常错误。
相反，我想返回在异常之前收到的所有成功答复。
public Flux<CustomObject1> getInfo(List<RequestObj> requestObjList) {
return requestObjList.stream()
.parallel()
.map(this::getResp)
.reduce(Flux::
浏览 9提问于2022-04-05得票数 0
我有一个场景，在这个场景中，我将使用以下命令从DB获取实体列表
repository.getAllByIds(ids)
它将返回Flux<Entity>
如果Flux为空，则需要调用handleAllEntitiesNotFound()，否则需要调用handleNotFoundEntities()
repository.getAllByIds(ids)
.buffer()
.switchIfEmpty(__ -> handleAllEntitiesNotFound(ids, erroneousEntities))
浏览 0提问于2019-11-01得票数 1
我需要将流量数据中的日期时间列整到R中最近的小时，但是当我使用asPOSIXct时，我得到响应
as.POSIXct.default中的错误(flux_dt10，format = "%Y-%m-%dT%H:%M:%OS")：不知道如何将'flux_dt10‘转换为“POSIXct”类
dataset是一列值，如下所示：
flux_dt10 <- "01APR2019:11:51:42"
我试过：
as.POSIXct(flux_dt10,format="%Y-%m-%dT%H:%M:%OS")
但是给出了不知道如何将数据转换为&
浏览 3提问于2021-04-12得票数 0
我正在尝试构建一个应用程序A(类似于适配器)，它将：
1)接收带有某个key的POST请求(JSON格式)
2)它应该以某种方式修改密钥，并创建到另一个系统B的POST请求。
3)应用程序A应该解析来自应用程序B的响应，并修改该响应。
4)之后，我的应用程序A应该响应初始的POST请求。
@RestController
@RequestMapping("/A")
public class Controller {
@ResponseStatus(HttpStatus.OK)
@PostMapping(value = "B", consumes =
浏览 2提问于2019-05-30得票数 0
我对反应性编程非常陌生。我正在使用一个webflux，它正在返回流响应( application/ stream +json )。我的任务是调用API并将响应转换为List。我调用API的代码片段
ClientResponse res = webClient.method(HttpMethod.GET)
.uri("uri")
.header("Authorization", "Basic " + encoding)
.header("
浏览 12提问于2022-01-06得票数 0
1回答
首先，执行一个save()方法，它通过测试直到达到一个条件，如果它是真，则调用saveBankAccountAndRole()方法，如果它是false，则发送一个Mono.error(new Exception("...").。
sizeAccounts(String customerId)方法确实通过了测试。
在saveBankAccountAndRole(BankAccountDto bnkDto)方法中，在执行sizeAccounts()方法之后，测试没有通过，我遗漏了什么？
public Flux<BankAccountDto> findAccountsBy
浏览 1提问于2022-01-25得票数 0
我使用的是第三方REST控制器，它接受一个JSON对象数组，并返回一个对象响应。当我使用有限的WebClient发布Flux时，代码可以工作(我假设，因为Flux完成了)。
然而，当Flux可能是无限的，我怎么做；
在大块数组中发布？
捕获响应，每个POSTed数组？
停止Flux的传输
这是我的豆子；
public class Car implements Serializable {
Long id;
public Car() {}
public Car(Long id) { this.id = id; }
public Long g
浏览 0提问于2019-04-04得票数 2
回答已采纳
我们要求DTO应该从文档中生成，在文档中我们可以定义fieldName & fieldType (可能是Json或Yaml )。我们将在Rest控制器中使用这些dto作为请求dto和响应dto。因此，需求是，我们可以根据客户端需求定义请求和响应字段，并在某些文档中配置它，这些文档在代码中自动获取。如何在Spring java中实现这一点？
浏览 0提问于2021-12-31得票数 -1
2回答
我有一个数据源服务，它接受一个观察者作为参数。
void subscribe(Consumer onEventConsumer);
我想使用flux作为RSocket的响应流。我该怎么做呢？就我现在所见，它应该是这样的
Flux<T> controllerMethod(RequestMessage mgs) {
var flux = Flux.empty();
dataSource.subscribe(event -> flux.push(event));
return flux;
}
但我很怀疑这是不是一个合适的解决方案，而且我还是个响应式方法的新手，我不
浏览 0提问于2020-05-07得票数 3
1回答
我创建了一个类ApUtils。在该类中定义两个方法。我希望通过方法引用在map函数的服务类中使用这两个方法，但是在调用这两个方法service.kt时，我得到了未排除的错误。
package com.nilmani.reactivespringdemo.services
import com.nilmani.reactivespringdemo.Utils.AppUtils
import com.nilmani.reactivespringdemo.dto.ProductDto
import com.nilmani.reactivespringdemo.entity.Product
imp
浏览 0提问于2021-09-20得票数 0
1回答
顺便说一句，我还在学习weblux；我不知道这是否可能，或者我有错误的方法，但考虑到这种并行的变化。
Flux<String> enablers = Flux.fromIterable(enablersList)
.parallel()
.runOn(Schedulers.elastic())
.flatMap(element -> service.getAMono(string, entity, element))
.sequential();
谁
浏览 69提问于2020-02-08得票数 0
2回答
我有一串弦。对于每一个字符串，我必须进行一个远程调用。但问题是，进行远程调用的方法实际上返回响应的Mono (显然，由于与单个请求对应，就会有一个响应)。
处理这类案件的正确模式应该是什么？我可以想到的一个解决方案是对流元素进行串行(或并行)调用，并将响应减少到单个元素并返回。
下面是代码：
fluxObj.flatmap(a -> makeRemoteCall(a)//converts the Mono of the response to a Flux).reduce(...)
我无法在返回一个flatmap.The makeRemoteCall方法的Mono中进行处理。但是flat
浏览 1提问于2018-12-31得票数 4
回答已采纳
1回答
我有一个简单的dto，其中的字段可以是空的。
public ResponseDto{
...
@Nullable
public List<ListDto> getListDto() {
return this.listDto;
}
...
}
如何正确实现消失的检查，删除警告
@NotNull
public Flux<ListDto> getApplicationList(String applicationSubsidiesId) {
return Mono.fromCallable(() -> mapper.toRq(app
浏览 22提问于2022-10-12得票数 1
回答已采纳
5回答
我已经对Spring进行了一些实验，我正在尝试修改响应体。使用响应装饰器，我可以看到主体被修改了，但是缓冲区大小仍然是原始响应的大小。是否有方法将缓冲区大小扩展到新响应体的大小？
public class ModifyBodyGatewayFilterImpl implements GatewayFilter {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
logger.info("\n\nexchan
浏览 0提问于2018-01-26得票数 2
2回答
我有一个网络服务，返回学生和注册班级的详细信息.
{
"name": "student-name",
"classes": [
{
"className": "reactor-101",
"day": "Tuesday"
},
{
"className": "reactor-102",
"day": "Friday"
}
]
}
浏览 4提问于2017-09-14得票数 5
回答已采纳
我试图使用Spring反应堆与我的Spring应用程序。
我正在使用和SpringBoot1.5.3。
我的Service类中有一个返回Flux的方法。
我想将这个值返回给web层中的控制器。但是，我看不到json响应中的值返回。
当我从浏览器调用时，我会得到响应，{“预取”：-1}
在返回响应之前，我不确定是否应该从Flux转换为String。
我的代码是共享的，
你能帮我找到正确的方法吗？
浏览 6提问于2017-05-31得票数 5
回答已采纳
1回答
免责声明:我是ServiceStack的新手
考虑到以下服务：
public class TestService : Service
{
public TestResponse Get(Test request)
{
if (String.IsNullOrEmpty(request.Message))
throw new ArgumentException("Message is required");
return new TestResponse();
}
}
和下列请求/答复DTO：
[Ro
浏览 0提问于2013-08-14得票数 2
回答已采纳
1回答
我正在寻找一种使用Flux实现以下功能的方法：
处理1,000,000 (或更多)请求的流。
请求编号为(从1到1 000 000)。
请求应该以并行方式启动，比如使用10个线程。
请求的启动顺序由它们的序列号决定。
结果Flux应该以与请求相同的顺序返回响应。
结果当每个响应都可用时，Flux就应该发出每个响应。
我知道#4的答案是为Scheduler使用单个执行器。然而，我不知道如何实现#6。
下面是一个示例场景：
请求1、2、3、4、5、6、7、8、9、10已启动。
响应2到达(当线程可用时，请求11启动)。
回应5到达(请求12已启动)。
浏览 0提问于2017-08-15得票数 0
1回答
上下文
我们正在构建一个基于流量的web应用程序，客户端(Flux/React/TypeScript)通过websockets (而不是通过HTTP )与服务器(C#)通信。
当执行客户端操作时，我们通过web套接字连接向服务器发送命令请求。
服务器总是使用第一个开始响应(指示是否可以执行请求的操作)快速响应，然后使用一个或多个进度响应(可能是数百个响应，其中包含有关执行操作的进度信息)。当服务器上的操作完成后，最后一个进度响应将有100%的进度分数和"OK“错误状态。
请注意，一些服务器操作可能只需要100 ms，但其他操作可能需要10分钟(因此可以获得进度响应，因此客户端可以向用户
浏览 4提问于2016-02-12得票数 1
我正在使用Flux来构建我的反应性管道。在这个过程中，我需要调用3种不同的外部系统REST，它们对访问速率非常严格。如果我超过了每秒的速度，我就会被按指数控制。每个系统都有自己的阈值。
我使用Spring进行REST调用；在3个WebClient中，有2个是GET，1个是POST。
在我的反应堆管道中，WebClient封装在flatMap中以执行API调用，如下所示：
WebClient getApiCall1 = WebClient.builder().build().get("api-system-1").retrieve().bodyToMono(String.clas
浏览 4提问于2020-06-02得票数 1
当使用Spring测试以下控制器时，我目前正面临着一个奇怪的问题(V5.2.6)
@RestController
@RequestMapping(path = "/address", produces = MediaType.APPLICATION_JSON_VALUE)
public class AddressController {
@GetMapping(path = "/postcode")
public Flux<String> listPostCodes(...) {
return Flux.just(&
浏览 6提问于2020-06-08得票数 1
回答已采纳
我创建了SpringBoot2.0演示应用程序，它包含两个使用WebClient通信的应用程序。而且，当我从WebClient的响应中使用Flux的block()方法时，他们经常停止通信，这让我感到痛苦。出于某些原因，我想使用List而不是Flux。
服务器端应用程序是这样的。它只返回Flux对象。
@GetMapping
public Flux<Item> findAll() {
return Flux.fromIterable(items);
}
客户端(或BFF端)应用程序是这样的。我从服务器获得Flux，并通过调用block()方法将其转换为List。
@GetMa
浏览 0提问于2018-01-30得票数 8
回答已采纳
如何链接Flux和Mono Publisher？ 我想把它们都链接起来，然后发送响应。基本上，所有操作都是异步执行的。 在这里，我使用zip for Mono & Flux来执行所有Mono和Flux发布器。 List> monoPubs = new ArrayList<>();
Mono.zip(monoPubs, mred -> result);
List> fluxPubs = new ArrayList<>();
Flux.zip(fluxPubs, fres -> result);
浏览 117提问于2021-02-28得票数 2
回答已采纳
2回答
我有一个包含URL的List<String>，我想对List中的每个URL执行一个GET请求。
这些要求应同时提出。在完成所有请求之后，我希望有一个包含所有反序列化响应的List<CustomModel>。
所以我创建了一个方法来发出HTTP请求
public Flux<JsonNode> performGetRequest(String url) {
WebClient webClient = WebClient.create(String.format("%s%s", API_BASE_URL, url));
retur
浏览 5提问于2021-03-19得票数 1
回答已采纳
大家好
我的任务是简单地制作控制器，在结果准备就绪时立即给出结果(下面的简单示例)
想象一下：
我想要得到字符串的确切数量(例如，以某种方式为1秒制作的1000个字符串)(实际上，我需要得到函数的结果，但为了简化任务-只是String)
因此，当我在控制器中收到一些请求时，我希望它在准备就绪后立即给出答案(没有缓冲结果)：
我想要的是：
1秒
“一些字符串”-> (向我的前端发送响应)
1秒
“另一个”-> (向我的前端发送回复)
1秒
“第三名”-> (向我的前部发送回复).
但我得到的是：
1000秒
“一些绳子”
.
“千弦”
这是我的代码：
@GetMapping(v
浏览 11提问于2022-04-07得票数 0
回答已采纳
我在修改Spring Cloud Gateway中的Flux响应时遇到了一些问题。我的设置(简化)如下:我有2个域对象：
@Data
@AllArgsConstructor
public class PersonV10 {
@NotNull
private String name;
}
@Data
@AllArgsConstructor
public class PersonV20 {
@NotNull
private String firstName;
@NotNull
private String lastName;
}
现在，我的服务
浏览 2提问于2020-06-23得票数 0
我在下面的客户端-服务器交互中看到了一些奇怪的行为，我想知道我是遇到了HTTP/1.1语义，还是我的反应式编程技能需要努力(或者两者兼而有之)。 我正在尝试创建一个客户端-服务器交互，其中请求和响应主体都是长时间运行的数据流。 客户端是一个Spring Reactive WebClient，它在请求体中发送无限流。它期望接收(并记录)无限的结果流。 Flux<Long> requests = Flux.interval(Duration.ofSeconds(2));
return WebClient.create()
.post()
.u
浏览 29提问于2019-12-04得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
