如何制作网站图片,自助建站平台,用什么软件做公司网站,中山家居企业网站建设文章目录零、懒汉式改为饿汉式一、基于配置文件二、基于Bean配置三、自定义规则1 权重优先调用2 集群优先调用3 元数据优先调用零、懒汉式改为饿汉式
【consumer-springboot-80子模块】
Ribbon默认使用懒汉式加载服务列表#xff0c;更改为懒汉式 application.yml
ribbon: …
文章目录零、懒汉式改为饿汉式一、基于配置文件二、基于Bean配置三、自定义规则1 权重优先调用2 集群优先调用3 元数据优先调用零、懒汉式改为饿汉式
【consumer-springboot-80子模块】
Ribbon默认使用懒汉式加载服务列表更改为懒汉式 application.yml
ribbon: # Ribbon相关配置eager-load: # 采用饿汉式进行加载clients: dept.provider # 设置服务名称使用“,”分割enabled: true # 启用饿汉式一、基于配置文件
2、【consumer-springboot-80子模块】 按照SpringCloud 所给出的官方文档来讲所有Ribbon相关的负载均衡策略全部都可以在application.yml配置文件之中进行定义对于定义的模型采用的是“ServiceID.ribbon.类型处理子类”本次开发之中所使用的“dept.provider”名称就属于一个ServicelD如果要想为项目进行 application.yml配置就采用如下的方式定义了。 修改application.yml配置文件追加一个随机访问算法。
dept.provider: # 微服务的IDribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # IRule子类按照现在所给出的代码的形式应该已经可以成功的进行了访问处理了所以官方文档所提供的配置项是可以使用的。
3、【consumer-springboot-80子模块】修改application.yml配置文件追加自定义负载均衡配置实现现在默认情况下可以见到的负载均衡的算法为“DynamicServerListLoadBalancer”类型本次配置同样的类型。
dept.provider: # 微服务的IDribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # IRule子类NFLoadBalancerClassName: com.netflix.loadbalancer.DynamicServerListLoadBalancer # ILoadBalancer二、基于Bean配置
重要提醒: 不要与应用程序组件包重合。虽然之前所有配置的Bean都是放在了SpringBoot启动类的CLASSPATH环境之中但是Ribbon的配置类不能够放在被直接扫描的路径下因为会有可能造成配置的冲突。 package muyan.yootk.config.ribbon; // 该包不在应用程序启动类的扫描包路径下import com.netflix.loadbalancer.IRule;
import muyan.yootk.loadbalancer.rule.NacosVersionRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration // 这个类必须使用该注解定义
public class DeptProviderRibbonConfig {Bean // Bean注册public IRule ribbonRule() { // 自定义负载均衡规则return new RandomRule(); // 随机读取}
} 在没有进行该规则Bean配置的时候之前采用的是一种轮询的处理模式:按照实例的数量(123123)轮番调用,但是现在变为了随机调用。 package com.yootk.consumer;import muyan.yootk.config.ribbon.DeptProviderRibbonConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.cloud.openfeign.EnableFeignClients;SpringBootApplication
EnableDiscoveryClient
// 如果此时要有多个配置项可以使用RibbonClients注解该注解可以配置多个RibbonClient
RibbonClient(name dept.provider, configuration DeptProviderRibbonConfig.class) // 自定义Ribbon配置
EnableFeignClients(com.yootk.service) // Feign扫描包
public class StartConsumerApplication {public static void main(String[] args) {SpringApplication.run(StartConsumerApplication.class, args);}
}
三、自定义规则 既然在Ribbon里面提供了如此多的默认的规则算法那么也就可以由用户自己来进行自定义规则算法的使用了此时直接定义配置Bean即可。 重要提醒: 不要与应用程序组件包重合。虽然之前所有配置的Bean都是放在了SpringBoot启动类的CLASSPATH环境之中但是Ribbon的配置类不能够放在被直接扫描的路径下因为会有可能造成配置的冲突。 1 权重优先调用 修改权重可以通过Nacos控制台的模型完成一般是用于动态修改之中的操作)也可以直接通过微服务application.yml的方式来进行权重的配置。修改完成之后再次通过消费端来进行部门微服务的调用这个时候发现并没有根据权重的大小来实现定义这主要是因为Ribbon消费端的负载均衡的算法没有进行有效的配置 1.【provider-dept-*子模块】既然要观察权重可以考虑为所有部门微服务的节点来配置权重的内容修改每一个微服务之中的application.yml 配置文件编辑权重的内容:
provider-dept-8001配置:
spring:application: # 配置应用信息name: dept.provider # 是微服务的名称cloud: # Cloud配置nacos: # Nacos注册中心配置discovery: # 发现服务weight: 10provider-dept-8002配置: weight: 50 provider-dept-8003配置: weight: 80
2、【consumer-springboot-80子模块】创建一个新的负载均衡算法该算法将基于权重的高低进行调度。
package muyan.yootk.loadbalancer.rule;import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.cloud.nacos.ribbon.NacosServer;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;// 如果要想进行规则的定义常见的做法是直接使用IRule接口完成
// 推荐的做法是使用IRule接口对应的抽象子类AbstractLoadBalancerRule
Slf4j
public class NacosWeightRule extends AbstractLoadBalancerRule { // Nacos权重规则Autowiredprivate NacosDiscoveryProperties nacosDiscoveryProperties; // Nacos配置属性private IClientConfig clientConfig;Overridepublic void initWithNiwsConfig(IClientConfig clientConfig) {this.clientConfig clientConfig;}Overridepublic Server choose(Object key) { // 选择服务实例BaseLoadBalancer loadBalancer (BaseLoadBalancer) super.getLoadBalancer(); // 获取负载均衡器String name loadBalancer.getName(); // 调用微服务名称// 此时的场景就变为了原生项目的NacosClient组件进行处理的操作了NamingService namingService this.nacosDiscoveryProperties.namingServiceInstance(); // 发现服务// 根据指定的服务名称以及分组名称获取服务的实例try {Instance instance namingService.selectOneHealthyInstance(name, this.nacosDiscoveryProperties.getGroup());// 整个的代码是工作在SpringCloud之中的所以需要将获取到的Instance对象实例转为Server对象实例return new NacosServer(instance); // NacosServer是Server子类} catch (NacosException e) {log.error(获取Nacos注册的微服务实例出错异常为 e);return null;}}
}
3、【consumer-springboot-80子模块】DeptProviderRibbonConfig
package muyan.yootk.config.ribbon; // 该包不在应用程序启动类的扫描包路径下import com.netflix.loadbalancer.IRule;
import muyan.yootk.loadbalancer.rule.NacosVersionRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration // 这个类必须使用该注解定义
public class DeptProviderRibbonConfig {Bean // Bean注册public IRule ribbonRule() { // 自定义负载均衡规则return new NacosWeightRule(); // 随机读取}
}启动类
package com.yootk.consumer;import muyan.yootk.config.ribbon.DeptProviderRibbonConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.cloud.openfeign.EnableFeignClients;SpringBootApplication
EnableDiscoveryClient
// 如果此时要有多个配置项可以使用RibbonClients注解该注解可以配置多个RibbonClient
RibbonClient(name dept.provider, configuration DeptProviderRibbonConfig.class) // 自定义Ribbon配置
EnableFeignClients(com.yootk.service) // Feign扫描包
public class StartConsumerApplication { // 沐言科技www.yootk.compublic static void main(String[] args) {SpringApplication.run(StartConsumerApplication.class, args);}
}2 集群优先调用
1、【consumer-springboot-80子模块】NacosClusterWeightRule
package muyan.yootk.loadbalancer.rule;import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.cloud.nacos.ribbon.ExtendBalancer;
import com.alibaba.cloud.nacos.ribbon.NacosServer;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.AbstractLoadBalancerRule;
import com.netflix.loadbalancer.BaseLoadBalancer;
import com.netflix.loadbalancer.Server;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;Slf4j
public class NacosClusterWeightRule extends AbstractLoadBalancerRule {// 如果要想按照集群调用那么首先一定要知道当前消费端的集群名称是什么Autowiredprivate NacosDiscoveryProperties nacosDiscoveryProperties; // 注入Nacos发现服务配置项Autowiredprivate IClientConfig clientConfig;Overridepublic void initWithNiwsConfig(IClientConfig clientConfig) {this.clientConfig clientConfig;}Overridepublic Server choose(Object key) { // 核心关键BaseLoadBalancer loadBalancer (BaseLoadBalancer) super.getLoadBalancer();// 如果此时没有这个调用的微服务名称那么是无法实现最终的服务查询的String name loadBalancer.getName();// 获取服务名称NamingService namingService this.nacosDiscoveryProperties.namingServiceInstance();// 获取指定服务名称的全部的实例列表数据try {// 根据指定的服务名称以及分组查询所有健康的服务实例列表此时的列表包含有所有的集群信息ListInstance instances namingService.selectInstances(name, this.nacosDiscoveryProperties.getGroup(), true);// 理论上现在应该采用的是迭代的处理形式将全部的集合列表进行迭代处理随后进行集群名称的判断ListInstance clusterInstance instances.stream().filter(instance - Objects.equals(instance.getClusterName(), this.nacosDiscoveryProperties.getClusterName())).collect(Collectors.toList());ListInstance instancesChoose null; // 保存最终的返回的列表// 如果以上的处理可以获取指定集群名称下的全部的服务实例数据那么就可以随意返回一个但是如果不能够获取if (CollectionUtils.isEmpty(clusterInstance)) { // 此时集群下的实例列表为空// 此时在指定集群名称下没有查找到任何的实例列表所以就把所获取到的全部实例列表instancesChoose instances;} else { // 如果已经查找到了指定集群名称下的实例列表instancesChoose clusterInstance; // 保存集群实例列表}// 因为最终所需要的是一个Server实例信息所以这个时候可以考虑随机读取一个或者按照权重返回一个Instance selectedInstance ExtendBalancer.getHostByRandomWeight2(instancesChoose);return new NacosServer(selectedInstance); // 指定集群名称下的一个实例} catch (NacosException e) {log.error(服务实例查询时出现了错误异常为{}, e);}return null;}
}
2、【consumer-springboot-80子模块】DeptProviderRibbonConfig
package muyan.yootk.config.ribbon; // 该包不在应用程序启动类的扫描包路径下import com.netflix.loadbalancer.IRule;
import muyan.yootk.loadbalancer.rule.NacosVersionRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration // 这个类必须使用该注解定义
public class DeptProviderRibbonConfig {Bean // Bean注册public IRule ribbonRule() { // 自定义负载均衡规则return new NacosClusterWeightRule (); // 随机读取}
}3 元数据优先调用
1、【consumer-springboot-80子模块】NacosVersionRule
package muyan.yootk.loadbalancer.rule;import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.cloud.nacos.ribbon.ExtendBalancer;
import com.alibaba.cloud.nacos.ribbon.NacosServer;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.AbstractLoadBalancerRule;
import com.netflix.loadbalancer.BaseLoadBalancer;
import com.netflix.loadbalancer.Server;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;Slf4j
public class NacosVersionRule extends AbstractLoadBalancerRule {// 如果要想按照集群调用那么首先一定要知道当前消费端的集群名称是什么Autowiredprivate NacosDiscoveryProperties nacosDiscoveryProperties; // 注入Nacos发现服务配置项Autowiredprivate IClientConfig clientConfig;Overridepublic void initWithNiwsConfig(IClientConfig clientConfig) {this.clientConfig clientConfig;}Overridepublic Server choose(Object key) {BaseLoadBalancer loadBalancer (BaseLoadBalancer) super.getLoadBalancer();// 如果此时没有这个调用的微服务名称那么是无法实现最终的服务查询的String name loadBalancer.getName();// 获取服务名称NamingService namingService this.nacosDiscoveryProperties.namingServiceInstance();try {// 根据指定的服务名称以及分组的名称获取全部的可用实例数据ListInstance instances namingService.selectInstances(name, this.nacosDiscoveryProperties.getGroup(), true);// 对获取到的实例集合进行迭代处理筛选出所需要的与当前版本匹配的实例数据ListInstance metadataVersionMatchInstance instances.stream().filter(instance - Objects.equals(this.nacosDiscoveryProperties.getMetadata().get(version), // 消费端配置的元数据版本项instance.getMetadata().get(version))) // 注册微服务实例配置的元数据版本项.collect(Collectors.toList());// 必须考虑没有匹配版本下的实例筛选操作ListInstance selectedInstances null; // 最终所使用的实例集合if (CollectionUtils.isEmpty(metadataVersionMatchInstance)) { // 没有查询到匹配的集合selectedInstances instances;} else {selectedInstances metadataVersionMatchInstance; // 版本匹配}Instance instance ExtendBalancer.getHostByRandomWeight2(selectedInstances);return new NacosServer(instance);} catch (NacosException e) {log.error(获取Nacos注册的微服务实例出错异常为 e);}return null;}
}
3、【consumer-springboot-80子模块】DeptProviderRibbonConfig
package muyan.yootk.config.ribbon; // 该包不在应用程序启动类的扫描包路径下import com.netflix.loadbalancer.IRule;
import muyan.yootk.loadbalancer.rule.NacosVersionRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration // 这个类必须使用该注解定义
public class DeptProviderRibbonConfig {Bean // Bean注册public IRule ribbonRule() { // 自定义负载均衡规则return new NacosVersionRule (); // 随机读取}
}
