springcloud+Ribbon负载均衡

2024-08-28 02:38

本文主要是介绍springcloud+Ribbon负载均衡,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

SpringCloud + Ribbon负载均衡

1.Ribbon简介

1.Ribbon主要实现客户端负载均衡

2.客户端负载均衡Ribbon与服务端负载均衡Nginx的区别:

Ribbon:服务实例在客户端,客户端从Eureka Server获取服务清单以后,通过负载均衡算法,在多个服务器中选择一个访问;

Nginx:服务实例在服务端,服务器进行负载均衡算法分配。

2.Ribbon使用

2.1.前置工作:

需要搭建Eureka server,我们以一台Eureka Server为例。详细配置见上一篇博客。

https://blog.csdn.net/u013071014/article/details/111031306

2.2.创建服务提供者项目

1.在parent项目的pom.xml文件中添加web依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.3.6.RELEASE</version>
</dependency>

2.在parent项目右键,New—> Maven Module,名称命名为springcloud-provider1

3.修改pom.xml文件

<packaging>jar</packaging><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>
</dependencies>

4.配置application.yml

spring:application:name: springcloud-provider1server:port: 8001eureka:client:service-url:defaultZone: http://localhost:8761/eureka/

5.添加主启动类SpringCloudProviderApplication,使用@EnableEurekaClient注解

