给我一个Java的响应式编程案例
时间: 2023-03-12 12:55:15 浏览: 103
响应式编程是一种编程范式,旨在解决异步数据流和事件驱动的编程问题。在 Java 中,可以使用 Reactor 等框架来实现响应式编程。
下面是一个使用 Reactor 的响应式编程的示例,它演示了如何通过 Flux 对象来发布事件,并使用 Subscriber 对象来订阅这些事件:
```
import reactor.core.publisher.Flux;
public class ReactiveExample {
public static void main(String[] args) {
Flux<Integer> numbers = Flux.range(1, 10);
numbers.subscribe(
System.out::println, // onNext
System.err::println, // onError
() -> System.out.println("Done") // onComplete
);
}
}
```
上面的代码会生成一个包含数字 1 到 10 的 Flux 对象,然后使用 subscribe() 方法订阅它。在这个例子中,我们传入了三个 lambda 表达式,分别对应 onNext、onError 和 onComplete 事件的处理器。当 Flux 对象发布一个事件时,它会调用对应的处理器进行处理。在这个例子中,每当 Flux 对象发布一个数字时,它都会调用 onNext 处理器,并将数字作为参数传入。