首页 > 其他 > 详细

Ribbon学习笔记

时间:2020-02-23 01:26:46      阅读:63      评论:0      收藏:0      [点我收藏+]

Ribbon 介绍

官网:https://github.com/Netflix/ribbon/wiki/Getting-Started

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套 客户端 负载均衡 的工具。

简单的说,Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单的说,就是在配置文件中列出Load Balancer(简称LB)后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随机连接等)去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

LB,即负载均衡(Load Balance),在微服务或分布式集群中经常用的一种应用。
负载均衡简单的说就是将用户的请求平摊的分配到多个服务上,从而达到系统的HA。
常见的负载均衡有软件Nginx,LVS,硬件 F5等。
相应的在中间件,例如:dubbo和SpringCloud中均给我们提供了负载均衡,SpringCloud的负载均衡算法可以自定义。

集中式LB

即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件,如F5, 也可以是软件,如nginx), 由该设施负责把访问请求通过某种策略转发至服务的提供方;

进程内LB

将LB逻辑集成到消费方,消费方从服务注册中心获知有哪些地址可用,然后自己再从这些地址中选择出一个合适的服务器。

Ribbon就属于进程内LB,它只是一个类库,集成于消费方进程,消费方通过它来获取到服务提供方的地址。

配置步骤:

第一步:修改microservicecloud-consumer-dept-80工程的pom文件,导入Ribbon Jar 包

???<!-- Ribbon相关 -->
??
???<!--Ribbon需要和Eureka整和需要的包Eureka客户端-->
???<dependency>
?????<groupId>org.springframework.cloud</groupId>
?????<artifactId>spring-cloud-starter-eureka</artifactId>
???</dependency>
???<dependency>
?????<groupId>org.springframework.cloud</groupId>
?????<artifactId>spring-cloud-starter-ribbon</artifactId>
???</dependency>
???<dependency>
?????<groupId>org.springframework.cloud</groupId>
?????<artifactId>spring-cloud-starter-config</artifactId>
???</dependency>

第二步:修改application.yml 追加eureka的服务注册地址

eureka:
  client:
    register-with-eureka: false
    service-url: 
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/  

第三步:对ConfigBean进行新注解@LoadBalanced 获得Rest时加入Ribbon的配置

由于Spring Cloud Ribbon是基于Netflix Ribbon实现的一套 客户端 负载均衡 的工具,所有只需要在ConfigBean中对RestTemplate 加上注解:

@Configuration
public class ConfigBean {

    @Bean
    @LoadBalanced
    public RestTemplate  getRestTemplate() {
        return new RestTemplate();
    }
}

第四步:主启动类DeptConsumer80_App添加@EnableEurekaClient

@SpringBootApplication
@EnableEurekaClient
public class DeptConsumer80_App {
    public static void main(String[] args) {

        SpringApplication.run(DeptConsumer80_App.class,args);
    }

第五步:修改DeptController_Consumer客户端访问类,将Eureka服务端地址该微服务名字

package cn.blogsx.springcloud.controller;

import cn.blogsx.springcloud.entities.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.List;

/**
 * @author Alex
 * @create 2020-02-21 13:11
 **/
@RestController
public class DeptController_Consumer {

//    private static final String REST_URL_PREFIX="http://localhost:8001";
    private static final String REST_URL_PREFIX="MICROSERVICECLOUD-DEPT";

    @Autowired
    private RestTemplate restTemplate;

    @RequestMapping(value = "/consumer/dept/add")
    public boolean add(Dept dept) {
        return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept,Boolean.class);
    }

    @RequestMapping(value = "/consumer/dept/get/{id}")
    public Dept get(@PathVariable("id") Long id) {
        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id,Dept.class);
    }

    @RequestMapping(value = "/consumer/dept/list")
    public List<Dept> list() {

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list/",List.class);
    }
    //测试@EnableDiscoveryClient,消费端可以调用服务发现
    @RequestMapping(value = "/consumer/dept/discovery")
    public Object discovery() {
            return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery",Object.class);
    }

}

Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号

Ribbon学习笔记

原文:https://www.cnblogs.com/sxblog/p/12348085.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!