微服务+springcloud+springcloud alibaba学习笔记【Ribbon的使用】(4/9)

news2024/11/24 3:13:04

Ribbon的使用 4/9

    • 1、Ribbon负载均衡
      • 1.1 Ribbon简介
      • 1.2 Ribbon功能
      • 1.3 使用Ribbon:
          • 1.3.1 Ribbon常用负载均衡算法
          • 1.3.2 使用Ribbon
          • 1.3.3 ribbon的轮询算法原理
          • 1.3.4 手写一个负载均衡轮询算法
          • 1.3.5 启动服务,测试

1、Ribbon负载均衡

1.1 Ribbon简介

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

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

注意：Ribbon目前也进入维护,基本上不准备更新了

1.2 Ribbon功能

在这里插入图片描述

  • 集中式LB

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

  • 进程内LB

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

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

两者区别：

  1. 简单地说就是将用户的请求平均分摊到多个服务上，从而达到系统的HA（高可用）。
    常见的负载均衡软件有Nginx，LVS，硬件F5等。

  2. Ribbon本地负载均衡客户端和Nginx服务端负载均衡区别

​ Nginx是服务器负载均衡，客户端所有请求都会交给Nginx，然后由Nginx实现转发请求。即负载均衡是由服务端实现的。

​ Ribbon本地负载均衡，在调用微服务接口时候，会在注册中心上获取注册信息服务列表之后缓存到JVM本地，从而在本地实现RPC远程服务调用技术

Ribbon就是负载均衡+RestTemplate

Ribbon其实就是一个软件实现负载均衡的客户端组件，他可以和其他所需请求的客户端结合使用，和Eureka结合只是其中的一个实例

在这里插入图片描述

Ribbon在工作时分成两步：

  1. 第一步先选择EurekaSever，它优先选择在同一区域内负载较少的server。
  2. 第二步再根据用户指定的策略，在从server取到的服务注册列表中选择一个地址。
    其中Ribbon提供了多种策略：比如轮询，随机和根据响应时间的加权等。

1.3 使用Ribbon:

  1. 默认我们使用eureka的新版本时,它默认集成了ribbon:
        <!-- 服务注册中心的客户端端 eureka-client -->
        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

这个>spring-cloud-starter-netflix-eureka-client中集成了ribbon了

在这里插入图片描述
我们也可以手动引入ribbon，放到order模块中,因为只有order访问pay时需要负载均衡。

	//ribbon依赖
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
      <version>2.2.1.RELEASE</version>
      <scope>compile</scope>
    </dependency>
  1. RestTemplate扩展说明

== getForObject/getForEntity方法的演示==

  • getForObject方法的演示

getForObject返回对象为响应体中数据转化成的对象，基本上可以理解为JSON

    @GetMapping("/consumer/getForObject/{id}")
    public CommonResult<Payment> getPaymentById1(@PathVariable("id") Long id){
        return restTemplate.getForObject(PAYMENT_URL+"/payment/"+id, CommonResult.class);
    }

在这里插入图片描述

  • getForEntity方法的演示

getForEntity返回的对象为ResponseEntity对象，包含了响应中的一些重要信息，比如响应头、响应状态码、响应体等

    @GetMapping("/consumer/getForEntity/{id}")
    public CommonResult<Payment> getPaymentById2(@PathVariable("id") Long id){
        ResponseEntity<CommonResult> entity = restTemplate.getForEntity(PAYMENT_URL+"/payment/"+id, CommonResult.class);
        if(entity.getStatusCode().is2xxSuccessful()){
            return entity.getBody();
        }else{
            return new CommonResult(444,"操作失败");
        }
    }

在这里插入图片描述

1.3.1 Ribbon常用负载均衡算法

IRule：根据特定算法从服务列表中选择一个要访问的服务

Rule接口有7个实现类,每个实现类代表一个负载均衡算法

继承关系图：

实现类 负载均衡算法

在这里插入图片描述
在这里插入图片描述

1.3.2 使用Ribbon

负载均衡算法上的替换

配置注意事项：

