在服务架构单中,业务会被拆分成一个一个独立的服务,服务与服务之间的通讯是通过Http Rest的,Spring cloud有两种服务调用方式,一种是ribbon+restTemplate,另一种是feign。
1 Ribbon简介
Ribbon是一个基于HTTP和TCP客户端的负载均衡器。Feign中也使用Ribbon,后续会介绍Feign的使用。Ribbon可以在通过客户端中配置的ribbonServerList服务端列表去轮询访问以达到均衡负载的作用。
当Ribbon与Eureka联合使用时,ribbonServerList会被DiscoveryEnabledNIWSServerList重写,扩展成从Eureka注册中心中获取服务端列表。同时它也会用NIWSDiscoveryPing来取代IPing,它将职责委托给Eureka来确定服务端是否已经启动。
下面我们通过实例看看如何使用Ribbon来调用服务,并实现客户端的均衡负载。
2 准备工作
本篇文章是基于上一篇文章的基础之上进行实现的,因此需要三个工程的支持。spring-cloud-eureka和spring-cloud-provide已不必多说。
spring-cloud-provid我们可以创建多个实例,注意并不是创建两个项目,而是一个工程启动两次,通过端口来进行区分,这样的话,我们来创建一个小的集群,以达到负载均衡的目的,端口分别是8081和8083。
除了上述之外,我们只需要再创建一个消费者服务工程即可。
3 创建一个服务消费者(spring-cloud-consumer-ribbon)
第一步:新建一个普通的Spring Boot工程
新建一个普通的Spring Boot工程,并命名为:spring-cloud-consumer-ribbon
第二步:引入依赖
在它的pom.xml继承了父pom文件,并引入了以下依赖
<?xml version="1.0" encoding="UTF-8"?>4.0.0com.brimenspring-cloud-brimen-consumer1.0-SNAPSHOTcom.brimenspring-cloud-consumer-ribbon0.0.1-SNAPSHOTspring-cloud-consumerSpring Cloud 消费者服务org.springframework.bootspring-boot-starter-weborg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.cloudspring-cloud-starter-netflix-ribbonorg.springframework.bootspring-boot-maven-plugin
第三步:在application.yml配置文件当中配置
在工程的配置文件当中指明服务注册中心的地址为:http://localhost:8080/eureka/,服务名称为:spring-cloud-consumer-ribbon,端口为:8082,配置如下:
eureka:client:serviceUrl:defaultZone:http://localhost:8080/eureka/ #1server:port:8082spring:application:name:spring-cloud-consumer-ribbon #2#1、服务注册中心的地址#2、服务的名称,作为其它服务调用的服务名
第四步:在入口类application当中,注入RestTemplate的bean
在入口类application当中,注入RestTemplate的bean,@LoadBalanced注解表明这个RestRemplate开启负载均衡的功能。
packagecom.brimen.springcloudconsumerribbon;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.client.loadbalancer.LoadBalanced;importorg.springframework.context.annotation.Bean;importorg.springframework.web.client.RestTemplate;@SpringBootApplicationpublicclassSpringCloudConsumerRibbonApplication{publicstaticvoidmain(String[] args){ SpringApplication.run(SpringCloudConsumerRibbonApplication.class, args); }@Bean@LoadBalancedRestTemplaterestTemplate(){returnnewRestTemplate(); }}
第五步:写一个HelloServer类来调用服务提供者的接口
写一个HelloService,并通过之前注入的RestTemplate来消费“spring-cloud-provide”的“gethello”接口,在这里我们用具体的服务名来替代url地址,在ribbon中它会根据服务名来选择具体的服务实例,根据服务实例在请求的时候会用具体的url替换掉服务名,代码如下:
packagecom.brimen.springcloudconsumerribbon.service;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service;importorg.springframework.web.client.RestTemplate;@ServicepublicclassHelloService{@Autowired RestTemplate restTemplate;publicString sayHelloFromProvider(String name) {returnrestTemplate.getForObject("http://spring-cloud-provide/hello/gethello?name="+ name, String.class); }}
第六步:写一个Controller,提供对外访问的接口
写一个具体的Controller,提供对外访问的接口,并调用Service的方法,代码如下:
packagecom.brimen.springcloudconsumerribbon.controller;importcom.brimen.springcloudconsumerribbon.service.HelloService;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RequestParam;importorg.springframework.web.bind.annotation.RestController;@RestController@RequestMapping("/hello")public class HelloController {@Autowired public HelloService helloService;@GetMapping(value="/gethello")public String getHello(@RequestParam(value ="name", defaultValue ="ribbon") String name) {returnhelloService.sayHelloFromProvider(name); }}
第七步:启动项目并访问
启动三个工程,spring-cloud-eureka、spring-cloud-provide和spring-cloud-consumer-ribbon,然后打开浏览器,访问消费者服务(spring-cloud-consumer-ribbon)的接口“gethello”,http://localhost:8082/hello/gethello ,连续进行刷新,会发现访问不同的服务提供者(spring-cloud-provide)8081和8083
参考:https://blog.csdn.net/qq_24630433/article/details/87926922http://blog.didispace.com/springcloud2/
https://mp.weixin.qq.com/s/9Je5uAdfJ2uFdDw3Jx7NnA
网友评论