'?? ???'? ????? ???? ??? ??? ? ????. ?? ??, ??? 1000?? ?? ??? ???? ?? ?? 2~3? ??? ???? ????? ??? ??? ??/?? ??? ?? ? ????.

??? ????? ??? ??? ?????. ??? ???? ??? ??? ?? ? ????. ?? ?? ????? ?? 5~10?? ? ??? ??? ? ??? ??? ?? ????? ? ??? ?????(?? ???? ?? ??) ), ??????.

????? ? ?? ???? ??? ??? ????? ????? ????. ?? ?? ?? ??? ???? ???? ???? ??? ??? ???? ?? ??? ????. ?? ?? WHOIS ???? ???????.

whois1.service.com whois2.service.com

?? ?? ???? ????? ?? ??? ????? ? ??? ?? ??? ???? ?? ???? ??? ? ????. ?, who1, who2 who1 ?? ?? ?? ??? ?? ?????. ?? ????? ??? " ??? ???? LoadBalancer”. 3?? ???? ???? ???

1. ??? ?? ? ?? ??? ?? ServiceInstanceListSupplier
2. ?? ??? ??? ???? ?? Bean ServiceInstanceListSupplier
3. ? ?????? @LoadBalancerClient? ??? ??? ?????

?? ???? ?? ?? ??? ???????

public class RestCaller implements ServiceInstanceListSupplier {

    private final String serviceId;

    public RestCaller(String serviceId) {
        this.serviceId = serviceId;
    }

    @Override
    public String getServiceId() {
        return serviceId;
    }

    @Override
    public Flux<List<ServiceInstance>> get() {
        return Flux.just(Arrays.asList(
                new DefaultServiceInstance(serviceId, serviceId, "abc.cyclic.app", 443, true),
                new DefaultServiceInstance(serviceId, serviceId, "someting.koyeb.app", 443, true),
                new DefaultServiceInstance(serviceId, serviceId, "127.0.0.1", 8080, false)
        ));
    }
}


@Configuration
public class RestCallerConfiguration {

    @Autowired
    @Qualifier("webClientBuilder")
    WebClient.Builder webClientBuilder;

    @Bean
    @Primary
    ServiceInstanceListSupplier serviceInstanceListSupplier(ConfigurableApplicationContext ctx) {
        return ServiceInstanceListSupplier
                .builder()
                .withRetryAwareness()
                .withHealthChecks(webClientBuilder.build())
                .withBase(new RestCaller("whoisService"))
                .build(ctx);
    }
}


@Configuration
@LoadBalancerClient(name = "whoisService", configuration = RestCallerConfiguration.class)
public class WebClientConfig {

    @LoadBalanced
    @Bean
    @Qualifier("loadBalancedWebClientBuilder")
    WebClient.Builder loadBalancedWebClientBuilder() {
        return WebClient.builder();
    }

    @Bean
    @Qualifier("webClientBuilder")
    WebClient.Builder webClientBuilder() {
        return WebClient.builder();
    }

}

?? ?? @Component ?? @Service?? ??? ? ????.

@Component
public class WhoisCaller {

    @Autowired
    @Qualifier("loadBalancedWebClientBuilder")
    WebClient.Builder webClientBuilder;

    public String getWhois(String ip, String source) {
        String url = "http://whoisService/whois?ip=" + ip + "&source=" + source;

        return webClientBuilder.build()
                .get()
                .uri(url)
                .retrieve()
                .bodyToMono(String.class)
                .timeout(Duration.ofMinutes(1))
                .doOnError(e -> {
                    WebClientResponseException e1 = (WebClientResponseException) e;
                    log.error(e1.getRequest().getURI().getHost());
                })
                .block();
    }
}

????:

• ???? ???? ????? ? ?? ???? ???? ??? ???? ?? SO? ?? ? ??
• Spring Cloud LoadBalancer

? ??? ?? ????? ???? ????? ??? ?? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!