负载均衡 Ribbon 与 Fegin 远程调用原理

文章目录

  • 一、什么是负载均衡
  • 二、Ribbon 负载均衡
    • 2.1 Ribbon 使用
    • 2.2 Ribbon 实现原理 (★)
    • 2.3 Ribbon 负载均衡算法
  • 三、Feign 远程调用
    • 3.1 Feign 简述
    • 3.2 Feign 的集成
    • 3.3 Feign 实现原理 (★)

一、什么是负载均衡

《服务治理：Nacos 注册中心》 末尾提到了负载均衡，那什么是负载均衡呢？

负载均衡就是将负载（⼯作任务，访问请求）进⾏分摊到多个操作单元（服务器，组件）上进行执行。
根据负载均衡发⽣位置的不同，⼀般分为： 服务端负载均衡 和 客户端负载均衡。

  • 服务端负载均衡指的是发生在服务提供者一方，比如常见的 Nginx 负载均衡。
  • 客户端负载均衡指的是发生在服务请求的一方，也就是在发送请求之前已经选好了由哪个实例处理请求。

在这里插入图片描述
注：在微服务调⽤关系中⼀般会选择客户端负载均衡，也就是在服务调用的一方来决定服务由哪个提供者执行。

二、Ribbon 负载均衡

2.1 Ribbon 使用

Ribbon 是 Spring Cloud 的⼀个组件， 它可以让我们使用一个注解就能轻松的搞定负载均衡。

1、在 RestTemplate 的生成方法上添加 @LoadBalanced 注解

@Bean
@LoadBalanced // 表示继承Ribbon进行负载均衡
public RestTemplate restTemplate() {return new RestTemplate();
}

2、修改服务调用的方法

@Service
@Slf4j
public class OrderServiceImpl implements OrderService {@Autowiredprivate OrderDao orderDao;@Autowiredprivate RestTemplate restTemplate;@Overridepublic Order createOrder(Long productId, Long userId) {log.info("接收到{}号商品的下单请求，接下来调⽤商品微服务查询此商品信息", productId);// 远程调⽤商品微服务，查询商品信息String url = "http://product-service/product/" + productId;log.info("服务器地址: {}", url);// 远程调⽤商品微服务,查询商品信息Product product = restTemplate.getForObject(url, Product.class);log.info("查询到{}号商品的信息，内容是:{}", productId, JSON.toJSONString(product));// 创建订单并保存Order order = new Order();order.setUid(userId);order.setUsername("安秀岩");order.setPid(productId);order.setName(product.getName());order.setPrice(product.getPrice());order.setNumber(1);orderDao.save(order);log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));return order;}
}

在这里插入图片描述
对比以下两种方式，差异显著：

 //⾃定义规则实现随机挑选服务List<ServiceInstance> instances = discoveryClient.getInstances("product-service");int index = new Random().nextInt(instances.size());ServiceInstance instance = instances.get(index);String url = instance.getHost() + ":" + instance.getPort();log.info("从nacos中获取到的微服务地址为:" + url);简化成了以下一行// Ribbon 直接使用需要远程调用的服务名称即可
String url = "http://product-service/";

那 Ribbon 底层原理又是什么呢？为什么可以使用服务名称就能远程调用该服务呢？

2.2 Ribbon 实现原理 (★)

现假设：两个商品服务做集群，向Nacos注册的IP分别是192.168.10.111：8081，192.168.10.112：8081

step1：当使用 RestTemplate 远程访问时，http://product-service/product/1 首先会将服务名称截取出来 product-service
step2：并在本地缓存列表中获取到服务的 IP 集合，即{{192.168.10.111:8081}, {192.168.10.112:8081}}。
step3：根据内部配置的 负载均衡算法，从集合中选取其中一个IP地址，如：192.168.10.112:8081
step4：将原来的 url 替换成 http://192.168.10.112:8081/product/1，最终通过 RestTemplate 发起请求。

2.3 Ribbon 负载均衡算法

Ribbon 内置了多种负载均衡策略，内部负载均衡的顶级接口为 com.netflix.loadbalancer.IRule，具体的负载策略如下图所示:

在这里插入图片描述
可以通过修改配置来调整 Ribbon 的负载均衡策略，如在 order-server 项目的 application.yml 中增加如下配置：

product-service: # 调⽤的提供者的名称ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

三、Feign 远程调用

3.1 Feign 简述

为什么要使用 feign 呢？原来的调用的方式 String url = "http://product-service/product/" + productId; 是固定的字符串做拼接不够灵活，而且还存在 productId 参数校验问题等，因此 Feign 可解决这个问题。

