反应式编程之Mono.defer

- 日理万妓 2023-07-03 12:29 13阅读 0赞

本文基于project reactor，，reactor-bom版本为Dysprosium-SR4，project reactor数据源大致可以分为两类：恶汉型跟懒汉型，

mono defer方法创建数据源属于懒汉型，与Mono.just等创建数据源则是恶汉型，下面看一个例子：

@Test
    	public void defer(){
    		//声明阶段创建DeferClass对象
    		
    		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 Feb 07 10:22:51 GMT+08:00 2020  
Fri Feb 07 10:22:51 GMT+08:00 2020  
Fri Feb 07 10:22:51 GMT+08:00 2020  
Fri Feb 07 10:22:56 GMT+08:00 2020

我们可以看到，创建了两个数据源，一个使用Mono.just创建，一个用Mono.defer创建，然后分别通过lambda表达式订阅这两个publisher，可以看到两个输出的时间都是10:22：51，延迟5秒钟后重新订阅，Mono.just创建的数据源时间没变，但是Mono.defer创建的数据源时间相应的延迟了5秒钟，原因在于Mono.just会在声明阶段构造Date对象，只创建一次，但是Mono.defer却是在subscribe阶段才会创建对应的Date对象，每次调用subscribe方法都会创建Date对象，在webflux中

DefaultWebFilterChain的filter方法就有Mono.defer的使用：

/**
         ** 声明一次，但是每次调用filter方法都会调用currentFilter的filter方法或者handler的handle
         ** 方法，这两个方法返回的数据每次都可能会不一样
        ***/
    	@Override
    	public Mono<Void> filter(ServerWebExchange exchange) {
    		return Mono.defer(() ->
    				this.currentFilter != null && this.next != null ?
    						this.currentFilter.filter(exchange, this.next) :
    						this.handler.handle(exchange));
    	}