《spring cloud微服务开发》五、服务消费(Ribbon)
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
接口的。