Ribbon

初识Ribbon

Ribbon是什么

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

Ribbon能干什么

  前面提到说Ribbon的作用就是向客户端提供负载均衡算法的工具,那么什么是负载均衡呢?负载均衡就是将用户发来的请求通过算法均摊到多个服务上,从而达到系统的HA(高可用性)

  其中,负载均衡又可分为本地负载均衡(进程内LB)和服务端负载均衡(集中式LB),服务端负载均衡以Nginx为例,用户的所有请求都会交给Nginx,由其决定请求将被转发到哪个服务器;Ribbon是本地负载均衡,在调用接口的时候从 eureka 注册中心服务器端上获取服务注册信息列表缓存到本地,从而可以在本地实现RPC远程调用服务

使用Ribbon实现负载均衡

  实际上Ribbon可以简单的理解为负载均衡算法 RestTemplate的调用,也就是说想要使用Ribbon实现负载均衡,就可以通过这两个技术加以实现。

RestTemplate三步走

  第一步: 引入Ribbon场景启动器依赖,但是之前使用eureka的时候我们在pom文件中导入过netflix-eureka-server的依赖,其中就默认引入了ribbon的场景启动器依赖(netflix-eureka-client也会默认导入),如果再引一次也可以,但是真没那必要。

  第二步: 使用配置文件开启 RestTemplate

/**
 * @ClassName: ApplicationContextConfig
 * @Description: 程序配置类,用于开启RestTemplate服务,以供后面使用
 * @author: chenhao
 * @date: 2022/7/17
 */
@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

  第三步: 使用RestTemplate的API实现负载均衡,RestTemplate的API根据请求方式的不同可以被分为get和post,根据返回类型又可以分为Object(响应体转化成的json串)和Entity(响应的重要信息,包括响应头、状态码、响应体等,可以使用对应的get方法获取到值),所以说最主要的四个API是getForObject、postForObject、getForEntity、postForEntity,这里我把四种API的使用方法都向大家介绍一下

@RestController
@Slf4j
@RequestMapping("consumer")
@Api("消费者的订单管理类")
public class OrderController {
	// 先注入RestTemplate对象
    @Resource
    private RestTemplate restTemplate;
	// 使用API实现负载均衡
    @ApiOperation(value = "创建一条支付记录", tags = ApiVersionConstant.v1_0)
    @PostMapping(value = "/payment/create", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Integer> create(@RequestBody Payment payment) {
        return restTemplate.postForObject(UrlConstant.CLUSTER_PAYMENT_URL   "/payment/create", payment, CommonResult.class);
    }
    @ApiOperation(value = "根据ID查询支付记录", tags = ApiVersionConstant.v1_0)
    @GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Payment> getPayment(@PathVariable("id") Integer id) {
        return restTemplate.getForObject(UrlConstant.CLUSTER_PAYMENT_URL   "/payment/get/"   id, CommonResult.class);
    }
    @ApiOperation(value = "根据ID查询支付记录Entity", tags = ApiVersionConstant.v1_0)
    @GetMapping(value = "/payment/getForEntity/{id}", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Payment> getPaymentEntity(@PathVariable("id") Integer id) {
        ResponseEntity<CommonResult> entity = restTemplate.getForEntity(UrlConstant.CLUSTER_PAYMENT_URL   "/payment/get/"   id, CommonResult.class);
        if (entity.getStatusCode().is2xxSuccessful()) {
            return entity.getBody();
        } else {
            return new CommonResult<>(444, "操作失败");
        }
    }
    @ApiOperation(value = "创建一条支付记录Entity", tags = ApiVersionConstant.v1_0)
    @PostMapping(value = "/payment/createEntity", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Integer> createEntity(@RequestBody Payment payment) {
        return restTemplate.postForEntity(UrlConstant.CLUSTER_PAYMENT_URL   "/payment/create", payment, CommonResult.class)
                .getBody();
    }
}

负载均衡算法

  经过我们上面的尝试,不难发现使用RestTemplate实现的负载均衡算法是轮询机制,实际上IRule中不仅仅只提供了一种算法

IRule实现算法切换

  第一步: 新建一个package,在官方文档中声明了IRule的配置类不能放到@ComponentScan注解所能扫描到的当前包以及子包下,否则自定义的配置类就会被Ribbon的所有客户端所共享,以至于失去客户端定制化的可能性。主程序入口上的@SpringBootApplication注解是复合注解,其中就包含@ComponentScan注解,而且是直接扫描主程序入口所在的当前包以及子包,也就是说配置类必须放到主程序入口之外的包下,于是需要新建一个package

  第二步: 在新建的包中新建一个MySelfRule规则类,用于设置轮询算法,如果不设置的话就默认为轮询

@Configuration
public class MySelfRule {
    @Bean
    public IRule myRule() {
        // 修改轮询算法为随机算法
        return new RandomRule();
    }
}

  第三步: 主启动类上使用@RibbonClient(name = “CLOUD-PAYMENT-SERVICE”, configuration = MySelfRule.class)注解,用于指定应用服务和自定义算法规则的配置类

@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "CLOUD-PAYMENT-SERVICE", configuration = MySelfRule.class)
public class OrderMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderMain80.class, args);
    }
}

