springcloud按版本发布微服务达到不停机更新的效果

ops/2024/9/25 8:31:44/

本文基于以下环境完成

  • spring-boot 2.3.2.RELEASE
  • spring-cloud Hoxton.SR9
  • spring-cloud-alibaba 2.2.6.RELEASE
  • spring-cloud-starter-gateway 2.2.6.RELEASE
  • spring-cloud-starter-loadbalancer 2.2.6.RELEASE
  • nacos 2.0.3

一、思路

实现思路：
前端项目在请求后端接口时，携带一个版本号version，网关gateway在接收到这个version后，根据version的值去选择对应的微服务实例，服务之间的调用openfeign也通过版本号去选择对应的服务实例

举例：
每次更新项目时版本号递增，比如目前在使用的后端项目版本为1.0.0，那么前端携带的版本也是1.0.0,
当我们要更新项目时，后端新的版本为2.0.0 前端项目的版本也为2.0.0，如果用户没有刷新页面，那么还是携带旧的版本号1.0.0, 那么请求都会转发到后端1.0.0, 如果用户刷新页面，那么就会携带新版本号2.0.0，此时请求被转发后端2.0.0版本

实现方式：
排除自带的ribbon依赖

<exclusions><exclusion><groupId>org.springframework.cloud</groupId></exclusion>
</exclusions>

引入spring-cloud-loadbalancer依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId><version>2.2.6.RELEASE</version>
</dependency>

spring-cloud-loadbalancer文档地址：点我跳转

配置微服务版本号

spring:cloud:nacos:discovery:metadata:version: 2.0.0

后续可以在nacos中修改
在这里插入图片描述

二 、重写网关的负载策略

2.1 重写轮训负载均衡

spring-cloud-loadbalancer默认的负载策略是轮训，实现类为org.springframework.cloud.loadbalancer.core.RoundRobinLoadBalancer，我们主要看里面的choose和getInstanceResponse方法，在getInstanceResponse方法中传入ServiceInstance集合，然后从这个集合中选择一个合适的instance实例，那么我们只要在重写这个方法在里面添加版本的筛选
在这里插入图片描述那么我们再看一下这个类是如何实例化的，主要是org.springframework.cloud.loadbalancer.annotation.LoadBalancerClientConfiguration

在这里插入图片描述
注意@ConditionalOnMissingBean这个注解，只有当spring容器中没有ReactorLoadBalancer类型的bean时才会实例化。

我们新建一个VersionLoadBalancer类，跟RoundRobinLoadBalancer一样去实现ReactorServiceInstanceLoadBalancer接口(其实就是把他的代码copy过来，然后添加我们自定义的筛选条件)

