java flux api,JAVA Reactor API 简单使用(Flux和Mono)及WebFlux的应用

Java Flux API和Java Reactor API都是用于响应式编程的工具，其中Flux和Mono是两个核心类。

Flux类代表的是包含0到N个元素的异步序列。这个序列中可以包含三种不同的信号：onNext、onComplete、onError。onNext信号表示序列中的一个元素，onComplete信号表示序列结束，onError信号表示出现错误。

Mono类代表的是包含0或1个元素的异步序列。它和Flux的区别在于，它要么只有一个元素，要么就是空序列。

WebFlux是Spring 5中引入的新的响应式Web框架，它基于Reactor库实现。WebFlux包含两个不同的编程模型：基于注解的模型和函数式编程模型。

下面是一个简单的示例，演示如何使用Flux和Mono：

// 创建一个包含1到10的整数序列
Flux<Integer> flux = Flux.range(1, 10);

// 订阅这个序列并输出每个元素
flux.subscribe(System.out::println);

// 创建一个包含单个字符串元素的Mono
Mono<String> mono = Mono.just("Hello World");

// 订阅这个序列并输出元素
mono.subscribe(System.out::println);

WebFlux的应用示例：

@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/users")
    public Flux<User> getAllUsers() {
        return userService.getAllUsers();
    }

    @GetMapping("/users/{id}")
    public Mono<User> getUserById(@PathVariable("id") String id) {
        return userService.getUserById(id);
    }

    @PostMapping("/users")
    public Mono<User> createUser(@RequestBody User user) {
        return userService.createUser(user);
    }

    @PutMapping("/users/{id}")
    public Mono<User> updateUser(
            @PathVariable("id") String id,
            @RequestBody User user) {
        return userService.updateUser(id, user);
    }

    @DeleteMapping("/users/{id}")
    public Mono<Void> deleteUser(@PathVariable("id") String id) {
        return userService.deleteUser(id);
    }
}

在这个示例中，我们创建了一个名为UserController的REST控制器，它包含了五个不同的请求处理方法。每个方法都返回一个Flux或Mono对象，以实现异步响应式编程。我们还注入了一个名为UserService的服务对象，它提供了所有用户相关的业务逻辑。