Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Spring Web Reactive Framework 多部分文件问题
我正在尝试使用 Spring 的响应式框架来实现图像上传 方法如下 RestController RequestMapping images public class ImageController Autowired private II
Spring
SpringMVC
reactive
projectreactor
从 Mono 列表创建 Flux 的正确方法
假设我有一个使用 CustomObjects 列表的 API 操作 对于其中的每一个对象 它都会调用一个创建 Mono 的服务方法 如何以惯用且非阻塞的方式从这些 Mono 对象创建 Flux 我现在想到的就是这个 我更改了方法名称以更好地
Spring
kotlin
MONO
flux
projectreactor
将 Streaming Flux 的 WebClient Post 拆分为 JSON 数组
我正在使用第三方 REST 控制器 它接受 JSON 对象数组并返回单个对象响应 当我使用有限的 WebClient 进行 POST 时Flux代码有效 我认为 因为Flux完成 然而 当Flux可能是无限的 我该怎么办 以数组块形式发布
Java
SpringWebFlux
projectreactor
reactivestreams
如何通过另一种方法动态地将元素添加到反应器热通量中?
我有一个数据源服务 它接受观察者作为参数 void subscribe Consumer onEventConsumer 我想使用 Flux 作为 RSocket 的响应流 我怎样才能做到这一点 我现在看到的应该是这样的 Flux
Java
reactiveprogramming
projectreactor
flux
rsocket
如何在 Spring data r2dbc 中替换 @PrePersist
我在用spring boot starter data r2dbc 版本 1 1 3 Spring Webflux 应用程序中的模块 我想将实体生命周期回调添加到我的持久层 使用 Spring Data JPA 可以使用注释 例如 PreP
Java
springdata
SpringWebFlux
projectreactor
springdatar2dbc
如何对 Reactor Flux 流中的值求和?
假设我有一个存储库findAll 返回一个方法Iterable of State where State是一个代表美国州的类 有两个字段 带有 getter setter name and population 我想获得所有人口字段的总和S
Java
reactiveprogramming
projectreactor
使用项目反应器 mergeWith() 运算符来实现“if/elseif/else”分支逻辑
我正在尝试使用项目反应堆 mergeWith运算符以实现if elseif else分支逻辑如下所述 RxJS If Else 运算符在哪里 https rangle io blog rxjs where is the if else op
reactiveprogramming
projectreactor
Spring Webflux webclient 出现问题,尝试发送 post 请求时没有任何反应
webclient 的实现如下 public
Java
Spring
springboot
SpringWebFlux
projectreactor
如何正确读取 Flux
并将其转换为单个 inputStream
我在用着WebClient和定制BodyExtractor我的 spring boot 应用程序的类 WebClient webLCient WebClient create webClient get uri url params acc
Java
Spring
projectreactor
SpringWebFlux
reactivestreams
支持 R2dbcRepository 中的异常处理,或者如何使用我自己的错误处理程序来装饰 R2dbcRepository 中的每个方法调用
背景 我有一个应用程序范围的通用异常处理程序来翻译来自R2dbcRepository 例如 摘录只是为了显示预期目的 Component public class ErrorHandler public Throwable mapError
Java
Exception
projectreactor
springdatar2dbc
r2dbc
反应堆中的地图与平面地图
我找到了很多关于RxJava https stackoverflow com questions 22847105 when do you use map vs flatmap in rxjava 但我想了解它在 Reactor 中是如何工
Java
SpringWebFlux
projectreactor
Spring Integration 5.0 + Project Reactor:控制线程
跟进问题https stackoverflow com a 47136941 1776585 https stackoverflow com a 47136941 1776585 我无法使我的集成 处理程序在使用时在并行线程中运行Flux
Java
Spring
springintegration
reactiveprogramming
projectreactor
使用 WebFlux 的 Spring Boot 在测试中总是抛出 403 状态
非常感谢您查看我的问题 我有一些奇怪的主题 我的 Spring Boot 测试不起作用 它们启动成功 但在向任何控制器发出请求时总是抛出 403 HTTP 状态 我有一些具有下一个依赖项的项目 buildscript ext kotlin
Spring
springboot
SpringWebFlux
projectreactor
SpringBootTest
Project Reactor:如何控制通量排放
我有一个能发出一些光的通量Date This Date映射到我在某些设备上运行的 1024 个模拟 HTTP 请求Executer 我想做的是等待所有 1024 个 HTTP 请求 然后再发出下一个请求Date 目前运行时 onNext 被
Java
reactiveprogramming
projectreactor
reactivestreams
Web 响应式编程 - 从 HTTP 客户端的角度来看有哪些优点?
让我们假设控制器生成一些带有延迟的随机数的这两种情况 1 Reactive Spring 5响应式应用 GetMapping randomNumbers public Flux
Spring
RXJava
reactiveprogramming
projectreactor
带有 Webflux 的 JDBC - 如何分派到容器线程
我正在使用 webflux 进行小型概念验证 在我的应用程序的一部分中 我想与一个数据库进行通信 通过 JDBC 该数据库是阻塞的并且不太适合反应器 尽管如此 对于这个概念验证 我正在考虑以下技巧 定义一个专用的线程池 我们称之为DBThr
Java
JDBC
projectreactor
SpringWebFlux
Reactive Spring 不支持 ServerHttpRequest 作为 REST 端点测试中的参数?
这个问题非常类似于this one https stackoverflow com questions 40361298 reactive spring does not support httpservletrequest as para
Java
Spring
SpringWebFlux
projectreactor
如何使用Mono的“缓存”方法
我是 spring webflux 的初学者 在研究时我发现了一些代码 例如 Mono result someMethodThatReturnMono cache 缓存 这个名字告诉我关于缓存某些东西 但是缓存在哪里以及如何检索缓存的东西
caching
reactiveprogramming
SpringWebFlux
projectreactor
webflux
Project Reactor 中的预取是什么意思?
我正在使用 Project Reactor 并且正在使用Flux flatMapIterable https projectreactor io docs core release api reactor core publisher Fl
Spring
projectreactor
为什么 Sinks.many().multicast().onBackPressureBuffer() 在订阅者之一取消订阅后完成以及如何避免它
我在使用时遇到了我不明白的行为Sinks Many
kotlin
SpringWebFlux
projectreactor
reactivestreams
«
1
2
3
4
5
»