本文共 11180 字,大约阅读时间需要 37 分钟。
SpringCloudRibbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。
简单的说,Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法和服务调用。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单的说,就是在配置文件中列出Load Balancer(简称LB)后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随机连接等)去连接这些机器。可以很容易使用Ribbon实现自定义的负载均衡算法。1.LB负载均衡(Load Balance)是什么
简单的说就是将用户的请求平摊的分配到多个服务上,从而达到系统的HA(高可用)。 常见的负载均衡有软件Nginx、LVS、硬件F5等。2.Ribbon本地负载均衡客户端VS Nginx服务端负载均衡区别
Nginx是服务器负载均衡,客户端所有请求都会交给nginx,然后由nginx实现转发请求。即负载均衡是由服务端实现的。
Ribbon本地负载均衡,在调用微服务接口时候,会在注册中心上获取注册信息服务列表之后缓存到JVM本地,从而在本地实现RPC远程服务调用技术。
即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件,如F5,也可以是软件,如nginx),由该设施负责把访问请求通过某种策略转发至服务的提供方。
将LB逻辑集成到消费方,消费方从服务注册中心获知有哪些地址可用,然后自己再从这些地址中选择出一个合适的服务器。
Ribbon就属于进程内LB,它只是一个类库,集成于消费方进程,消费方通过它来获取服务提供方的地址。总结一句话来说就是:负载均衡+RestTemplate调用
总结:Ribbon其实就是一个软负载均衡的客户端组件,它可以和其他所需请求的客户端结合使用,和eureka结合只是其中的一个实例。
在消费者80模块 controller中编写代码如下:
@RestController@Slf4jpublic class OrderController { // public static final String PAYMENT_URL="http://localhost:8001"; public static final String PAYMENT_URL="http://CLOUD-PAYMENT-SERVICE"; @Autowired private RestTemplate restTemplate; @GetMapping("/consumer/payment/create") public CommonResultcreate(Payment payment){ //参数1:支付模块的请求地址 //参数2: 传给支付模块的参数 //参数3:返回给客户端消费者的结果 是个.class字节码文件 return restTemplate.postForObject(PAYMENT_URL+"/payment/create",payment,CommonResult.class); } @GetMapping("/consumer/payment/get/{id}") public CommonResult getPayment(@PathVariable("id") Long id){ //参数1:支付模块的请求地址 //参数2:返回给客户端消费者的结果 是个.class字节码文件 return restTemplate.getForObject(PAYMENT_URL+"/payment/get/"+id,CommonResult.class); } @GetMapping("/consumer/payment/ForEntity/{id}") public CommonResult getForEntity(@PathVariable("id") Long id){ ResponseEntity entity = restTemplate.getForEntity(PAYMENT_URL+"/payment/get/"+id,CommonResult.class); if(entity.getStatusCode().is2xxSuccessful()){ return entity.getBody(); }else{ return new CommonResult(444,"操作失败"); } }}
测试:可以发现Ribbion通过轮询的策略,负载均衡到每一台服务器上。
IRule:根据特定算法从服务列表中选取一个要访问的服务。有如下七种算法:
官方文档明确给出了警告:
这个自定义配置类不能放在@ComponentScan所扫描的当前包下以及子包下,否则我们自定义的这个配置类就会被所有的Ribbon客户端所共享,达不到特殊化定制的目的了。总结一句话说,不能和主启动类在同一个包下。 目录结构如下:
@Configurationpublic class MySelfRule { @Bean public IRule myRule(){ return new RandomRule(); //定义为随机 }}
@SpringBootApplication@EnableEurekaClient//name是服务注册中心提供者的名字,configuration是定义Ribbon负载均衡策略配置类@RibbonClient(name = "CLOUD-PAYMENT-SERVICE",configuration = MySelfRule.class)public class OrderMain80 { public static void main(String[] args) { SpringApplication.run(OrderMain80.class,args); }}
负载均衡算法:rest接口第几次请求数%服务器集群总数量 = 实际调用服务器位置下标,每次服务重启动后rest接口技术从1开始。
可以通过下列代码,获取集群的列表,是一个List集合
Listinstances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");如: List[0] instances = 127.0.0.1:8002 List[1] instances = 127.0.0.1:8001
8001+8002组合成为集群,它们共计2台机器,集群总数为2,按照轮询算法原理:
CAS+自旋锁
1.7001/7002集群启动
2.在8001/8002controller加上下面这行代码@GetMapping(value = "/payment/lb") public String getPaymentLB(){ return serverPort; }
3.80订单服务改造
3.1在ApplicationContextBean去掉@LoadBalanced@Bean// @LoadBalanced //使用@LoadBalanced注解赋予RestTemplate负载均衡的能力 public RestTemplate getRestTemplate(){ return new RestTemplate(); }
3.2编写LoadBalancer接口
public interface LoadBalancer { //收集服务器总共有多少台能够提供服务的集群,并放到List里面 ServiceInstance instance(ListserviceInstances);}
3.3编写接口的实现类MyLB
@Componentpublic class MyLB implements LoadBalancer { private AtomicInteger atomicInteger = new AtomicInteger(0); //下标 private final int getAndIncrement(){ int current; int next; do { current = this.atomicInteger.get(); next = current >= 2147483647 ?0:current+1; }while (!this.atomicInteger.compareAndSet(current,next)); System.out.println("第几次访问,次数next:"+next); return next; } @Override public ServiceInstance instance(ListserviceInstances) { //得到机器的列表 int index = getAndIncrement()%serviceInstances.size(); //得到服务器的下标位置 return serviceInstances.get(index); }}
3.4OrderController类中添加
@Autowired private RestTemplate restTemplate; @Autowired private LoadBalancer loadBalancer; @Autowired private DiscoveryClient discoveryClient; @GetMapping(value = "/consumer/payment/lb") public String getPaymentLB(){ Listinstances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE"); //如果获取的机器列表为空,或者数量小于0 直接返回null if(instances==null || instances.size()<=0){ return null; } //自定义的轮询算法,获取处理的机器 ServiceInstance serviceInstance = loadBalancer.instance(instances); URI uri = serviceInstance.getUri(); return restTemplate.getForObject(uri+"/payment/lb",String.class); }
测试:可以发现,每刷新一次都是在轮询调用的服务提供者。,并且访问的次数在不断的增加,如下图所示:
Feign是一个声明式WebService客户端。使用Feign能让编写Web Service客户端更加简单。 它的使用方法是定义一个服务接口然后在上面添加注解。Feign也支持可拔插式的编码器和解码器。SpringCloud 对Fegin进行了封装,使其支持了SpringMVC标准注解和HttpMessageConverters。Feign可以与Eureka和Ribbon组合使用以支持负载均衡。
总结来说:Feign是一个声明式的web服务客户端,让编写web服务客户端变得非常容易,只需创建一个接口并在接口上添加注解即可。
Feign使用编写Java Http客户端变得更容易。
前面在使用Ribbon+RestTemplate时,利用RestTemplate对http请求的封装处理,形成了一套模板化的调用方法。但在实际开发中,由于对服务依赖的调用可能不止一处,往往一个接口会被多处调用,所以通常都会针对每个微服务自行封装一些客户端来包装这些依赖服务的调用。所以,Fegin在此基础上做了进一步封装,由他来帮助我们定义和实现依赖服务接口的定义。在Feign的实现下,我们只需创建一个接口并使用注解的方式来配置它(以前是Dao接口上面标注Mapper注解,现在是一个微服务接口上面标注一个Feign注解即可) ,即可完成对服务提供方的接口绑定,简化了使用Spring cloud Ribbon时,自动封装服务调用客户端的开发量。Feign集成了Ribbon
利用Ribbon维护了Payment的服务列表信息,并且通过轮询实现了客户端的负载均衡。而与Ribbon不同的是,通过feign只需要定义服务绑定接口且以声明式的方法,优雅而简单的实现了服务调用。就是A要调用B,Feign就是在A中创建一个一模一样的B对外提供服务的的接口,我们调用这个接口,就可以服务到B。
使用接口+注解的方式:微服务调用接口+@FeignClient
Feign在消费端使用。
cloud123 com.atguigu.springcloud 1.0-SNAPSHOT 4.0.0 cloud-consumer-feign-order80 org.springframework.cloud spring-cloud-starter-openfeign org.springframework.cloud spring-cloud-starter-netflix-eureka-client com.atguigu.springcloud cloud-api-commons ${ project.version} org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-actuator org.springframework.boot spring-boot-devtools runtime true org.projectlombok lombok true org.springframework.boot spring-boot-starter-test test
server: port: 80eureka: client: register-with-eureka: false service-url: defaultZone: http://eureka7001.com:7001/eureka, http://eureka7002.com:7002/eureka
在主启动类上加@EnableFeignClients注解
@SpringBootApplication@EnableFeignClientspublic class OrderFeignMain80 { public static void main(String[] args) { SpringApplication.run(OrderFeignMain80.class,args); }}
业务逻辑接口+@FeignClient配置调用provider服务。
@Component@FeignClient(value = "CLOUD-PAYMENT-SERVICE") //对应注册在Eureka 服务名称public interface PaymentFeignService { @GetMapping(value = "/payment/get/{id}") //对应服务提供者controller层的方法 CommonResultgetPaymentById(@PathVariable("id") Long id);}
@RestControllerpublic class OrderFeignController { @Autowired private PaymentFeignService paymentFeignService; @GetMapping(value = "/consumer/payment/get/{id}") public CommonResultgetPaymentById(@PathVariable("id") Long id){ return paymentFeignService.getPaymentById(id); }}
测试: 访问http://localhost/consumer/payment/get/31,可以发现Feign自带负载均衡配置项。
1.服务提供方8001故意写暂停程序
在controller添加下列代码@GetMapping(value = "/payment/feign/timeout") public String paymentFeignTimeout(){ try { TimeUnit.SECONDS.sleep(3); }catch (Exception e){ } return serverPort; }
2.服务消费方80PaymentFeignService接口中添加添加超时方法
@GetMapping(value = "/payment/feign/timeout") public String paymentFeignTimeout();
3.服务消费方80OrderFeignController中添加超时方法
@GetMapping(value = "/consumer/payment/feign/timeout") public String paymentFeignTimeout(){ return paymentFeignService.paymentFeignTimeout(); }
运行结果如下图所示:
OpenFeign默认等待一秒钟,超过后就会报错。默认Feign客户端只等待一秒钟,但是服务端处理需要超过1秒钟,导致Feign客户端不想等待了,直接返回报错。为了避免这样的情况,我们可以设置设置Feign客户端的超时控制。
4.80模块中YML文件里开启OpenFeign客户端超时控制
#设置feign客户端超时时间(OpenFeign默认支持ribbon)ribbon:#指的是建立连接所用的时间,适用于网络状况正常的情况下,两端连接所用的时间 ReadTimeout: 5000 #指的是建立连接后从服务器读取到可用资源所用的时间 ConnectTimeout: 5000
Feign提供了日志打印功能,我们可以通过配置来调子日志级别,从而了解Feign中Http请求的细节。
说白了就是对Feign接口的调用情况进行监控和输出。再80模块创建FeignConfig.java
@Configurationpublic class FeignConfig { @Bean Logger.Level feignLoggerLever(){ return Logger.Level.FULL; }}
logging: level: #feign日志以什么级别监控哪个接口 com.donggua.springclou.service.PaymentFeignService:debug
转载地址:http://tpiwi.baihongyu.com/