​ 官方文档明确给出警告：

我们自定义的算法配置类不能放在@ComponentScan所扫描的当前包及其子包下，否则我们自定义的这个配置类就会被所有的Ribbon客户端所共享，达不到特殊定制化的目的

​ 说白了就是不能放在主启动类所在的包以及他所在包的子包

  1. 创建一个跟springcloud同级的包，起名为myribbonrule

sp

  1. 创建配置类,指定负载均衡算法

自定义的ribbon负载均衡配置类：

package com.tigerhhzz.myribbonrule;

import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author tigerhhzz
 * @date 2023/4/10 11:24
 */
@Configuration
public class MyselfRibbonRule {

    @Bean
    public IRule myRule() {

        return new RandomRule();   //定义为随机
    }
}

默认的轮询算法换成随机算法

  1. 在主启动类上加一个注解@RibbonClient
package com.tigerhhzz.springcloud;

import com.tigerhhzz.myribbonrule.MyselfRibbonRule;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;

@Slf4j
@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "CLOUD-PROVIDER-SERVICE",configuration = MyselfRibbonRule.class)
public class OrderMain80{
    public static void main(String[] args){
        SpringApplication.run(OrderMain80.class,args);
        log.info("OrderMain80启动成功~~~~~~~~~~~~~~~~~~~");
    }
}

//name:代表哪个服务提供者要使用我们配置的算法
//configuretion:指定我们的算法配置类

表示,访问CLOUD-PROVIDER-SERVICE的服务时,使用我们自定义的负载均衡算法

1.3.3 ribbon的轮询算法原理

在这里插入图片描述

1.3.4 手写一个负载均衡轮询算法
  1. 改造模块(8001,8002),的controller方法

给模块(8001,8002),的controller方法添加一个方法,返回当前节点端口

    @GetMapping("/payment/lb")
    public String getPaymentLB(){
        return serverPort;
    }
  1. 修改order80模块

去掉@LoadBalanced注解

package com.tigerhhzz.springcloud.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @author tigerhhzz
 * @date 2023/4/8 22:52
 */
@Configuration
public class ApplicationContextConfig {

    @Bean
    //@LoadBalanced   //注释掉这个注解
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
        /*
        RestTemplate提供了多种便捷访问远程http服务的方法，
        是一种简单便捷的访问restful服务模板类，是spring提供的用于rest服务的客户端模板工具集
        */
    }
}
  1. 新建自定义ribbon负载均衡接口
package com.tigerhhzz.myloadbanlance;

import org.springframework.cloud.client.ServiceInstance;

import java.util.List;

/**
 * @author tigerhhzz
 * @date 2023/4/10 17:24
 */
public interface myloadbanlance {
    ServiceInstance instance(List<ServiceInstance> instances);
}
  1. 自定义ribbon负载均衡接口实现类
package com.tigerhhzz.myloadbanlance;

import org.springframework.cloud.client.ServiceInstance;
import org.springframework.stereotype.Component;

import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @author tigerhhzz
 * @date 2023/4/10 17:25
 */
@Component
public class myloadbanlanceImpl implements myloadbanlance{


    private AtomicInteger atomicInteger = new AtomicInteger(0);

    //获取下一个要调用的服务id
    public final int getIncrement() {
        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(List<ServiceInstance> instances) {
        //拿到id，进行取余得到真正要调用服务的下标
        int index = getIncrement() % instances.size();
        return instances.get(index);
    }
}
  1. 在80模块的controller中增加一个测试接口 @GetMapping(“payment/lb”)
package com.tigerhhzz.springcloud.controller;

import com.tigerhhzz.myloadbanlance.myloadbanlance;
import com.tigerhhzz.springcloud.entities.CommonResult;
import com.tigerhhzz.springcloud.entities.Payment;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import java.net.URI;
import java.util.List;

@RestController
@Slf4j
@RequestMapping("comsumer")
public class OrderController {

    //远程调用的 地址
    //public static final String PAYMENY_URL = "http://localhost:8001";

    //远程调用的 地址
    public static final String PAYMENT_URL = "http://cloud-provider-service";

