Spring Cloud服务消费（基础）

使用LoadBalancerClient

这是一个负载均衡客户端的抽象定义，负载均衡的好处在于：

  • 提供动态的负载均衡功能，可以将所有请求动态分布到其所管理的所有服务实例中进行处理；

所以在分布式系统设计中，负载均衡可以用来实现系统的高可用、集群扩容等功能。负载均衡也分为“客户端负载均衡”和“服务端负载均衡”两种模式。

我们的Spring Cloud Eureka属于客户端负载均衡的情况，所以这里我们用一个具体的例子来演示客户端负载均衡的具体实现。

此Demo需要结合前面已有的eureka-server和eureka-client一起看效果

创建消费服务

还是按照之前的套路，使用Spring Initializer新建一个Spring Boot工程，叫eureka-consumer。

添加依赖

对应的gradle文件如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
plugins {
    id 'org.springframework.boot' version '2.6.3'
    id 'io.spring.dependency-management' version '1.0.11.RELEASE'
    id 'java'
}

group = 'com.hhp.registry'
version = '0.0.1'
sourceCompatibility = '1.8'

repositories {
    maven { url 'https://maven.aliyun.com/repository/public/' }
    mavenLocal()
    mavenCentral()
}

ext {
    set('springCloudVersion', "2021.0.1")
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-actuator'
    implementation 'org.springframework.boot:spring-boot-starter-web'
    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
    }
}

tasks.named('test') {
    useJUnitPlatform()
}

配置服务发现

打开application.yml文件，贴入下列配置：

1
2
3
4
5
6
7
8
9
spring:
  application:
    name: eureka-consumer
server:
  port: 2101
eureka:
  client:
    service-url:
      defaultZone: http://localhost:1001/eureka/

找到Spring Boot启动入口类，在上面加上@EnableDiscoveryClient注解，这里我们把RestTemplate带入我们的配置中：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@EnableDiscoveryClient
@SpringBootApplication
public class EurekaConsumerApplication {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(EurekaConsumerApplication.class, args);
    }

}

创建服务消费接口

我们新建一个接口来消费eureka-client服务

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@RestController
public class DcController {

    @Resource
    private LoadBalancerClient loadBalancerClient;

    @Resource
    private RestTemplate restTemplate;

    @GetMapping("/consumer")
    public String dc() {
        ServiceInstance serviceInstance = loadBalancerClient.choose("eureka-client");
        String url = "http://" + serviceInstance.getHost() + ":" + serviceInstance.getPort() + "/dc";
        System.out.println(url);
        return restTemplate.getForObject(url, String.class);
    }
}

可以看出：

  1. 我们注入了LoadBalancerClient和RestTemplate，并在/consumer接口中实现；
  2. 通过LoadBalancerClient.choose选择出eureka-client的服务实例；
  3. 然后通过ServiceInstance服务的信息拼接出/dc接口的详细地址；
  4. 利用RestTemplate对象实现对服务提供者接口的调用；

最终效果

将eureka-server，eureka-client和eureka-consumer三个服务同时运行起来，然后访问http://localhost:2101/consumer。可以看到当服务器请求过程中，真正调用的是eureka-client，而eureka-consumer会把请求通过网络分发出去。