1. 首页
  2. 开发
  3. 详情

《spring cloud微服务开发》五、服务消费(Ribbon)

changs  • 

Spring Cloud Ribbon

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。它是一个基于HTTP和TCP的客户端负载均衡器。它可以通过在客户端中配置ribbonServerList来设置服务端列表去轮询访问以达到均衡负载的作用。

当Ribbon与Eureka联合使用时,ribbonServerList会被DiscoveryEnabledNIWSServerList重写,扩展成从Eureka注册中心中获取服务实例列表。同时它也会用NIWSDiscoveryPing来取代IPing,它将职责委托给Eureka来确定服务端是否已经启动。

而当Ribbon与Consul联合使用时,ribbonServerList会被ConsulServerList来扩展成从Consul获取服务实例列表。同时由ConsulPing来作为IPing接口的实现。

我们在使用Spring Cloud Ribbon的时候,不论是与Eureka还是Consul结合,都会在引入Spring Cloud Eureka或Spring Cloud Consul依赖的时候通过自动化配置来加载上述所说的配置内容,所以我们可以快速在Spring Cloud中实现服务间调用的负载均衡。

下面我们通过具体的例子来看看如何使用Spring Cloud Ribbon来实现服务的调用以及客户端均衡负载。

基于Spring Cloud Ribbon实现的消费者,我们可以根据eureka-consumer实现的内容进行简单改在就能完成,具体步骤如下

  • pom.xml中引入依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
  • 配置application.properties,指定eureka注册中心的地址:

spring:
  application:
    name: eureka-consumer
server:
  port: 9003
  context-path: /consumer
eureka:
  client:
    service-url:
      defaultZone: http://root:changs@127.0.0.1:9000/eureka/

  • 创建应用主类。初始化RestTemplate,用来真正发起REST请求。@EnableDiscoveryClient注解用来将当前应用加入到服务治理体系中。

@SpringBootApplication
@EnableDiscoveryClient
@ComponentScan(basePackages="com.xzcs")
public class EurekaUserApplication {

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

   @Bean
   @LoadBalanced
   RestTemplate restTemplate() {
      return new RestTemplate();
   }
}
  • 创建一个接口用来消费eureka-client提供的接口:

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    RestTemplate restTemplate;

    @RequestMapping("/getNames")
    public List<String> getNames(){
        List<String> names = restTemplate.getForObject("http://service-common/eurekaClient/user/getNames", List.class);
        return names;
    }

    @RequestMapping("/getName")
    public String getName(){
        String name = restTemplate.getForObject("http://service-common/eurekaClient/user/getName", String.class);
        return name;
    }
}

可以看到这里,我们除了去掉了原来与LoadBalancerClient相关的逻辑之外,对于RestTemplate的使用,我们的第一个url参数有一些特别。这里请求的host位置并没有使用一个具体的IP地址和端口的形式,而是采用了服务名的方式组成。那么这样的请求为什么可以调用成功呢?因为Spring Cloud Ribbon有一个拦截器,它能够在这里进行实际调用的时候,自动的去选取服务实例,并将实际要请求的IP地址和端口替换这里的服务名,从而完成服务接口的调用。

在完成了上面你的代码编写之后,读者可以将eureka-server、eureka-client、eureka-consumer都启动起来,然后访问http://localhost:9003/consumer/user/getNames ,来跟踪观察eureka-consumer服务是如何消费eureka-client服务的/user/getNames接口的。



声明:若要转载FengHuoX中的任何博客请注明转载地址