    @Resource
    private RestTemplate restTemplate;
    @Resource
    private myloadbanlance myloadbanlance;
    @Resource
    private DiscoveryClient discoveryClient;

    @PostMapping("payment/create")
    public CommonResult<Payment> create (@RequestBody Payment payment){

        return restTemplate.postForObject(PAYMENT_URL + "/payment/create",//请求地址
                                          payment,//请求参数
                                          CommonResult.class);//返回类型
    }

    @GetMapping("payment/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id")Long id){
        return restTemplate.getForObject(PAYMENT_URL + "/payment/" + id,//请求地址
                                         CommonResult.class);//返回类型
    }

    @GetMapping("getForObject/{id}")
    public CommonResult<Payment> getPaymentById1(@PathVariable("id") Long id){
        return restTemplate.getForObject(PAYMENT_URL+"/payment/"+id, CommonResult.class);
    }

    @GetMapping("getForEntity/{id}")
    public CommonResult<Payment> getPaymentById2(@PathVariable("id") Long id){
        ResponseEntity<CommonResult> entity = restTemplate.getForEntity(PAYMENT_URL+"/payment/"+id, CommonResult.class);
        if(entity.getStatusCode().is2xxSuccessful()){
            return entity.getBody();
        }else{
            return new CommonResult(444,"操作失败");
        }
    }

    @GetMapping("payment/lb")
    public String getPaymentLB() {
        List<ServiceInstance> instances = discoveryClient.getInstances("cloud-provider-service");
        if (instances == null || instances.size() == 0) {
            return null;
        }
        ServiceInstance serviceInstance = myloadbanlance.instance(instances);
        URI uri = serviceInstance.getUri();
        System.out.println(uri+"/payment/lb");
        return restTemplate.getForObject(uri+"/payment/lb",String.class);
//        return uri+"/payment/lb";
    }


}
1.3.5 启动服务,测试

注意：手写自定义的轮询算法的包必须放在启动类同一目录中，要不然spring启动后，扫描不到自己写的自定义轮询算法类

在这里插入图片描述

在这里插入图片描述

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

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

相关文章

Nestjs实战干货-概况-管道-Pipes

Nestjs实战干货-概况-管道-Pipes

管道 带上装饰器 Injectable() 并实现了 PipeTransform 接口的类&#xff0c;就是管道。 管道有 2 个典型的应用场景&#xff1a; 数值转换&#xff1a;将输入的参数转换成目标类型&#xff0c;例如&#xff0c;string to number。 数值校验&#xff1a;对输入的参数进行校验…
阅读更多...
记一次 MySQL 主从同步异常的排查记录，百转千回

记一次 MySQL 主从同步异常的排查记录，百转千回

本文主要内容如下&#xff1a; 一、现象 最近项目的测试环境遇到一个主备同步的问题&#xff1a; 备库的同步线程停止了&#xff0c;无法同步主库的数据更改。 备库报错如下&#xff1a; 完整的错误信息&#xff1a; Relay log read failure: Could not parse relay log even…
阅读更多...
一文读懂【Git 工作流】

一文读懂【Git 工作流】

文章目录一、Git分支管理二、Git日志规范三、Git Flow工作流一、Git分支管理 我们在实际工作中会创建很多分支以便于不同场景下的开发&#xff0c;但是如果没有分支规范就会造成分支杂乱&#xff0c;大家往往也搞不清楚某一个分支是在做什么&#xff0c;下面我们就介绍一下我们…
阅读更多...
车企围攻整车OS，这张“新王牌”怎么打？

车企围攻整车OS，这张“新王牌”怎么打？

今年2月23日&#xff0c;梅赛德斯--奔驰发布了打造自有操作系统MB.OS的具体计划&#xff0c;该操作系统将在本年代中期随全新梅赛德斯-奔驰模块化架构&#xff08;MMA&#xff09;平台推出&#xff0c;预计2025年用户将能体验到它的强大功能。 据悉&#xff0c;基于覆盖芯片到…
阅读更多...
YOLOv8运行参数解读