import java.util.List;
import java.util.Random;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.cloud.loadbalancer.core.*;
import org.springframework.http.HttpHeaders;
import org.springframework.util.StringUtils;
import reactor.core.publisher.Mono;import org.springframework.beans.factory.ObjectProvider;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.reactive.DefaultResponse;
import org.springframework.cloud.client.loadbalancer.reactive.EmptyResponse;
import org.springframework.cloud.client.loadbalancer.reactive.Request;
import org.springframework.cloud.client.loadbalancer.reactive.Response;/*** {@link org.springframework.cloud.loadbalancer.core.RoundRobinLoadBalancer}** @Author * @Date 2024/4/18 11:46* @Description**/
public class VersionLoadBalancer implements ReactorServiceInstanceLoadBalancer {private static final Log log = LogFactory.getLog(VersionLoadBalancer.class);private final AtomicInteger position;@Deprecatedprivate ObjectProvider<ServiceInstanceSupplier> serviceInstanceSupplier;private ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider;private final String serviceId;/*** @param serviceId               id of the service for which to choose an instance* @param serviceInstanceSupplier a provider of {@link ServiceInstanceSupplier} that*                                will be used to get available instances* @deprecated Use {@link #VersionLoadBalancer(ObjectProvider, String)}} instead.*/@Deprecatedpublic VersionLoadBalancer(String serviceId,ObjectProvider<ServiceInstanceSupplier> serviceInstanceSupplier) {this(serviceId, serviceInstanceSupplier, new Random().nextInt(1000));}/*** @param serviceInstanceListSupplierProvider a provider of*                                            {@link ServiceInstanceListSupplier} that will be used to get available instances* @param serviceId                           id of the service for which to choose an instance*/public VersionLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider,String serviceId) {this(serviceInstanceListSupplierProvider, serviceId, new Random().nextInt(1000));}/*** @param serviceInstanceListSupplierProvider a provider of*                                            {@link ServiceInstanceListSupplier} that will be used to get available instances* @param serviceId                           id of the service for which to choose an instance* @param seedPosition                        Round Robin element position marker*/public VersionLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider,String serviceId, int seedPosition) {this.serviceId = serviceId;this.serviceInstanceListSupplierProvider = serviceInstanceListSupplierProvider;this.position = new AtomicInteger(seedPosition);}/*** @param serviceId               id of the service for which to choose an instance* @param serviceInstanceSupplier a provider of {@link ServiceInstanceSupplier} that*                                will be used to get available instances* @param seedPosition            Round Robin element position marker* @deprecated Use {@link #VersionLoadBalancer(ObjectProvider, String, int)}}* instead.*/@Deprecatedpublic VersionLoadBalancer(String serviceId,ObjectProvider<ServiceInstanceSupplier> serviceInstanceSupplier,int seedPosition) {this.serviceId = serviceId;this.serviceInstanceSupplier = serviceInstanceSupplier;this.position = new AtomicInteger(seedPosition);}@SuppressWarnings("all")@Override// see original// https://github.com/Netflix/ocelli/blob/master/ocelli-core/// src/main/java/netflix/ocelli/loadbalancer/RoundRobinLoadBalancer.javapublic Mono<Response<ServiceInstance>> choose(Request request) {HttpHeaders headers = (HttpHeaders) request.getContext();String requestVersion = headers.getFirst("version");// TODO: move supplier to Request?// Temporary conditional logic till deprecated members are removed.if (serviceInstanceListSupplierProvider != null) {ServiceInstanceListSupplier supplier = serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new);return supplier.get().next().map(m -> this.getInstanceResponse(m, requestVersion));}ServiceInstanceSupplier supplier = this.serviceInstanceSupplier.getIfAvailable(NoopServiceInstanceSupplier::new);return supplier.get().collectList().map(m -> this.getInstanceResponse(m, requestVersion));}@SuppressWarnings("deprecation")private Response<ServiceInstance> getInstanceResponse(List<ServiceInstance> instances, String requestVersion) {List<ServiceInstance> serviceInstances = this.filterInstance(instances, requestVersion);if (serviceInstances.isEmpty()) {log.warn("No servers available for service: " + this.serviceId + " ,request version: " + requestVersion);return new EmptyResponse();}// TODO: enforce order?int pos = Math.abs(this.position.incrementAndGet());ServiceInstance instance = serviceInstances.get(pos % serviceInstances.size());return new DefaultResponse(instance);}/*** 获取对应的版本** @param instances* @param requestVersion* @return*/private List<ServiceInstance> filterInstance(List<ServiceInstance> instances, String requestVersion) {if (StringUtils.isEmpty(requestVersion)) {return instances;}return instances.stream().filter(f -> requestVersion.equals(f.getMetadata().get("version"))).collect(Collectors.toList());}}

然后新建一个配置类VersionLoadBalancerConfig，注意不能使用@Configuration

import com.demo.gateway.filter.VersionLoadBalancer;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;/*** 注意: 这里不能使用@Configuration !!!* 参考 {@link org.springframework.cloud.loadbalancer.annotation.LoadBalancerClientConfiguration}** @Author * @Date 2024/4/18 11:50* @Description**/public class VersionLoadBalancerConfig {@Beanpublic ReactorLoadBalancer<ServiceInstance> reactorServiceInstanceLoadBalancer(Environment environment,LoadBalancerClientFactory loadBalancerClientFactory) {String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);return new VersionLoadBalancer(loadBalancerClientFactory.getLazyProvider(name,ServiceInstanceListSupplier.class), name);}}

官方文档示例
在这里插入图片描述
然后在项目的启动类添加@LoadBalancerClients(defaultConfiguration = {VersionLoadBalancerConfig.class})

import com.demo.gateway.config.VersionLoadBalancerConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClients;/*** @Author * @Date 2022/10/10 16:38* @Description**/
@EnableDiscoveryClient
@SpringBootApplication
@LoadBalancerClients(defaultConfiguration = {VersionLoadBalancerConfig.class})
public class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class, args);}}

2.2 重写过滤器