package com.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication
@EnableEurekaClient
public class SpringCloudProviderApplication {public static void main(String[] args) {// TODO Auto-generated method stubSpringApplication.run(SpringCloudProviderApplication.class, args);}}

6.添加controller

package com.springcloud.controller;import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping(path = "/provider")
public class ProviderController {@RequestMapping(path = "/getProvider", method = RequestMethod.GET)public String getProvider() {return "Provider1";}
}

7.为方便测试,我们依此步骤,再创建两个服务提供者,project名称分别为springcloud-provider2和springcloud-provider3,但是application.yml文件中配置和的服务名都设置为springcloud-provider1,端口分别为8002和8003。ProviderController中API返回值分别设置为Provider2和Provider3

8.项目结构如下
在这里插入图片描述

9.先启动Eureka Server,再分别启动三个Provider,进入Eureka管理页面查看服务是否注册成功。
在这里插入图片描述

2.3.创建服务消费者

1.在parent项目右键,New—> Maven Module,名称命名为springcloud-consumer1

2.修改pom.xml,由于Eureka已经集成了Ribbon,所以我们无需单独引入Ribbon依赖。

<packaging>jar</packaging><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>
</dependencies>

3.配置application.yml

spring:application:name: springcloud-consumer1server:port: 8090eureka:client:service-url:defaultZone: http://localhost:8761/eureka/

4.创建主启动类SpringCloudConsumerApplication,使用@EnableEurekaClient注解,并添加RestTemplate。

注:使用RestTemplate开启负载均衡,在调用服务时,也可以直接使用服务名调用,避免IP访问

package com.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;@SpringBootApplication
@EnableEurekaClient
public class SpringCloudConsumerApplication {public static void main(String[] args) {// TODO Auto-generated method stubSpringApplication.run(SpringCloudConsumerApplication.class, args);}@Bean@LoadBalanced	//开启负载均衡public RestTemplate restTemplate() {return new RestTemplate();}}

5.添加controller

package com.springcloud.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;@RestController
@RequestMapping(path = "/consumer")
public class ConsumerController {@Autowiredprivate RestTemplate restTemp;@RequestMapping(path = "/getConsumer", method = RequestMethod.GET)public String getConsumer() {String result = restTemp.getForObject("http://springcloud-provider1/provider/getprovider", String.class);return result;}
}

6.多次call consumer的API访问测试,我们会发现返回值Provider1、Provider2、Provider3以轮询的方式出现。
在这里插入图片描述

7.注意:

我在测试的时候,开始有如下报错
在这里插入图片描述

在我本地maven仓库中也确实没找到对应的jar包,于是,在consumer的pom文件中新增了如下依赖:

<dependency><groupId>com.liferay</groupId><artifactId>org.apache.commons.configuration</artifactId><version>1.10.LIFERAY-PATCHED-2</version>
</dependency>

3.负载均衡策略

3.1.默认负载均衡策略

通过上述步骤,我们发现返回值以轮询的方式出现,也就说明consumer在调用provider的时候,是以轮询的方式访问。事实确实如此,Ribbon默认的负载均衡策略是轮询。

框架自带7种实现:com.netflix.loadbalancer.RoundRobinRule  - 轮询com.netflix.loadbalancer.RandomRule  - 随机com.netflix.loadbalancer.RetryRule - 重试,先按RoundRobinRule进行轮询,如果失败就在指定时间内进行重试com.netflix.loadbalancer.WeightedResponseTimeRule - 权重,响应速度越快,权重越大,越容易被选中。com.netflix.loadbalancer.BestAvailableRule  - 先过滤掉不可用的处于断路器跳闸转态的服务,然后选择一个并发量最小的服务com.netflix.loadbalancer.AvailabilityFilteringRule - 先过滤掉故障实例,再选择并发量较小的实例com.netflix.loadbalancer.ZoneAvoidanceRule - 默认规则,复合判断server所在区域的性能和server的可用性进行服务的选择。

3.2.修改Ribbon负载均衡策略

1.新建一个不会被@ComponentScan组件扫描到的包
在这里插入图片描述

2.修改负载均衡策略

package com.springcloud.myRule;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;@Configuration
public class myRule {@Beanpublic IRule ribbonRule() {return new RandomRule();}}

3.在主启动类添加@RibbonClient注解

package com.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;import com.springcloud.myRule.myRule;@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "springcloud-consumer1", configuration = myRule.class)
public class SpringCloudConsumerApplication {public static void main(String[] args) {// TODO Auto-generated method stubSpringApplication.run(SpringCloudConsumerApplication.class, args);}@Bean@LoadBalanced	//开启负载均衡public RestTemplate restTemplate() {return new RestTemplate();}}

4.重新启动consumer,我们可以发现返回值不再是以轮询的方式出现。

5.也可以参照此方法自定义负载均衡策略

4.源码地址

https://github.com/DamonLiu666/springcloud_test

这篇关于springcloud+Ribbon负载均衡的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1113495

相关文章

SpringBoot使用Apache Tika检测敏感信息

《SpringBoot使用ApacheTika检测敏感信息》ApacheTika是一个功能强大的内容分析工具,它能够从多种文件格式中提取文本、元数据以及其他结构化信息,下面我们来看看如何使用Ap... 目录Tika 主要特性1. 多格式支持2. 自动文件类型检测3. 文本和元数据提取4. 支持 OCR(光学

Java内存泄漏问题的排查、优化与最佳实践

《Java内存泄漏问题的排查、优化与最佳实践》在Java开发中,内存泄漏是一个常见且令人头疼的问题,内存泄漏指的是程序在运行过程中,已经不再使用的对象没有被及时释放,从而导致内存占用不断增加,最终... 目录引言1. 什么是内存泄漏?常见的内存泄漏情况2. 如何排查 Java 中的内存泄漏?2.1 使用 J

JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

《JAVA系统中SpringBoot应用程序的配置文件application.yml使用详解》:本文主要介绍JAVA系统中SpringBoot应用程序的配置文件application.yml的... 目录文件路径文件内容解释1. Server 配置2. Spring 配置3. Logging 配置4. Ma

Java 字符数组转字符串的常用方法

《Java字符数组转字符串的常用方法》文章总结了在Java中将字符数组转换为字符串的几种常用方法,包括使用String构造函数、String.valueOf()方法、StringBuilder以及A... 目录1. 使用String构造函数1.1 基本转换方法1.2 注意事项2. 使用String.valu

java脚本使用不同版本jdk的说明介绍

《java脚本使用不同版本jdk的说明介绍》本文介绍了在Java中执行JavaScript脚本的几种方式,包括使用ScriptEngine、Nashorn和GraalVM,ScriptEngine适用... 目录Java脚本使用不同版本jdk的说明1.使用ScriptEngine执行javascript2.

Spring MVC如何设置响应

《SpringMVC如何设置响应》本文介绍了如何在Spring框架中设置响应,并通过不同的注解返回静态页面、HTML片段和JSON数据,此外,还讲解了如何设置响应的状态码和Header... 目录1. 返回静态页面1.1 Spring 默认扫描路径1.2 @RestController2. 返回 html2

Spring常见错误之Web嵌套对象校验失效解决办法

《Spring常见错误之Web嵌套对象校验失效解决办法》:本文主要介绍Spring常见错误之Web嵌套对象校验失效解决的相关资料,通过在Phone对象上添加@Valid注解,问题得以解决,需要的朋... 目录问题复现案例解析问题修正总结  问题复现当开发一个学籍管理系统时,我们会提供了一个 API 接口去

Java操作ElasticSearch的实例详解

《Java操作ElasticSearch的实例详解》Elasticsearch是一个分布式的搜索和分析引擎,广泛用于全文搜索、日志分析等场景,本文将介绍如何在Java应用中使用Elastics... 目录简介环境准备1. 安装 Elasticsearch2. 添加依赖连接 Elasticsearch1. 创

Spring核心思想之浅谈IoC容器与依赖倒置(DI)

《Spring核心思想之浅谈IoC容器与依赖倒置(DI)》文章介绍了Spring的IoC和DI机制,以及MyBatis的动态代理,通过注解和反射,Spring能够自动管理对象的创建和依赖注入,而MyB... 目录一、控制反转 IoC二、依赖倒置 DI1. 详细概念2. Spring 中 DI 的实现原理三、

SpringBoot 整合 Grizzly的过程

《SpringBoot整合Grizzly的过程》Grizzly是一个高性能的、异步的、非阻塞的HTTP服务器框架,它可以与SpringBoot一起提供比传统的Tomcat或Jet... 目录为什么选择 Grizzly?Spring Boot + Grizzly 整合的优势添加依赖自定义 Grizzly 作为