Spring Boot 响应式 WebFlux 笔记1

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import java.time.Duration;
import java.util.stream.Stream;
 
@RestController
public class WebFluxController {
 
    // 使用 Flux 创建一个简单的响应式响应流
    @GetMapping("/flux")
    public Flux<String> streamFlux() {
        return Flux.fromStream(Stream.of("Hello", "World"))
                   .delayElements(Duration.ofSeconds(1)) // 每个元素间隔1秒发送
                   .log(); // 打印Flux中的日志信息
    }
}

这段代码演示了如何在Spring Boot应用中使用Flux.fromStream创建一个简单的响应式流，每个元素间隔1秒发送，并使用.log()方法打印日志以便于调试。这是学习响应式编程和WebFlux基础的一个很好的起点。