此时运行项目发现碰到空指针异常，断点后发现是VersionLoadBalancer.choose方法里面request.getContext()是个null值，那么我们再看一下是在哪里调用了这个方法，主要是org.springframework.cloud.gateway.filter.ReactiveLoadBalancerClientFilter
在这里插入图片描述在这里插入图片描述那么我们需要重写这个过滤器，在choose方法里面将我们http请求的header对象传递给VersionLoadBalancer，我们再看一下ReactiveLoadBalancerClientFilter是怎么初始化的，主要是org.springframework.cloud.gateway.config.GatewayReactiveLoadBalancerClientAutoConfiguration
在这里插入图片描述
那么我们就可以新建一个VersionLoadBalancerFilter去覆盖原来的ReactiveLoadBalancerClientFilter(如果直接新增一个过滤器那么原来的过滤器也会执行，还会有过滤器的执行顺序问题)

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerUriTools;
import org.springframework.cloud.client.loadbalancer.reactive.DefaultRequest;
import org.springframework.cloud.client.loadbalancer.reactive.Request;
import org.springframework.cloud.client.loadbalancer.reactive.Response;
import org.springframework.cloud.gateway.config.LoadBalancerProperties;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.cloud.gateway.filter.ReactiveLoadBalancerClientFilter;
import org.springframework.cloud.gateway.support.DelegatingServiceInstance;
import org.springframework.cloud.gateway.support.NotFoundException;
import org.springframework.cloud.gateway.support.ServerWebExchangeUtils;
import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.core.Ordered;
import org.springframework.http.HttpHeaders;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;import java.net.URI;import static org.springframework.cloud.gateway.support.ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR;/*** 参考 {@link ReactiveLoadBalancerClientFilter}* @Author SYLIANG* @Date 2024/4/19 10:48* @Description**/
public class VersionLoadBalancerFilter extends ReactiveLoadBalancerClientFilter implements GlobalFilter, Ordered {private static final Log log = LogFactory.getLog(VersionLoadBalancerFilter.class);private static final int LOAD_BALANCER_CLIENT_FILTER_ORDER = 10250;private final LoadBalancerClientFactory clientFactory;private LoadBalancerProperties properties;public VersionLoadBalancerFilter(LoadBalancerClientFactory clientFactory, LoadBalancerProperties properties) {super(clientFactory, properties);this.clientFactory = clientFactory;this.properties = properties;}@Overridepublic int getOrder() {return LOAD_BALANCER_CLIENT_FILTER_ORDER;}@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {URI url = (URI)exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);String schemePrefix = (String)exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR);if (url != null && ("lb".equals(url.getScheme()) || "lb".equals(schemePrefix))) {ServerWebExchangeUtils.addOriginalRequestUrl(exchange, url);if (log.isTraceEnabled()) {log.trace(ReactiveLoadBalancerClientFilter.class.getSimpleName() + " url before: " + url);}return this.choose(exchange).doOnNext((response) -> {if (!response.hasServer()) {throw NotFoundException.create(this.properties.isUse404(), "Unable to find instance for " + url.getHost());} else {ServiceInstance retrievedInstance = (ServiceInstance)response.getServer();URI uri = exchange.getRequest().getURI();String overrideScheme = retrievedInstance.isSecure() ? "https" : "http";if (schemePrefix != null) {overrideScheme = url.getScheme();}DelegatingServiceInstance serviceInstance = new DelegatingServiceInstance(retrievedInstance, overrideScheme);URI requestUrl = this.reconstructURI(serviceInstance, uri);if (log.isTraceEnabled()) {log.trace("LoadBalancerClientFilter url chosen: " + requestUrl);}exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, requestUrl);}}).then(chain.filter(exchange));} else {return chain.filter(exchange);}}@Overrideprotected URI reconstructURI(ServiceInstance serviceInstance, URI original) {return LoadBalancerUriTools.reconstructURI(serviceInstance, original);}@SuppressWarnings("deprecation")private Mono<Response<ServiceInstance>> choose(ServerWebExchange exchange) {URI uri = exchange.getAttribute(GATEWAY_REQUEST_URL_ATTR);ReactorLoadBalancer<ServiceInstance> loadBalancer = this.clientFactory.getInstance(uri.getHost(), VersionLoadBalancer.class);if (loadBalancer == null) {throw new NotFoundException("No loadbalancer available for " + uri.getHost());} else {return loadBalancer.choose(this.createRequest(exchange));}}@SuppressWarnings("deprecation")private Request createRequest(ServerWebExchange exchange) {HttpHeaders headers = exchange.getRequest().getHeaders();Request<HttpHeaders> request = new DefaultRequest<>(headers);return request;}
}