轮询算法

  所谓的轮询算法就是根据所有的服务,依次将请求均摊到所有的服务依次访问,它的算法实现就是用RestTemplate接收到的请求数量对服务器集群的数量进行取模运算,余数就是服务在服务列表中对应的索引位置,所以说可以实现轮询。但是如果中途服务器关掉的话接收到的请求数量就会从1重新计数

OpenFeign

初识OpenFeign

什么是OpenFeign

  openFeign是要声明式的web服务客户端,或叫做声明式REST客户端,它让编写web服务客户端变得简单。它将提供者的restful服务伪装成接口进行消费,消费者只需要通过feign接口 注解就可以直接调用提供者的服务接口,也就是可以实现接口对接口的调用,而无需像ribbon一样通过restTemplate方式对提供者的服务进行调用

  值得注意的一点是,openFeign内置了负载均衡器-Ribbon,所以说openfeign也可以使用负载均衡算法

如何使用OpenFeign

  第一步: 引入相关依赖

<!--openfeign-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

  第二步: 配置配置文件,只是基本配置和注册,没有OpenFeign独有的配置

server:
  port: 80
eureka:
  client:
    register-with-eureka: false
    service-url:
      #服务端的地址,服务端为集群版,向所有的模块都注册
      defaultZone: http://localhost:7001/eureka,
                   http://localhost:7002/eureka,
                   http://localhost:7003/eureka

  第三步: 主启动类开启OpenFeign客户端

@SpringBootApplication
@EnableFeignClients
public class OrderFeignMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderFeignMain80.class, args);
    }
}

  第四步: 之前使用ribbon是直接在controller里调用payment服务的controller,但是openfeign则是通过service调用,于是第三步就是创建一个service接口用于调用payment服务的接口

@Component
@FeignClient(value = "CLOUD-PAYMENT-SERVICE") // 用于指定服务名,可在eureka或者服务的配置文件中查看
public interface PaymentFeignService {
    @GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
    CommonResult<Payment> getPaymentById(@PathVariable("id") Integer id);
}

  第五步: controller层调用service接口

@RestController
@RequestMapping("consumer")
public class OrderFeignController {
    @Autowired
    private PaymentFeignService paymentFeignService;
    @GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Integer id) {
        return paymentFeignService.getPaymentById(id);
    }
}

  如此操作也可实现order服务对payment服务的调用,而且由于OpenFeign默认引入Ribbon,去进行order服务访问的时候,后端会默认轮询名为是“CLOUD-PAYMENT-SERVICE”的微服务,也就是两个payment服务

OpenFeign超时控制

  使用OpenFeign调用服务接口,默认等待时间为1秒,超时就会直接报错。如果有些服务的调用确实会花费超过1s的时间,就需要我们在服务调用方(也就是order服务)的配置文件中进行配置

  由于OpenFeign的超时控制由其底层的ribbon实现,于是配置文件中的超时控制也由ribbon进行配置

#设置feign客户端超时时间(OpenFeign默认支持ribbon)
ribbon:
  #指的是建立连接所用的时间,适用于网络状况正常的情况下, 两端连接所用的时间
  ReadTimeout: 5000
  #指的是建立连接后从服务器读取到可用资源所用的时间
  ConnectTimeout: 5000

OpenFeign日志打印

  OpenFeign提供了日志打印的功能,我们可以通过日志的打印监控接口的调用情况,从而了解接口调用时HTTP请求的具体细节,具体的使用分

  第一步: 使用配置类配置日志级别

@Configuration
public class FeignConfig {
    /**
     * 日志级别
     * NONE:默认的,不显示任何日志
     * BASIC:仅记录请求方法、URL、响应状态码以及执行时间
     * HEADERS:请求方法、URL、响应状态码、执行时间、请求和响应的头信息
     * FULL:请求方法、URL、响应状态码、执行时间、请求和响应的头信息、正文以及元数据
     */
    @Bean
    Logger.Level feignLoggerLevel() {
        return Logger.Level.FULL;
    }
}

  第二步: 配置文件开启日志打印,并指定监控的接口和级别

logging:
  level:
    # feign日志以 debug 级别监控 com.atguigu.springcloud.service.PaymentFeignService 接口
    com.xiaochen.springcloud.service.PaymentFeignService: debug

打印出来的日志如下:

到此这篇关于SpringCloud Ribbon与OpenFeign详解如何实现服务调用的文章就介绍到这了,更多相关SpringCloud Ribbon与OpenFeign内容请搜索Devmax以前的文章或继续浏览下面的相关文章希望大家以后多多支持Devmax!

