Mono.defer方法创建数据源属于懒汉型,Mono.just方法创建数据源属于恶汉型,下面看一个例子:
package com.example.demo;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import reactor.core.publisher.Mono;
import java.util.Date;
@SpringBootTest
class DemoApplicationTests {
@Test
void contextLoads() {
//恶汉型:比较霸道,只创建一次
Mono<Date> m1 = Mono.just(new Date());
//懒汉型:比较懒,每次调用才创建
Mono<Date> m2 = Mono.defer(() -> Mono.just(new Date()));
m1.subscribe(System.out::println);
m2.subscribe(System.out::println);
//延迟5秒钟
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
m1.subscribe(System.out::println);
m2.subscribe(System.out::println);
}
}
输出结果
Fri Jun 04 15:25:20 CST 2021
Fri Jun 04 15:25:20 CST 2021
Fri Jun 04 15:25:20 CST 2021
Fri Jun 04 15:25:25 CST 2021
我们可以看到,创建了两个数据源,一个使用Mono.just创建,一个用Mono.defer创建,然后分别通过lambda表达式订阅这两个publisher,可以看到两个输出的时间都是15:25:20,延迟5秒钟后重新订阅,Mono.just创建的数据源时间没变,但是Mono.defer创建的数据源时间相应的延迟了5秒钟,原因在于Mono.just会在声明阶段构造Date对象,只创建一次,但是Mono.defer却是在subscribe阶段才会创建对应的Date对象,每次调用subscribe方法都会创建Date对象