注意choose方法里面的ReactorLoadBalancer loadBalancer = this.clientFactory.getInstance(uri.getHost(), VersionLoadBalancer.class); 这里不能直接new，否则轮训会失效

新建配置类VersionFilterConfiguration

import com.personnel.gateway.filter.VersionLoadBalancerFilter;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer;
import org.springframework.cloud.gateway.config.GatewayLoadBalancerClientAutoConfiguration;
import org.springframework.cloud.gateway.config.LoadBalancerProperties;
import org.springframework.cloud.gateway.filter.ReactiveLoadBalancerClientFilter;
import org.springframework.cloud.loadbalancer.config.LoadBalancerAutoConfiguration;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.DispatcherHandler;/*** ReactiveLoadBalancerClientFilter过滤器的Request没有请求头信息* 参考 {@link org.springframework.cloud.gateway.config.GatewayReactiveLoadBalancerClientAutoConfiguration}** @Author * @Date 2024/4/22 15:56* @Description**/
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass({LoadBalancerClient.class, ReactiveLoadBalancer.class,LoadBalancerAutoConfiguration.class, DispatcherHandler.class})
@AutoConfigureBefore(GatewayLoadBalancerClientAutoConfiguration.class)
@AutoConfigureAfter(LoadBalancerAutoConfiguration.class)
@EnableConfigurationProperties(LoadBalancerProperties.class)
public class VersionFilterConfiguration {@Beanpublic ReactiveLoadBalancerClientFilter versionLoadBalancer(LoadBalancerClientFactory clientFactory,LoadBalancerProperties properties) {return new VersionLoadBalancerFilter(clientFactory, properties);}}

三、重写openfeign的负载策略

3.1 spring-cloud-loadbalancer负载

我们同样使用spring-cloud-loadbalancer作为负载均衡器，新建自定义负载策略VersionLoadBalancer类，注意这里面的版本号version通过spring-web的ServletRequestAttributes获取

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.reactive.DefaultResponse;
import org.springframework.cloud.client.loadbalancer.reactive.EmptyResponse;
import org.springframework.cloud.client.loadbalancer.reactive.Request;
import org.springframework.cloud.client.loadbalancer.reactive.Response;
import org.springframework.cloud.loadbalancer.core.*;
import org.springframework.http.HttpHeaders;
import org.springframework.util.StringUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import reactor.core.publisher.Mono;import java.util.List;
import java.util.Random;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;/**** 重写负载均衡策略: 通过版本选择服务实例* {@link RoundRobinLoadBalancer}** @Author * @Date 2024/4/18 11:46* @Description**/
public class VersionLoadBalancer implements ReactorServiceInstanceLoadBalancer {private static final Log log = LogFactory.getLog(VersionLoadBalancer.class);private final AtomicInteger position;@Deprecatedprivate ObjectProvider<ServiceInstanceSupplier> serviceInstanceSupplier;private ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider;private final String serviceId;private final String version = "version";/*** @param serviceId               id of the service for which to choose an instance* @param serviceInstanceSupplier a provider of {@link ServiceInstanceSupplier} that*                                will be used to get available instances* @deprecated Use {@link #VersionLoadBalancer(ObjectProvider, String)}} instead.*/@Deprecatedpublic VersionLoadBalancer(String serviceId,ObjectProvider<ServiceInstanceSupplier> serviceInstanceSupplier) {this(serviceId, serviceInstanceSupplier, new Random().nextInt(1000));}/*** @param serviceInstanceListSupplierProvider a provider of*                                            {@link ServiceInstanceListSupplier} that will be used to get available instances* @param serviceId                           id of the service for which to choose an instance*/public VersionLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider,String serviceId) {this(serviceInstanceListSupplierProvider, serviceId, new Random().nextInt(1000));}/*** @param serviceInstanceListSupplierProvider a provider of*                                            {@link ServiceInstanceListSupplier} that will be used to get available instances* @param serviceId                           id of the service for which to choose an instance* @param seedPosition                        Round Robin element position marker*/public VersionLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider,String serviceId, int seedPosition) {this.serviceId = serviceId;this.serviceInstanceListSupplierProvider = serviceInstanceListSupplierProvider;this.position = new AtomicInteger(seedPosition);}/*** @param serviceId               id of the service for which to choose an instance* @param serviceInstanceSupplier a provider of {@link ServiceInstanceSupplier} that*                                will be used to get available instances* @param seedPosition            Round Robin element position marker* @deprecated Use {@link #VersionLoadBalancer(ObjectProvider, String, int)}}* instead.*/@Deprecatedpublic VersionLoadBalancer(String serviceId,ObjectProvider<ServiceInstanceSupplier> serviceInstanceSupplier,int seedPosition) {this.serviceId = serviceId;this.serviceInstanceSupplier = serviceInstanceSupplier;this.position = new AtomicInteger(seedPosition);}@SuppressWarnings("all")@Override// see original// https://github.com/Netflix/ocelli/blob/master/ocelli-core/// src/main/java/netflix/ocelli/loadbalancer/RoundRobinLoadBalancer.javapublic Mono<Response<ServiceInstance>> choose(Request request) {ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();String requestVersion = requestAttributes.getRequest().getHeader(version);// TODO: move supplier to Request?// Temporary conditional logic till deprecated members are removed.if (serviceInstanceListSupplierProvider != null) {ServiceInstanceListSupplier supplier = serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new);return supplier.get().next().map(m -> this.getInstanceResponse(m, requestVersion));}ServiceInstanceSupplier supplier = this.serviceInstanceSupplier.getIfAvailable(NoopServiceInstanceSupplier::new);return supplier.get().collectList().map(m -> this.getInstanceResponse(m, requestVersion));}@SuppressWarnings("deprecation")private Response<ServiceInstance> getInstanceResponse(List<ServiceInstance> instances, String requestVersion) {List<ServiceInstance> serviceInstances = this.filterInstance(instances, requestVersion);if (serviceInstances.isEmpty()) {log.warn("No servers available for service: " + this.serviceId + " ,request version: " + requestVersion);return new EmptyResponse();}// TODO: enforce order?int pos = Math.abs(this.position.incrementAndGet());ServiceInstance instance = serviceInstances.get(pos % serviceInstances.size());return new DefaultResponse(instance);}/*** 获取对应的版本** @param instances* @param requestVersion* @return*/private List<ServiceInstance> filterInstance(List<ServiceInstance> instances, String requestVersion) {if (StringUtils.isEmpty(requestVersion)) {return instances;}return instances.stream().filter(f -> requestVersion.equals(f.getMetadata().get(version))).collect(Collectors.toList());}}