YOLOv8运行参数解读

整理来自yolov8官方文档常用的一些命令行参数&#xff0c;官方文档YOLOv8 Docs yolov8命令行的统一运行格式为&#xff1a; yolo TASK MODE ARGS其中主要是三部分传参&#xff1a; TASK(可选) 是[detect、segment、classification]中的一个。如果没有显式传递&#xff0c;YO…
阅读更多...
智慧水务软件-科学系统架构-数字化管理

智慧水务软件-科学系统架构-数字化管理

平台概述 柳林智慧水务软件是以物联感知技术、大数据、智能控制、云计算、人工智能、数字孪生、AI算法、虚拟现实技术为核心&#xff0c;以监测仪表、通讯网络、数据库系统、数据中台、模型软件、前台展示、智慧运维等产品体系为支撑&#xff0c;以城市水资源、水生态、水环境…
阅读更多...
VGG论文翻译及复现

VGG论文翻译及复现

VGG网络实现&#xff1a;https://blog.csdn.net/weixin_43912621/article/details/127852595 论文地址&#xff1a;https://arxiv.org/abs/1409.1556 VERY DEEP CONVOLUTIONAL NETWORKS FOR LARGE-SCALE IMAGE RECOGNITION 用于大规模图像识别的深度卷积网络 Abstract In t…
阅读更多...
Salesforce Admin管理员中文学习教程，如何高效筛选出具有Admin权限的用户！

Salesforce Admin管理员中文学习教程，如何高效筛选出具有Admin权限的用户！

组织中最常见的错误之一就是拥有太多具有系统管理员简档的用户。不幸的是&#xff0c;这在某些行业中非常普遍。 实际上这存在着很大的潜在风险。拥有这些权限的用户可能会暴露、窃取或删除组织中的数据&#xff0c;甚至影响到其他用户。防止过多的管理员访问权限是保护Salesf…
阅读更多...
基于Python机器学习、深度学习技术提升气象、海洋、水文领域实践应用能力

基于Python机器学习、深度学习技术提升气象、海洋、水文领域实践应用能力

目录 专题一、Python软件的安装及入门 专题二、气象常用科学计算库 专题三、气象海洋常用可视化库 专题四、爬虫和气象海洋数据 专题五、气象海洋常用插值方法 专题六、机器学习基础理论和实操 专题七、机器学习的应用实例 专题八、深度学习基础理论和实操 专题九、深…
阅读更多...
摸鱼也可以效率翻倍：Python 统计 gitlab 代码量，定量统计发给领导

摸鱼也可以效率翻倍：Python 统计 gitlab 代码量，定量统计发给领导

嗨害大家好鸭&#xff01;我是爱摸鱼的芝士❤ 一、确定需求 需求是公司大领导想要了解每周研发提交的代码量。 因为研发人员比较多&#xff0c; 想着用 python 做个自动化&#xff0c; 定时统计代码量并发送邮件给领导。 二、统计gitlab代码 首先安装第三方库python-gitlab&…
阅读更多...
如何提升智能文档处理识别精度？合合信息“版面分析”实现新突破

如何提升智能文档处理识别精度？合合信息“版面分析”实现新突破

春季是繁忙的播种季&#xff0c;学生党迎来了开学季和紧张的研究生复试&#xff0c;职场人士也需要处理新签业务带来的大量不同类型的文件&#xff0c;比如合同、发票、档案等。这些文件在被拍照、扫描成电子文档的过程中&#xff0c;时常存在漏字、错位现象。究其原因&#xf…
阅读更多...
kali的下载与安装（VM虚拟机）

kali的下载与安装（VM虚拟机）

目录 一、介绍 二、下载安装 &#xff08;一&#xff09;官网下载kali &#xff08;二&#xff09;官网下载VM虚拟机 &#xff08;三&#xff09;安装VM虚拟机 &#xff08;三&#xff09;VM虚拟机里面安装kali系统 一、介绍 &#xff08;1&#xff09;Kali Linux是一种基…
阅读更多...
基于Chatbot UI 实现ChatGPT对话-V1.0