  Feign 是 Spring Cloud 提供的⼀个声明式的伪 Http 客户端，它使得调用远程服务就像调用本地服务一样简单，只需要创建一个接口并添加一个注解即可。Nacos 很好的兼容了 Feign，Feign 默认集成了 Ribbon，所以在 Nacos 下使用 Fegin 默认就实现了负载均衡的效果。

3.2 Feign 的集成

1、在shop-order-server项⽬的pom文件加入Fegin的依赖

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

2、在启动类上添加 Fegin 的扫描注解 @EnableFeignClients，注意扫描路径(默认扫描当前包及其子包)

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients // 会扫描当包及其子包下贴有@FeignClient注解的接口
public class OrderServer {public static void main(String[] args) {SpringApplication.run(ProductApplication .class, args);}
}

3、在 shop-order-server 项目中新增接口 ProductFeignApi 和该接口的容错类 ProductFeignFallback

@FeignClient(name = "product-service", fallback = ProductFeignFallback.class)
// 远程调用服务名称；fallback 指定返回兜底数据的类的字节码，即服务挂起时的降级类方法
public interface ProductFeignApi {@RequestMapping("/product/{pid}")// 路径要与 ProductController 的接口保持一致Product findByPid(@PathVariable("pid") Long pid);
}

@Component // 该类的作用是返回兜底数据以防 “服务器雪崩”
public class ProductFeignFallback implements ProductFeignApi {@Overridepublic Product findByPid(Long pid) {System.out.println("返回兜底数据");return new Product();}
}

在这里插入图片描述

4、修改服务调用的方法

@Service
@Slf4j
public class OrderServiceImpl implements OrderService {@Autowiredprivate OrderDao orderDao;@Autowiredprivate ProductFeignApi productFeignApi;@Overridepublic Order createOrderFeign(Long productId, Long userId) {// feign 调用Product product = productFeignApi.findByPid(productId);log.info("查询到{}号商品的信息，内容是:{}", productId, JSON.toJSONString(product));// 创建订单并保存Order order = new Order();order.setUid(userId);order.setUsername("叩丁狼教育");order.setPid(productId);order.setName(product.getName());order.setPrice(product.getPrice());order.setNumber(1);orderDao.save(order);log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));return order;}
}

3.3 Feign 实现原理 (★)

Feign 实现的原理是基于动态代理和反射技术，并且内部还是使用 RestTemplate 实现的，具体详细流程如下：
在这里插入图片描述

文章参考：Java微服务商城高并发秒杀项目实战|Spring Cloud Alibaba真实项目实战+商城双11秒杀+高并发+消息+支付+分布式事物Seata

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/53090.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

第二十篇——行军篇：别指望外援，好好培养亲兵

第二十篇——行军篇：别指望外援，好好培养亲兵

目录 一、背景介绍二、思路&方案三、过程1.思维导图2.文章中经典的句子理解3.学习之后对于投资市场的理解4.通过这篇文章结合我知道的东西我能想到什么&#xff1f; 四、总结五、升华 一、背景介绍 微观层面&#xff0c;从驯服的视角&#xff0c;我们可以洞察到人性中非常…
阅读更多...
leveldb源码剖析（二）——LSM Tree

leveldb源码剖析（二）——LSM Tree

LSM Tree LSM Tree&#xff1a;Log-Structured Merge Tree&#xff0c;日志结构合并树。是一种频繁写性能很高的数据结构。 LSM Tree将写入操作与合并操作分离&#xff0c;数据首先写入磁盘中的日志文件&#xff08;WAL&#xff09;&#xff0c;随后写入内存缓存&#xff0c;…
阅读更多...
UDP英译汉网络词典

UDP英译汉网络词典

这里我们用UDP实现一个简单的英译汉小词典。我们还是仿照前一篇的UDP编程&#xff0c;将各自的组件封装起来&#xff0c;实现高内聚低耦合。 一. 字典翻译功能实现 首先我们将我们的字典知识库放在txt文本中。 apple: 苹果 banana: 香蕉 cat: 猫 dog: 狗 book: 书 pen: 笔 ha…
阅读更多...
云计算之ECS

云计算之ECS

目录 一、ECS云服务器 1.1 ECS的构成 1.2 ECS的实例规格 1.3 镜像 1.4 磁盘 1.5 安全组 1.6 网络 1.7 产品结构 二、块存储介绍 2.1 快存储定义 2.2 块存储性能指标 2.3 快存储常用操作-云盘扩容 2.4 块存储常见问题 三、快照介绍 3.1 快照定义 3.2 快照常见问题…
阅读更多...
flume 使用 exec 采集容器日志，转储磁盘

flume 使用 exec 采集容器日志，转储磁盘

flume 使用 exec 采集容器日志&#xff0c;转储磁盘 在该场景下&#xff0c;docker 服务为superset&#xff0c;flume 的sources 选择 exec &#xff0c; sinks选择 file roll 。 任务配置 具体配置文件如下&#xff1a; #simple.conf: A single-node Flume configuration#…
阅读更多...
GPT-4o mini轻量级大模型颠覆AI的未来

GPT-4o mini轻量级大模型颠覆AI的未来

GPT-4o mini发布&#xff0c;轻量级大模型如何颠覆AI的未来&#xff1f; 引言 随着人工智能技术的飞速发展&#xff0c;大型AI模型的发布已成常态。然而&#xff0c;庞大的计算资源和存储空间限制了它们在广泛场景中的应用。为满足市场需求&#xff0c;轻量级大模型应运而生&a…
阅读更多...
TOMATO靶机漏洞复现

TOMATO靶机漏洞复现

步骤一&#xff0c;我们来到tomato页面 什么也弄不了只有一番茄图片 弱口令不行&#xff0c;xxs也不行&#xff0c;xxe还是不行 我们来使用kali来操作... 步骤二&#xff0c;使用dirb再扫一下, dirb http://172.16.1.133 1.发现这个文件可以访问.我们来访问一下 /antibot_i…
阅读更多...
【课程学习】信号检测与估计

【课程学习】信号检测与估计

文章目录 3.7-CRB延展到向量的形式3.8-参数变换形式的CRB CRB for transformation， pp45-463.9-高斯分布 CRLB for the General Gaussian Case3.7-CRB延展到向量的形式 0904 向量和变换形式的CRLB形式 估计参数真实值 θ \theta θ，估计值 θ ^ \hat \theta θ^ 与信号与系统…
阅读更多...
C# NX二次开发-获取对象名称

C# NX二次开发-获取对象名称

UG软件是所有带标签对象都能设置名称和属性&#xff1a; 代码&#xff1a; theUf.Obj.AskName(body.Tag,out string name);name.NxListing(); 免责声明&#xff1a; 只用于参考&#xff0c;如果有什么问题不要找我呀。
阅读更多...
【JAVA入门】Day27 - 单列集合体系结构综述

【JAVA入门】Day27 - 单列集合体系结构综述

【JAVA入门】Day27 - 单列集合体系结构 文章目录 【JAVA入门】Day27 - 单列集合体系结构1.1 Collection 集合的基本方法1.2 Collection 集合的遍历方式1.2.1 迭代器遍历1.2.2 增强 for 遍历1.2.3 利用 Lambda 表达式进行遍历 1.3 List 集合的基本方法1.4 List 集合的遍历方式 J…
阅读更多...
WordPress自适应美图网站整站打包源码

WordPress自适应美图网站整站打包源码

直接服务器整站源码数据库打包了&#xff0c;恢复一下就可以直接投入使用。保证好用易用&#xff0c;无需独立服务器就可以使用。 强调一下&#xff0c;我这个和其他地方的不一样、不一样、不一样。具体的看下面的说明。 现在网络上同样的资源包都是用的加密带后门的主题&…
阅读更多...
年化收益37.7%的A股小市值策略，小市值和动量因子长期有效（附具体逻辑）

年化收益37.7%的A股小市值策略，小市值和动量因子长期有效（附具体逻辑）

“ 原创内容第640篇&#xff0c;专注量化投资、个人成长与财富自由” 股票的“小市值”策略&#xff0c;就像ETF的趋势动量一样&#xff0c;长期有效。 这是一个很神奇的异象。 年化37.07%&#xff0c;夏普0.89。 这里我做了一些特殊的处理&#xff1a; 1、包括排除了科创板…
阅读更多...
Pencils Protocol生态新进展，即将上线 Vault 产品

Pencils Protocol生态新进展，即将上线 Vault 产品

“极高的盈利预期、通证的持续回购与销毁&#xff0c;Vault产品的推出正在成为Pencils Protocol生态发展的重磅利好。” Pencils Protocol是目前Scroll生态TVL最高的DeFi平台 &#xff0c;即便是行情整体较为平淡&#xff0c;其仍旧能够保持在3亿美元左右的锁仓价值&#xff0c…
阅读更多...
day35-测试之性能测试JMeter的测试报告、并发数计算和性能监控

day35-测试之性能测试JMeter的测试报告、并发数计算和性能监控

目录 一、JMeter的测试报告 1.1.聚合报告 1.2.html报告 二、JMeter的并发数计算 2.1.性能测试时的TPS&#xff0c;大都是根据用户真实的业务数据&#xff08;运营数据&#xff09;来计算的 2.2.运营数据 2.3.普通计算方法 2.4.二八原则计算方法 2.5.计算稳定性测试并发量 2.6…
阅读更多...
Mybatis链路分析：JDK动态代理和责任链模式的应用

Mybatis链路分析：JDK动态代理和责任链模式的应用

背景 此前写过关于代理模式的文章&#xff0c;参考&#xff1a;代理模式 动态代理功能&#xff1a;生成一个Proxy代理类&#xff0c;Proxy代理类实现了业务接口&#xff0c;而通过调用Proxy代理类实现的业务接口&#xff0c;实际上会触发代理类的invoke增强处理方法。 责任链功…
阅读更多...
Mac 安装Hadoop教程（HomeBrew安装）

Mac 安装Hadoop教程（HomeBrew安装）

1. 引言 本教程旨在介绍在Mac 电脑上安装Hadoop&#xff0c;便于编程开发人员对大数据技术的熟悉和掌握。 2.前提条件 2.1 安装JDK 想要在你的Mac电脑上安装Hadoop&#xff0c;你必须首先安装JDK。具体安装步骤这里就不详细描述了。你可参考Mac 安装JDK8。 2.2 配置ssh环境…
阅读更多...
【CVPR‘24】DeCoTR：使用 2D 和 3D 注意力增强深度补全

【CVPR‘24】DeCoTR：使用 2D 和 3D 注意力增强深度补全

DeCoTR: Enhancing Depth Completion with 2D and 3D Attentions DeCoTR: Enhancing Depth Completion with 2D and 3D Attentions 中文解析摘要介绍方法方法3.1 问题设置3.2 使用高效的 2D 注意力增强基线3.3 3D中的特征交叉注意力点云归一化位置嵌入3.4 捕捉 3D 中的全局上下…
阅读更多...
给鼠标一个好看的指针特效 鼠标光标如何修改形状？

给鼠标一个好看的指针特效 鼠标光标如何修改形状？

许多爱美的小伙伴们都想着如何给自己的电脑打扮一下&#xff0c;用各种各样的途径来美化我们的电脑。今天我们给大家分享一下&#xff0c;如何美化鼠标效果&#xff0c;给鼠标指针修改成一个非常好看的形状~ 一起来看几组鼠标的效果&#xff0c;小编我给大家做了个录屏&#x…
阅读更多...
linux文件——用户缓冲区——概念深度探索、IO模拟实现

linux文件——用户缓冲区——概念深度探索、IO模拟实现

前言&#xff1a;本篇文章主要讲解文件缓冲区。 讲解的方式是通过抛出问题&#xff0c; 然后通过分析问题&#xff0c; 将缓冲区的概念与原理一步一步地讲解。同时&#xff0c; 本节内容在最后一部分还会带友友们模拟实现一下c语言的printf&#xff0c; fprintf接口&#xff0c…
阅读更多...
依托自研力量，给共享集群存储服务一个优选

依托自研力量，给共享集群存储服务一个优选

YashanDB共享集群有三大关键组件&#xff0c;崖山集群服务&#xff08;YCS&#xff09;、崖山集群文件系统&#xff08;YFS&#xff09;、DB组件。上一篇共享集群系列文章《为何共享集群的高可用能力被频频称赞&#xff0c;它的机制有何不同&#xff1f;》深入解析了关键组件的…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023