SpringCloud Ribbon与OpenFeign详解如何实现服务调用的更多相关文章

  1. SpringCloud超详细讲解微服务网关Zuul基础

    这篇文章主要介绍了SpringCloud Zuul微服务网关,负载均衡,熔断和限流,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

  2. SpringCloud gateway+zookeeper实现网关路由的详细搭建

    这篇文章主要介绍了SpringCloud gateway+zookeeper实现网关路由,本文通过图文实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

  3. 详解OpenFeign服务调用(微服务)

    OpenFeign是Spring Cloud在Feign的基础上支持了SpringMVC的注解,如@RequesMapping等等,这篇文章主要介绍了OpenFeign服务调用的相关知识,需要的朋友可以参考下

  4. Spring Cloud OpenFeign实例介绍使用方法

    Spring Cloud OpenFeign 对 Feign 进行了二次封装,使得在 Spring Cloud 中使用 Feign 的时候,可以做到使用 HTTP 请求访问远程服务,就像调用本地方法一样的,开发者完全感知不到这是在调用远程访问,更感知不到在访问 HTTP 请求

  5. SpringCloud OpenFeign 服务调用传递 token的场景分析

    这篇文章主要介绍了SpringCloud OpenFeign 服务调用传递 token的场景分析,本篇文章简单介绍 OpenFeign 调用传递 header ,以及多线程环境下可能会出现的问题,其中涉及到 ThreadLocal 的相关知识,需要的朋友可以参考下

  6. OpenFeign实现远程调用

    这篇文章主要为大家详细介绍了OpenFeign实现远程调用,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

  7. Springcloud Stream消息驱动工具使用介绍

    SpringCloud Stream由一个中间件中立的核组成,应用通过SpringCloud Stream插入的input(相当于消费者consumer,它是从队列中接收消息的)和output(相当于生产者producer,它是发送消息到队列中的)通道与外界交流

  8. SpringCloud中Gateway的使用教程详解

    SpringCloud Gateway是Spring体系内的一个全新项目,它旨在为微服务架构提供一种简单有效的统一的API路由管理方式。本文就来为大家详细讲讲Gateway的使用教程,需要的可以参考一下

  9. sentinel整合ribbon与fallback流程分步讲解

    这篇文章主要介绍了sentinel整合ribbon与fallback分步流程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

  10. SpringCloud 客户端Ribbon负载均衡的实现方法

    Ribbon 是 Netflix 提供的一个基于 Http 和 TCP 的客户端负载均衡工具,且已集成在 Eureka 依赖中,这篇文章主要介绍了SpringCloud 客户端Ribbon负载均衡的实现方法,需要的朋友可以参考下

随机推荐

  1. 基于EJB技术的商务预订系统的开发

    用EJB结构开发的应用程序是可伸缩的、事务型的、多用户安全的。总的来说,EJB是一个组件事务监控的标准服务器端的组件模型。基于EJB技术的系统结构模型EJB结构是一个服务端组件结构,是一个层次性结构,其结构模型如图1所示。图2:商务预订系统的构架EntityBean是为了现实世界的对象建造的模型,这些对象通常是数据库的一些持久记录。

  2. Java利用POI实现导入导出Excel表格

    这篇文章主要为大家详细介绍了Java利用POI实现导入导出Excel表格,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

  3. Mybatis分页插件PageHelper手写实现示例

    这篇文章主要为大家介绍了Mybatis分页插件PageHelper手写实现示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

  4. (jsp/html)网页上嵌入播放器(常用播放器代码整理)

    网页上嵌入播放器,只要在HTML上添加以上代码就OK了,下面整理了一些常用的播放器代码,总有一款适合你,感兴趣的朋友可以参考下哈,希望对你有所帮助

  5. Java 阻塞队列BlockingQueue详解

    本文详细介绍了BlockingQueue家庭中的所有成员,包括他们各自的功能以及常见使用场景,通过实例代码介绍了Java 阻塞队列BlockingQueue的相关知识,需要的朋友可以参考下

  6. Java异常Exception详细讲解

    异常就是不正常,比如当我们身体出现了异常我们会根据身体情况选择喝开水、吃药、看病、等 异常处理方法。 java异常处理机制是我们java语言使用异常处理机制为程序提供了错误处理的能力,程序出现的错误,程序可以安全的退出,以保证程序正常的运行等

  7. Java Bean 作用域及它的几种类型介绍

    这篇文章主要介绍了Java Bean作用域及它的几种类型介绍,Spring框架作为一个管理Bean的IoC容器,那么Bean自然是Spring中的重要资源了,那Bean的作用域又是什么,接下来我们一起进入文章详细学习吧

  8. 面试突击之跨域问题的解决方案详解

    跨域问题本质是浏览器的一种保护机制,它的初衷是为了保证用户的安全,防止恶意网站窃取数据。那怎么解决这个问题呢?接下来我们一起来看

  9. Mybatis-Plus接口BaseMapper与Services使用详解

    这篇文章主要为大家介绍了Mybatis-Plus接口BaseMapper与Services使用详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

  10. mybatis-plus雪花算法增强idworker的实现

    今天聊聊在mybatis-plus中引入分布式ID生成框架idworker,进一步增强实现生成分布式唯一ID,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

返回
顶部