新建配置类VersionLoadBalancerConfig

import com.personnel.common.load.VersionLoadBalancer;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;/*** 注意: 这里不能使用@Configuration !!!* 参考 {@link org.springframework.cloud.loadbalancer.annotation.LoadBalancerClientConfiguration}** @Author * @Date 2024/4/18 11:50* @Description**/public class VersionLoadBalancerConfig {@Beanpublic ReactorLoadBalancer<ServiceInstance> reactorServiceInstanceLoadBalancer(Environment environment,LoadBalancerClientFactory loadBalancerClientFactory) {String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);return new VersionLoadBalancer(loadBalancerClientFactory.getLazyProvider(name,ServiceInstanceListSupplier.class), name);}}

在启动类中添加@LoadBalancerClients(defaultConfiguration = {VersionLoadBalancerConfig.class})

3.2 ribbon负载

如果使用ribbon则使用以下配置

import com.alibaba.cloud.nacos.ribbon.NacosServer;
import com.google.common.base.Optional;
import com.netflix.loadbalancer.Server;
import com.netflix.loadbalancer.ZoneAvoidanceRule;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;import java.util.ArrayList;
import java.util.List;/*** openfeign调用根据版本选择对应的实例* @Author * @Date 2024/1/18 14:16* @Description**/
@Component
public class VersionReleaseRule extends ZoneAvoidanceRule {private final String version = "version";@Overridepublic Server choose(Object key) {ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();String requestVersion = requestAttributes.getRequest().getHeader(version);if (!StringUtils.isEmpty(requestVersion)) {List<Server> serverList = this.getLoadBalancer().getAllServers();List<Server> versionServers = new ArrayList<>();for (Server server : serverList) {NacosServer nacosServer = (NacosServer) server;if (requestVersion.equals(nacosServer.getMetadata().get(version))) {versionServers.add(server);}}if (!CollectionUtils.isEmpty(versionServers)) {Optional<Server> serverOptional = this.getPredicate().chooseRoundRobinAfterFiltering(versionServers, key);return serverOptional.isPresent() ? serverOptional.get() : null;}}return super.choose(key);}
}

四、openfeign携带token

在openfeign调用时如果没有携带token则添加以下配置