基于Chatbot UI 实现ChatGPT对话-V1.0

基于Chatbot UI 实现ChatGPT对话-V1.0 前端基于开源项目&#xff1a;chatbot-ui进行二次开发&#xff0c;感兴趣的小伙伴可以自行研究。 本项目搭建初衷&#xff1a;在无法科学上网的情况下&#xff0c;实现ChatGPT对话。还有规避官方聊天时&#xff0c;长时间无链接导致的问题…
阅读更多...
“GPT全家桶”，喂不饱商汤科技

“GPT全家桶”，喂不饱商汤科技

加码追风大模型&#xff0c;终究没能让商汤科技找回投资者们的信心。 4月10日&#xff0c;商汤发布了“日日新SenseNova”大模型体系&#xff0c;且一口气展示了多个产品&#xff0c;有类ChatGPT产品“商量”&#xff08;SenseChat&#xff09;、与Midjourney画风一致的秒画平台…
阅读更多...
语句覆盖率\条件覆盖率\路径覆盖率\分支覆盖率的区别您知道吗

语句覆盖率\条件覆盖率\路径覆盖率\分支覆盖率的区别您知道吗

代码覆盖率 代码覆盖率是一种度量&#xff0c;它描述了程序源代码已经过测试的程度&#xff0c;它可以帮助我们评估测试执行的效率&#xff0c; 简单来理解代码覆盖率就是单元测试中代码执行量与代码总量之间的比率。代码覆盖率主要包括语句覆盖率、分支覆盖率、条件覆盖率和路…
阅读更多...
【Linux】实现守护进程 | 以tcpServer为例

【Linux】实现守护进程 | 以tcpServer为例

本文首发于 慕雪的寒舍 本文将以tcp服务器代码为基本&#xff0c;讲述如何将进程守护进程化&#xff0c;后台运行 1.守护进程 所谓守护进程&#xff0c;就是和其他进程没有关系的进程&#xff1b;其独立运行于系统后台&#xff0c;除非自己退出或收到信号终止&#xff0c;否则…
阅读更多...
逆向-还原代码之(*point)[4]和char *point[4] (Arm 64)

逆向-还原代码之(*point)[4]和char *point[4] (Arm 64)

// source code #include <stdio.h> #include <string.h> #include <stdlib.h> /* * char (*point)[4] // 数组指针。 a[3][4] // 先申明二维数组,用它来指向这个二维数组 * char *point[4] // 指针数组。 a[4][5] // 一连串的指针…
阅读更多...
编程语言，TIOBE 4 月榜单：黑马出现了

编程语言，TIOBE 4 月榜单：黑马出现了

TIOBE 4 月榜单已经发布了&#xff0c;一起来看看这个月编程语言排行榜有什么变化吧&#xff01; C 发展依旧迅猛 在本月榜单中&#xff0c;TOP 20 的变动不大&#xff0c;Python、C、Java 、 C 和C#依然占据前五。甚至排名顺序都和上个月一样没有变动。 同时&#xff0c;Rus…
阅读更多...
【图形学】多边形裁剪算法综述

【图形学】多边形裁剪算法综述

系列综述&#xff1a; &#x1f49e;目的&#xff1a;本文是个人学习多边形裁剪知识整理的&#xff0c;整理期间努力理解论文作者含义&#xff0c;并增加了自己的详述和注解。 &#x1f970;来源&#xff1a;材料主要源于多边形裁剪相关论文进行的&#xff0c;每个知识点的学习…
阅读更多...
第三十一天 Linux介绍和基础命令

第三十一天 Linux介绍和基础命令

目录 1.前言 1.1 什么是Linux 1.2 为什么要学Linux 1.3 学完Linux能干什么 2.Linux简介 2.1 主流操作系统 2.2 Linux发展历史 3. Linux安装 3.1 安装方式介绍 3.2 安装VMware 3.3 安装Linux 3.4 网卡设置 3.5 安装SSH连接工具 3.6 Linux目录结构 4.Linux常用命令…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023