“負載平衡”可以解釋為維持任何工作負載。例如，如果您早上必須提供 1000 份早餐，您可以將工作分配給 2-3 個或更多的餐飲服務(wù)商，以縮短交付/準備時間。

在計算機世界中，同樣的邏輯也適用，如果你想快速交付，你可以分工，例如一個網(wǎng)站我們可以有5-10個網(wǎng)絡(luò)服務(wù)器，這樣網(wǎng)站會交付得更快（尤其是在高流量的情況下） ），這是服務(wù)器端。

我想談?wù)効蛻舳素撦d平衡及其工作原理，例如您正在查詢每個請求的后端，并且您有多個服務(wù)器執(zhí)行后端工作，為此我將使用 WHOIS 服務(wù)

whois1.service.com whois2.service.com

我們可以對這兩臺服務(wù)器中的每個請求進行負載平衡，最常用的算法和默認循環(huán)意味著每個請求都會依次發(fā)送到一個而不是另一個，例如 who1、who2 who1 等，這可以在客戶端通過“ Spring Cloud 負載均衡器”。我們需要配置3個類

1. ServiceInstanceListSupplier 用于定義后端地址和端口
2. Bean ServiceInstanceListSupplier 用于提供端點列表
3. @LoadBalancerClient，即網(wǎng)絡(luò)客戶端，將用于后端調(diào)用

現(xiàn)在，我們已經(jīng)完成了后端的全部設(shè)置

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();
    }

}

現(xiàn)在可以在任何 @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實現(xiàn)客戶端負載平衡
• Spring Cloud LoadBalancer

以上是什么是負載平衡以及如何在客戶端進行負載平衡的詳細內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！