Project Reactor

동기 호출을 비동기로 전환하기(JDBC 등)

CompletableFuture, @Async, 그리고 Reactor가 제공해주는 기능등을 통해 동기 호출을 쓰레드 기반 비동기로 전환할 수 있다.
reactive programming - Spring webflux and reading from database - Stack Overflow
Reactor 3 Reference Guide Blocking 호출을 비동기로 전환하기
Spring 5 WebFlux and JDBC: To Block or Not to Block - DZone Java
Reactive systems using Reactor
Spring Data JPA @Aync 참조. CompletableFuture → Mono/Flux 전환 가능

Mono blockingWrapper = Mono.fromCallable(() -> { 
    return /* make a remote synchronous call */ 
});
blockingWrapper = blockingWrapper.subscribeOn(Schedulers.elastic());

@GetMapping(value = "/v1/measurements")
public Flux<Measurement> getMeasurements() {
    return Flux.defer(() -> Flux.fromIterable(repository.findByFromDateGreaterThanEqual(new Date(1486980000L))))
           .subscribeOn(Schedulers.elastic());
}

@Configuration
public class SchedulerConfiguration {
    private final Integer connectionPoolSize;
    public SchedulerConfiguration(@Value("${spring.datasource.maximum-pool-size}") Integer connectionPoolSize) {
        this.connectionPoolSize = connectionPoolSize;
    }
    @Bean
    public Scheduler jdbcScheduler() {
        return Schedulers.fromExecutor(Executors.newFixedThreadPool(connectionPoolSize));
    }
}
 
@Service
public class AddressService {
    private final AddressRepository repository;
    private final Scheduler scheduler;
    public AddressRouter(AddressRepository repository, @Qualifier("jdbcScheduler") Scheduler scheduler) {
        this.repository = repository;
        this.scheduler = scheduler;
    }
    public Mono<Iterable<Address>> findAll() {
        return async(() -> repository.findAll());
    }
    private <T> Mono<T> async(Callable<T> callable) {
        return Mono.fromCallable(callable).publishOn(scheduler);
    }
}

Tuning

Block Hound

권남

사이드바

목차

Project Reactor

동기 호출을 비동기로 전환하기(JDBC 등)

Tuning

참조

권남

사용자 도구

사이트 도구

사이드바

목차

Project Reactor

동기 호출을 비동기로 전환하기(JDBC 등)

Tuning

참조

문서 도구