SpringCloud之loadbalancer負(fù)載均衡組件實(shí)戰(zhàn)詳解

更新時(shí)間：2023年06月15日 16:45:25 作者：吃貓的魚(yú)_ 創(chuàng)作等級(jí)LV.3

LoadBalancer是Spring Cloud官方提供的負(fù)載均衡組件，可用于替代Ribbon，這篇文章主要介紹了SpringCloud之loadbalancer負(fù)載均衡組件,需要的朋友可以參考下

SpringCloud之loadbalancer負(fù)載均衡組件

概述

在Spring Cloud 2020版本后，默認(rèn)移除了對(duì)Netflix的依賴，作為負(fù)載均衡組件的Ribbon被棄用了，官方默認(rèn)推薦使用的是Loadbalancer。

LoadBalancer簡(jiǎn)介

LoadBalancer是Spring Cloud官方提供的負(fù)載均衡組件，可用于替代Ribbon。其使用方式與Ribbon基本兼容，可以從Ribbon進(jìn)行平滑過(guò)渡。

官方文檔

使用

依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

RestTemplate配置

@Configuration
public class RestTemplateConfig {
    @Bean
    @ConfigurationProperties(prefix = "rest.template.config")
    public HttpComponentsClientHttpRequestFactory customHttpRequestFactory() {
        return new HttpComponentsClientHttpRequestFactory();
    }
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate(customHttpRequestFactory());
    }
}

服務(wù)提供者接口

@RestController
@RequestMapping("/user")
public class UserLoadBalancerController {
    @Autowired
    private RestTemplate restTemplate;
    @Value("${service-url.nacos-user-service}")
    private String userServiceUrl;
    @GetMapping("/{id}")
    public CommonResult getUser(@PathVariable Long id) {
        return restTemplate.getForObject(userServiceUrl + "/user/{1}", CommonResult.class, id);
    }
}

服務(wù)實(shí)例緩存

LoadBalancer為了提高性能，不會(huì)在每次請(qǐng)求時(shí)去獲取實(shí)例列表，而是將服務(wù)實(shí)例列表進(jìn)行了本地緩存。
默認(rèn)的緩存時(shí)間為35s，為了減少服務(wù)不可用還會(huì)被選擇的可能性，我們可以進(jìn)行如下配置。

spring:
  cloud:
    loadbalancer:
      cache: # 負(fù)載均衡緩存配置
        enabled: true # 開(kāi)啟緩存
        ttl: 5s # 設(shè)置緩存時(shí)間
        capacity: 256 # 設(shè)置緩存大小

HTTP請(qǐng)求轉(zhuǎn)換

如果你想在每次遠(yuǎn)程調(diào)用中傳入自定義的請(qǐng)求頭的話，可以試試LoadBalancerRequestTransformer，通過(guò)它可以對(duì)原始請(qǐng)求進(jìn)行一定的轉(zhuǎn)換。

首先我們需要配置好LoadBalancerRequestTransformer的Bean實(shí)例，這里我們將ServiceInstance的instanceId放入到請(qǐng)求頭X-InstanceId中；

@Configuration
public class LoadBalancerConfig {
    @Bean
    public LoadBalancerRequestTransformer transformer() {
        return new LoadBalancerRequestTransformer() {
            @Override
            public HttpRequest transformRequest(HttpRequest request, ServiceInstance instance) {
                return new HttpRequestWrapper(request) {
                    @Override
                    public HttpHeaders getHeaders() {
                        HttpHeaders headers = new HttpHeaders();
                        headers.putAll(super.getHeaders());
                        headers.add("X-InstanceId", instance.getInstanceId());
                        return headers;
                    }
                };
            }
        };
    }
}

在服務(wù)提供接口中打印請(qǐng)求頭

@RestController
@RequestMapping("/user")
public class UserController {
    @GetMapping("/{id}")
    public CommonResult<User> getUser(@PathVariable Long id) {
        User user = userService.getUser(id);
        LOGGER.info("根據(jù)id獲取用戶信息，用戶名稱為：{}", user.getUsername());
        ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        HttpServletRequest request = servletRequestAttributes.getRequest();
        String instanceId = request.getHeader("X-InstanceId");
        if (StrUtil.isNotEmpty(instanceId)) {
            LOGGER.info("獲取到自定義請(qǐng)求頭:X-InstanceId={}", instanceId);
        }
        return new CommonResult<>(user);
    }
}

到此這篇關(guān)于SpringCloud之loadbalancer負(fù)載均衡組件的文章就介紹到這了,更多相關(guān)SpringCloud loadbalancer負(fù)載均衡內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: