Spring WebFlux平面映射返回Mono<Void>
Spring WebFlux是Spring Framework的一个模块，用于构建响应式的Web应用程序。它基于Reactor项目，提供了一种非阻塞的编程模型，可以处理高并发的请求。
平面映射是Spring WebFlux中的一种处理方式，它指的是将请求映射到一个处理器方法，并返回一个Mono<Void>对象作为响应。Mono<Void>表示一个空的响应，不包含任何数据。
使用平面映射返回Mono<Void>的优势是可以实现非阻塞的请求处理，提高系统的吞吐量和性能。由于不需要返回具体的数据，可以节省网络带宽和服务器资源。
Spring WebFlux的平面映射适用于一些不需要返回具体数据的场景，例如处理一些异步的操作，如发送消息、写入日志等。它也可以用于处理一些简单的HTTP请求，如健康检查、心跳等。
腾讯云提供了一系列与Spring WebFlux相关的产品和服务，包括云服务器CVM、负载均衡CLB、云数据库MySQL、云存储COS等。这些产品可以帮助用户构建高性能、可靠的Web应用程序。具体产品介绍和链接如下：
- 云服务器CVM：提供可扩展的计算能力，支持快速部署和弹性伸缩。了解更多：云服务器CVM
- 负载均衡CLB：实现流量分发和负载均衡，提高系统的可用性和稳定性。了解更多：负载均衡CLB
- 云数据库MySQL：提供高性能、可扩展的关系型数据库服务，支持数据的存储和访问。了解更多：云数据库MySQL
- 云存储COS：提供安全可靠的对象存储服务，用于存储和管理大规模的非结构化数据。了解更多：云存储COS
通过使用这些腾讯云的产品，开发人员可以更好地支持和扩展Spring WebFlux应用程序，提供稳定、高效的服务。
相关·内容
1回答
我在我们的应用程序中升级spring版本，这是在之前的Spring4.3中，而升级到spring 5时，我们想要更改应用程序的某些部分，以使用可用的反应性特性。MVC和WebFlux在应用程序中都是并行工作的，但是视图解析在webflux中是不支持的。
@RequestMapping(value = "/react/createWithReactive")
public Mono<String> reactCreateWithReactive(Model map) {
return Mono.just("creat
浏览 4提问于2018-12-24得票数 0
1回答
我已经开始学习Spring WebFlux了，我不明白Mono是如何工作的。当我们从端点返回Mono对象作为响应时会发生什么？示例：
@PostMapping("/product")
@ResponseStatus(HttpStatus.CREATED)
public Mono<Product> createProduct(@RequestBody Product product){
return productService.save(product);
}
服务端是如何处理请求的？
浏览 1提问于2021-11-13得票数 0
1回答
在Spring 5中，我只知道Spring方法处理请求，并返回、Mono、或Flux作为响应。
@Component
public class HelloWorldHandler {
public Mono<ServerResponse> helloWorld(ServerRequest request) {
return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).body(BodyInserters.fromObject("Hello World"));
}
}
但我
浏览 0提问于2018-07-03得票数 21
回答已采纳
我使用的是Spring Webflux，保存成功需要返回用户ID。
存储库正在返回Mono
Mono<User> savedUserMono = repository.save(user);
但是在控制器中，我需要返回从save()调用返回的对象中的用户ID。
我尝试过使用doOn*和subscribe()，但当我使用return from subscribe时，出现错误‘意外返回值’。
浏览 4提问于2019-08-07得票数 3
我有一个端点，它接受id参数并发送delete product api来删除。productService.delete也会返回Mono。问题是，当productService.delete方法返回mono error时，端点总是以http 200响应。我可以看到关于这个单声道错误的错误日志，但我的处理程序方法响应http 200。 我的应用程序接口中有一个AbstractErrorWebExceptionHandler to handler异常。但由于Mono，错误处理程序无法处理此问题。当下游发生异常时，Spring webflux应该知道此错误，并且不会使用http 200进行响应。
浏览 51提问于2020-06-18得票数 0
回答已采纳
嗨，我有一个spring webflux应用程序。我想要一个上传文件的API。我按照中的说明操作
写了类似这样的东西
@PostMapping(consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
public Mono<Void> save(@RequestPart("file") Mono<FilePart> file) {
log.info("Storing a new file. Recieved by Controller");
this.stor
浏览 49提问于2020-02-18得票数 1
我尝试创建spring boot webflux的处理程序和路由器类。模型类是用户类。代码是 @Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
@Document(collection="Users")
public class User {
@Id
private String _id;
@Indexed(unique = true)
private Long id;
@Indexed(unique=true)
private String user
浏览 70提问于2019-07-01得票数 2
回答已采纳
我不明白thenEmpty、thenMany和flatMapMany在Flux上的用法和区别，或者spring webflux中的Mono。
浏览 0提问于2018-01-15得票数 25
回答已采纳
是否有一种方法可以在使用Spring的RequestBody方法中访问@ExceptionHandler (最好是映射形式的)？
请考虑以下示例：
@RestController
class TestRestController {
@PostMapping("/test")
Mono<TestBody> testPost(@RequestBody TestBody testBody) {
return Mono.error(new NullPointerException());
}
@ExceptionHandler(NullPoin
浏览 8提问于2020-04-14得票数 5
如何访问Mono类型的RequestBody参数。Spring Boot Webflux reactive。 我想返回一个ResponseEntity，而不是Mono。 @RequestMapping(value = "/poststudentdata", method = RequestMethod.POST, headers={"content-type=application/json"})
public ResponseEntity<String> poststudentData(@Valid @RequestBody Mono<St
浏览 74提问于2019-04-01得票数 1
1回答
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
Flux<DataBuffer> body = exchange.getRequest().getBody();
//Return different according to body content...
if (condition) {
return chain.filter(exchange);
} else {
return Mono.e
浏览 14提问于2018-08-10得票数 5
回答已采纳
3回答
我必须使用spring Webflux以一种被动的方式保存一些值。但当我发送请求时，将返回404状态作为响应。 pom.xml <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jersey</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot
浏览 103提问于2020-08-24得票数 1
回答已采纳
我正在使用Spring WebFlux和反应性Spring数据MongoDB实现一个简单的基于电影的CRUD。我想确保我的实现是正确的，并且我正确地使用了Flux和Mono来实现CRUD操作。我还希望确保正确地处理任何错误或空值。我对这个编程范例和Spring非常陌生，所以我不确定Controller和服务层实现的正确性，我想确保我坚持Spring和项目反应堆最佳实践。
@Repository
public interface MovieRepository extends ReactiveMongoRepository<Movie, String> {
Flux<
浏览 0提问于2017-03-28得票数 3
回答已采纳
我是Spring WebFlux的新手，我有一个问题。我想返回类似于Mono<String>的内容，如下所示： @PostMapping("/test")
public Mono<String> test(){
return Mono.just("Test String")
.thenEmpty(it -> {
// Do something I need
System.out.println("Print somethings&
浏览 195提问于2019-12-05得票数 0
回答已采纳
我在我的spring引导项目中使用WebFlux。我有一段注册用户的代码，它首先检查数据库中是否存在提交的电子邮件
userRepository.findByEmail(userDto.getEmail())
.flatMap(t -> {
UserAlreadyExistException userAlreadyExistException = new UserAlreadyExistException("There is an account with this email address: " + userDt
浏览 2提问于2020-06-24得票数 0
回答已采纳
关于使用Mono<ServerResponse>和Mono<ResponseEntity<MyPojo>>作为返回类型的小问题。 我看到了一些示例，有时候，Mono<ServerResponse>在Spring Webflux的函数路由中用作返回类型。 但也可以看到一些示例，有时在Spring函数路由中使用Mono<ResponseEntity<MyPojo>>作为返回类型。 此外，在@控制器、@RequestMapping (Get、Post映射等)中使用Mono<ResponseEntity<MyPojo
浏览 28提问于2020-12-15得票数 3
回答已采纳
在基于WebFlux的Spring中，我有一个更复杂的用例，我在Mono的使用上遇到了一些小问题。长话短说，即使不需要，我的switchIfEmpty也会被调用。我准备了一个小例子，让我可以重现这个问题：
public class ReactiveTest {
@Test
void test1() {
isOdd(2)
.flatMap(this::onNotEmpty)
.switchIfEmpty(Mono.defer(this::onEmpty))
.block();
}
浏览 4提问于2022-01-12得票数 0
我一直在使用Spring Boot 2.0.1及其Webflux库开发一个响应式web api示例。我一直在看网上的例子，试图构建它，但我被两件事难住了。下面是我的两个问题。
1)我如何返回一个响应实体的Flux，当我尝试时，我得到一个错误，说只能返回一个响应实体。下面是我当前的代码。
@Service
public class MovieServiceImpl implements MovieService {
@Autowired
private MovieRepository movieRepository;
@Override
public Flux
浏览 5提问于2018-04-29得票数 6
回答已采纳
这个问题非常类似于。除了我用：
org.springframework.http.server.ServerHttpRequest 不是 HttpServletRequest。
异常出现在测试代码中。真电话管用。
代码：
@RunWith(SpringRunner.class)
@SpringBootTest(classes = SecurityTests.SecurityTestsApplication.class)
@TestPropertySource(properties = {""})
@AutoConfigureWebTestClient
publi
浏览 2提问于2018-11-20得票数 9
回答已采纳
关于如何将Spring Webflux Websocket作为注释的问题。 我正在做一个Springboot Webflux websocket项目，它同时处理restful api和Websocket。 需要强调的是，这是一个单独的Spring Webflux项目。不是Springboot starter websocket，不是Springboot rsocket，也不是Springboot pub sub。 该项目如下所示： @SpringBootApplication
public class EchoApplication {
public static void main
浏览 13提问于2020-10-27得票数 0
回答已采纳
我尝试使用kotlin/webflux/r2dbc:postgresql编写web应用程序，但我有一些问题。我不明白为什么switchIfEmpty调用如果工作的结果hackerService.resetPassword不是空的
控制器
@PostMapping("/reset/password/{link}", consumes = [MediaType.APPLICATION_FORM_URLENCODED_VALUE])
fun resetPassword(@PathVariable link: String, req: ResetPassword): Mono&
浏览 0提问于2020-10-11得票数 0
回答已采纳
一般来说，我对Webflux和Spring很陌生，在设置一个处理POST请求的简单服务器时遇到了困难：
WebfluxtestApplication.java
package com.test.webfluxtest;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.PostMapping;
import or
浏览 7提问于2019-12-04得票数 4
回答已采纳
在Spring MVC框架中，当控制器返回接口类型时，spring的消息转换器可以将返回值转换为适当的消息(如JSON)。
例如，当我调用'vehicle‘api时，我可能会收到一条JSON消息。
@GetMapping("vehicle")
public Vehicle getVehicle() {
return new Car();
}
public interface Vehicle {
}
public class Car implements Vehicle {
privat
浏览 3提问于2019-04-16得票数 0
2回答
因此，我了解到，在外壳下，Spring WebFlux和反应堆使用netty作为nio，现在我想释放调用线程来释放资源，以便处理更多的请求。下面的简单代码是否释放了调用线程？
@GetMapping("/foo")
public Mono<Void> bar() {
someService.veryLongSyncOperation();
return Mono.empty();
}
我没有将服务调用包装在Flux/Mono中，我只想首先验证调用线程是否在服务完成其长期工作时释放。这是否足以实现调用线程的发布？如果是的话，有什么方法来测试这个吗？
我认为
浏览 2提问于2019-03-09得票数 1
回答已采纳
空手道测试框架可以与Spring Webflux一起工作吗?在Spring Webflux中，返回类型是Mono<>和Flux<>对象，而不是json字符串。任何推荐人都会很有帮助。
浏览 2提问于2021-07-11得票数 1
我有一个使用Spring Boot 2.0.0.M5/2.0.0.BUILD-SNAPSHOT的Spring Boot WebFlux应用程序，我需要向所有日志添加跟踪ids。
为了在WebFlux应用程序中实现这一点，我尝试使用描述为和的WebFilter方法
@Component
public class TraceIdFilter implements WebFilter {
@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
return ch
浏览 2提问于2017-10-25得票数 4
回答已采纳
1回答
最近我正在学习Spring WebFlux。当我尝试关闭连接池中的连接时，它不起作用！ 代码如下： return connectionPool.create().flatMap(connection -> {
Mono<Result> result = Mono.from(connection.createStatement("").execute());
connection.close();
return result;
})
.flatMap(body -> Mono.from(body.map(((row
浏览 66提问于2021-07-24得票数 1
回答已采纳
我正在使用WebFlux的功能端点。我使用onErrorResume将服务层发送的异常转换为HTTP错误代码
public Mono<String> serviceReturningMonoError() {
return Mono.error(new RuntimeException("error"));
}
public Mono<ServerResponse> handler(ServerRequest request) {
return serviceReturningMonoError().flatMap(e ->
浏览 0提问于2018-02-09得票数 7
回答已采纳
1回答
我正在使用spring-webflux调用外部call服务异步，例如： String param1;
int param2;
webClient.send(...)
.exchange()
.doOnSuccess(rsp -> processResponse(rsp))
.onErrorMap(ex -> processException(ex, param1, param2)); 现在，我想将实际的发送重构为一个更通用的方法，调用者应该提供成功+错误函数a参数。但是怎么做呢？ public Mono send(Fu
浏览 12提问于2021-04-12得票数 1
回答已采纳
我正在寻找一个使用WebFlux处理错误的简单示例。我在网上读过很多东西，但找不到我想要的东西。
我用Spring 2.45跑步
我打的电话是这样的：
Mono<ResponseObject> mono = webClient.post()
.uri(url.toString())
.header("Authorization", authToken)
.body(Mono.just(contract), contract.getClass())
.retrieve()
.bodyToMono(ResponseObject.class)
浏览 3提问于2021-07-13得票数 1
回答已采纳
1回答
我有一个Spring (而不是WebFlux)应用程序，它使用来自WebFlux项目的WebClient类。除了WebClient-related代码之外，应用程序中的所有现有代码都是基于CompletableFuture的异步代码，对JPA的阻塞调用通常如下所示：
@Service
public class MyService {
private final MyRepository repo;
private final Executor executor; // configured by me & injected by Spring
...
@Async
浏览 1提问于2020-06-03得票数 1
1回答
我正在尝试在一个Spring-Boot WebFlux应用程序中创建一些WebFilters，我注意到我开发的所有post操作都只能使用WebFlux的端点，但它们不能使用我自己的端点。 在我的分析过程中，我注意到当我调用一个Actuator端点(比如: health)时，Mono会按预期完成。然而，当我调用我的端点时，mono发出了一个取消信号。这是一种预期的行为吗？ 依赖关系： <parent>
<groupId>org.springframework.boot</groupId>
<artifactId>s
浏览 8提问于2019-05-30得票数 0
当使用在tomcat.Extended中将Spring WebFlux应用程序部署为war文件时，将面临下面的异常，并实现如下的getConfigClasses方法。
应用程序
@SpringBootApplication
public class TestSpringApplication extends AbstractAnnotationConfigDispatcherHandlerInitializer {
public static void main(String[] args) {
SpringApplication.run(TestSpringAppl
浏览 6提问于2017-11-21得票数 3
回答已采纳
我有一个简单的用例，不知道该怎么做，因为我是spring webflux的新手。
我使用的是spring boot webflux starters。我需要呼叫2个端点。假设是Endpoint1和Endpoint2。
每当Endpoint1被请求击中时，我应该首先用相同的请求击中Endpoint2，并使用来自Endpoint2的响应来丰富原始请求，然后再做进一步的事情。在执行任何操作之前，需要使用来自Endpoint2的响应来丰富Endpoint1的请求对象。如何使用Spring webflux强制执行此命令?在我的示例中，原始请求对象在可以进一步使用之前没有被丰富。这方面的任何帮助都是非常感
浏览 4提问于2019-04-05得票数 1
我是Spring的新手，正在尝试将我的spring webflux应用程序转换为WebFlux。我从我的服务中返回一个单声道：
List<Store> stores = new ArrayList();
当我这样做的时候：
mono.subscribe(stores::addAll);
dataexchange.put("stores", stores);
return Mono.just(dataexchange);
然后，商店作为响应被填充为空列表。但是，我可以在返回响应后验证subscribe()是否正常工作。
当我这样做的时候
浏览 2提问于2019-02-12得票数 6
回答已采纳
我正在尝试打印一个计数器，它从doOnNext()函数中递增。
public static void main(String [] args) {
final AtomicInteger counter = new AtomicInteger();
Mono.just(List.of(1))
.doOnNext(i -> System.out.println("doOnNext " + counter.incrementAndGet()))
.map(i -> {
浏览 9提问于2021-01-27得票数 1
回答已采纳
我是Spring的新手。我试着用函数式的方式为spring webflux制作一个示例应用程序。为什么我们的处理函数不能传递Flux。有没有办法让路由器功能接受它，因为据说路由器功能接受serverResponse的一个子类型。 显示处理程序代码 public Mono<ServerResponse> getShowList(ServerRequest request){
Flux<Show> showList = showRepository.findAll();
Flux<ShowVo> showVoL
浏览 33提问于2020-08-27得票数 1
我正在尝试使用Spring WebFlux中的org.springframework.validation.Validator来验证JSON @RequestBody，但是我得到了“Internal WebFlux Error”和以下消息。
java.lang.IllegalStateException: Failed to resolve argument 1 of type 'org.springframework.validation.BindingResult' on public reactor.core.publisher.Mono ....
验证器类：
@Comp
浏览 1提问于2018-02-05得票数 1
我需要上传文件和阅读内容，使用spring mvc很容易，但是使用spring webflux我不知道如何处理FilePart和DataBuffer的Flux
我期望的结果是这样的：
@PostMapping("/upload")
fun readFile(@RequestPart("file", required = true) file: Mono<FilePart>): Mono<ResponseEntity<String>> {
return Mono.just("my text
浏览 0提问于2019-10-30得票数 0
1回答
我正在学习反应式编程和spring-webflux，我正在尝试实现JWT Token Authorization，但我得到了一个关于ResponseEntity的运行时错误： open class JwtReactiveAuthenticationManager(
private val userDetailsService: ReactiveUserDetailsService,
private val passwordEncoder: PasswordEncoder
): ReactiveAuthenticationManager {
priva
浏览 27提问于2020-01-10得票数 0
回答已采纳
我有一个小型的Spring微服务，它使用webflux将其端点公开为反应性的。
当我从IntelliJ、Gradle或cmd行运行应用程序时，SpringDoc支持：
implementation 'org.springdoc:springdoc-openapi-webflux-ui:1.4.4'
我去http://localhost:8080/swagger-ui.html，我得到了一个500个错误，日志显示：
java.lang.IllegalStateException: No primary or default constructor found for interf
浏览 7提问于2020-08-19得票数 2
回答已采纳
我正在学习Spring，在编写示例应用程序的过程中，我发现了与Spring WebFlux结合使用的反应式类型(Mono/Flux)相关的一个问题。
考虑下面的代码片段(用Kotlin编写)：
@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>
@Service
class TaskService(val taskRepository: TaskRepository) {
@Cacheable("tasks")
fun get(id: Strin
浏览 4提问于2018-01-09得票数 25
回答已采纳
我得到这个错误:类型Mono中的方法flatMap()不适用于参数(( prev)->{}) public Mono<PortCall> updateByFindById(String gsisKey, PortCall portCall) {
PortCall next = portCallRepository.findById(portCall.getNextPortCall().getNextScheduleEntryKey()).toProcessor().block();
return portCallRepository.findById(gsi
浏览 7提问于2021-02-02得票数 0
我正在做一个Spring webflux项目，
我想这样做，当客户端进行API调用时，我想向客户端发送成功消息，并在后台执行大文件操作。
这样客户端就不必等到我整个文件都处理完了。
为了试用，我制作了如下示例代码
REST控制器
@GetMapping(value = "/{jobId}/process")
@ApiOperation("Start import job")
public Mono<Integer> process(@PathVariable("jobId") long jobId) {
return
浏览 0提问于2020-01-25得票数 0
假设我有一个使用Spring Webflux的非常简单的HTTP端点： @GetMapping
fun greeting(@RequestParam("msg") val message : String) = Mono.just(Greeting(message)) 其中Greeting是一个序列化为JSON的简单DTO。如何指示Spring Webflux返回压缩为GZIP的响应？如果有必要的话，我会使用Netty实现。
浏览 22提问于2019-03-19得票数 0
回答已采纳
在spring webflux中，如何停止filter链并从当前的filter返回BAD_REQUEST？
public class AuthorizationFilter implements WebFilter {
@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
return chain.filter(Optional.of(exchange)
.filter(serverWebExch
浏览 1提问于2019-10-16得票数 1
据我理解，在春季WebFlux反应器中
Mono<Void>指的是一个空的Mono
Mono.empty()指的是空，因为调用任何对此的调用都会给出一个空指针。
它们在用法上有何不同？
浏览 8提问于2020-05-15得票数 14
回答已采纳
我使用Spring和Webflux。
在我的代码中，我尝试返回一个Flux，但是我从intellij获得了以下错误，代码被标记为红色：
no instance(s) of type variable(s) R exists so that Flux<UUID> conforms to Mono<>
我的代码：
public Flux<UUID> deleteCCProtections(Mono<ProtectionSetRequest> protectionSetRequest) {
return protectionSetReq
浏览 0提问于2020-07-14得票数 0
回答已采纳
我有一个Spring 2.3.2.RELEASE WebFlux应用程序。在application.yml中，我有以下设置：
spring:
jackson:
property-naming-strategy: SNAKE_CASE
serialization:
write-date-timestamps-as-nanoseconds: false
write-dates-as-timestamps: true
实际上，几乎所有的JSON响应都被正确地发送回用户代理:除了默认的默认格式之外，都是蛇案例格式。我的意思是这个框架所产生的任何反应。
这是一
浏览 3提问于2020-08-13得票数 1
回答已采纳
我在mongodb中使用了spring boot WebFlux处理函数和路由函数。下面是我的ReactiveMongoRepository接口和处理程序类。 ReactiveMongoRepository接口 public interface UserReactiveMongoRepository extends ReactiveMongoRepository<User, String> {
Mono<User> findByEmail(@Param("email") String email);
Mono<User>
浏览 32提问于2019-06-26得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
