LoadBalancerSpringCloud微服务组件LoadBalancer

Posted Cry丶

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了LoadBalancerSpringCloud微服务组件LoadBalancer相关的知识,希望对你有一定的参考价值。

文章目录

1. 什么是Spring Cloud LoadBalancer

Spring Cloud LoadBalancer是Spring Cloud官方自己提供的客户端负载均衡器, 用来替代Ribbon。
官网地址: https://spring.io/guides/gs/spring-cloud-loadbalancer/

Spring官方提供了两种负载均衡的客户端:

1)RestTemplate

RestTemplate是Spring提供的用于访问Rest服务的客户端,RestTemplate提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。默认情况下,RestTemplate默认依赖jdk的HTTP连接工具。

2)WebClient

WebClient是从Spring WebFlux 5.0版本开始提供的一个非阻塞的基于响应式编程的进行Http请求的客户端工具。它的响应式编程的基于Reactor的。WebClient中提供了标准Http请求方式对应的get、post、put、delete等方法,可以用来发起相应的请求。

2. RestTemplate整合LoadBalancer

1)引入依赖

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

<!-- 提供了RestTemplate支持 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<!-- nacos服务注册与发现  移除ribbon支持-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    <exclusions>
        <exclusion>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </exclusion>
    </exclusions>
</dependency>

注意: nacos-discovery中引入了ribbon,需要移除ribbon的包
如果不移除,也可以在yml中配置不使用ribbon

spring:
  application:
    name: mall-user-loadbalancer-demo
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
    # 不使用ribbon
    loadbalancer:
      ribbon:
        enabled: false

原理:默认情况下,如果同时拥有RibbonLoadBalancerClient和BlockingLoadBalancerClient,为了保持向后兼容性,将使用RibbonLoadBalancerClient。要覆盖它,可以设置spring.cloud.loadbalancer.ribbon.enabled属性为false。

2)使用@LoadBalanced注解配置RestTemplate

@Configuration
public class RestConfig 
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() 
        return new RestTemplate();
    

3) 使用

@RestController
@RequestMapping("/user")
public class UserController 

    @Autowired
    private RestTemplate restTemplate;

    @RequestMapping(value = "/findOrderByUserId/id")
    public R findOrderByUserId(@PathVariable("id") Integer id) 
        String url = "http://mall-order/order/findOrderByUserId/"+id;
        R result = restTemplate.getForObject(url,R.class);
        return result;
    

3. WebClient整合LoadBalancer

1)引入依赖

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

<!-- webflux -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>


<!-- nacos服务注册与发现 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    <exclusions>
        <exclusion>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </exclusion>
    </exclusions>
</dependency>

2) 配置WebClient作为负载均衡器的client

@Configuration
public class WebClientConfig 

    @LoadBalanced
    @Bean
    WebClient.Builder webClientBuilder() 
        return WebClient.builder();
    
    
    @Bean
    WebClient webClient() 
      return webClientBuilder().build();
    

3) 使用

@Autowired
private WebClient webClient;

@RequestMapping(value = "/findOrderByUserId2/id")
public Mono<R> findOrderByUserIdWithWebClient(@PathVariable("id") Integer id) 

    String url = "http://mall-order/order/findOrderByUserId/"+id;
    //基于WebClient
    Mono<R> result = webClient.get().uri(url)
            .retrieve().bodyToMono(R.class);
    return result;

原理: 底层会使用ReactiveLoadBalancer

引入webFlux

@Autowired
private ReactorLoadBalancerExchangeFilterFunction lbFunction;

@RequestMapping(value = "/findOrderByUserId3/id")
public Mono<R> findOrderByUserIdWithWebFlux(@PathVariable("id") Integer id) 

    String url = "http://mall-order/order/findOrderByUserId/"+id;
    //基于WebClient+webFlux
    Mono<R> result = WebClient.builder()
            .filter(lbFunction)
            .build()
            .get()
            .uri(url)
            .retrieve()
            .bodyToMono(R.class);
    return result;

以上是关于LoadBalancerSpringCloud微服务组件LoadBalancer的主要内容,如果未能解决你的问题,请参考以下文章

微服务实战:选择微服务部署策略

微服务实战

微服务实践:微服务的事件驱动数据管理

Chris Richardson微服务实战系列

微服务实战:选择微服务部署策略

微服务实践:从单体式架构迁移到微服务架构