import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;/***  openfeign请求添加token* @Author SYLIANG* @Date 2024/4/25 11:22* @Description**/
@Configuration
public class FeignClientInterceptorConfig {private final String authorization = "Authorization";@Beanpublic RequestInterceptor requestInterceptor() {return new RequestInterceptor() {@Overridepublic void apply(RequestTemplate requestTemplate) {// 从当前请求的 Header 中获取 tokenServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();if (attributes != null) {String token = attributes.getRequest().getHeader(authorization);if (token != null && !token.isEmpty()) {// 添加 token 到请求头部requestTemplate.header(authorization, token);}}}};}
}

http://www.ppmy.cn/ops/19490.html

相关文章

制造型企业 如何实现便捷的机台文件统一管理？

制造型企业 如何实现便捷的机台文件统一管理？

机台文件统一管理&#xff0c;这是生产制造型企业都需要去做的&#xff0c;机台文件需要统一管理的原因主要包括以下几点&#xff1a; 1、提高效率&#xff1a;统一管理可以简化文件的访问和使用过程&#xff0c;提高工作效率&#xff0c;尤其是在需要频繁访问或更新机台文件的…
阅读更多...
微信小程序实时日志使用，setFilterMsg用法

微信小程序实时日志使用，setFilterMsg用法

实时日志 背景 为帮助小程序开发者快捷地排查小程序漏洞、定位问题&#xff0c;我们推出了实时日志功能。开发者可通过提供的接口打印日志&#xff0c;日志汇聚并实时上报到小程序后台。开发者可从We分析“性能质量->实时日志->小程序日志”进入小程序端日志查询页面&am…
阅读更多...
K8s: 公有镜像中心和私有镜像中心的搭建

K8s: 公有镜像中心和私有镜像中心的搭建

公有镜像中心的搭建和使用 1 &#xff09;在 官方docker镜像中心推送 在 hub.docker.com 上注册账号 (国内一般访问不了&#xff0c;原因不多说) 找到 Create Repository 按钮就行仓库的创建 这样就在官方创建了一个仓库&#xff0c;比如地址为: xx/y-y xx 是我的账户名y-y 是…
阅读更多...
【网站项目】考研助手

【网站项目】考研助手

&#x1f64a;作者简介&#xff1a;拥有多年开发工作经验&#xff0c;分享技术代码帮助学生学习&#xff0c;独立完成自己的项目或者毕业设计。 代码可以私聊博主获取。&#x1f339;赠送计算机毕业设计600个选题excel文件&#xff0c;帮助大学选题。赠送开题报告模板&#xff…
阅读更多...
ZIP压缩输入流（将文件压缩为ZIP文件）

ZIP压缩输入流（将文件压缩为ZIP文件）

文章目录 前言一、ZIP压缩输入流是什么&#xff1f;二、使用介绍 1.使用方法2.实操展示总结 前言 该篇文章将会介绍如何使用java代码将各种文件&#xff08;文件夹&#xff09;的资源压缩为一个ZIP压缩包。通过java.util包中的ZipOutputStream类来实现。并且需要自定义压缩方法…
阅读更多...
富格林：可信方针实现安全盈利

富格林：可信方针实现安全盈利

富格林指出&#xff0c;现货黄金一直以来都是投资者们追捧的热门品种之一。其安全性和保值增值的特性吸引着广大投资者。然而&#xff0c;要在现货黄金市场中取得成功并非易事&#xff0c;是需要一定的可信技巧和方针来支撑的。下面富格林将介绍一些关键的可信方针&#xff0c;…
阅读更多...
java:基于guava ClassPath工具实现基于包名(package)的类扫描

java:基于guava ClassPath工具实现基于包名(package)的类扫描

google的guava库提供了一个类路径扫描的实用工具ClassPath(参见说明&#xff1a; https://github.com/google/guava/wiki/ReflectionExplained#classpath)工具&#xff0c;适用于非android的Java平台搜索类。基于它可以设计一个过滤包名的搜索工具。 导入依赖库 <dependen…
阅读更多...
CSS基础选择器

CSS基础选择器

标签选择器&#xff1a;标签名 p{ font-size:16px;} 类选择器&#xff1a;.class { font-size:16px;} <标签名 class "类名称">标签内容</标签名> id选择器&#xff1a;#id { font-size:16px;} <标签名 id "id名称">标签内容</标签…
阅读更多...
最新文章

Copyright @ 2022~2023