国产 无码 综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

Spring Cloud Gateway + Nacos 灰度發(fā)布

這篇具有很好參考價值的文章主要介紹了Spring Cloud Gateway + Nacos 灰度發(fā)布。希望對大家有所幫助。如果存在錯誤或未考慮完全的地方,請大家不吝賜教,您也可以點擊"舉報違法"按鈕提交疑問。

前言

本文將會使用 SpringCloud Gateway 網(wǎng)關(guān)組件配合 Nacos 實現(xiàn)灰度發(fā)布(金絲雀發(fā)布)

環(huán)境搭建

創(chuàng)建子模塊服務(wù)提供者?provider,網(wǎng)關(guān)模塊?gateway

父項目

pom.xml 配置

<?xml version="1.0" encoding="UTF-8"?>  
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">  
    <modelVersion>4.0.0</modelVersion>  
  
  
    <groupId>com.example</groupId>  
    <artifactId>spring-gateway-demo</artifactId>  
    <version>0.0.1-SNAPSHOT</version>  
    <packaging>pom</packaging>  
    <name>spring-gateway-demo</name>  
    <description>spring-gateway-demo</description>  
  
    <properties>  
        <java.version>11</java.version>  
        <maven.compiler.source>11</maven.compiler.source>  
        <maven.compiler.target>11</maven.compiler.target>  
        <maven.compiler.plugin>3.8.1</maven.compiler.plugin>  
        <spring-boot.version>2.3.7.RELEASE</spring-boot.version>  
        <spring-cloud-alibaba.version>2.2.2.RELEASE</spring-cloud-alibaba.version>  
        <spring-cloud.version>Hoxton.SR9</spring-cloud.version>  
        <spring-cloud-starter-alibaba-nacos-config>2.2.0.RELEASE</spring-cloud-starter-alibaba-nacos-config>  
    </properties>  
  
    <modules>  
        <module>provider</module>  
        <module>gateway</module>  
    </modules>  
  
    <dependencies>  
        <dependency>  
            <groupId>com.alibaba.cloud</groupId>  
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>com.alibaba.cloud</groupId>  
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>  
        </dependency>  
    </dependencies>  
  
    <dependencyManagement>  
        <dependencies>  
            <dependency>  
                <groupId>org.springframework.cloud</groupId>  
                <artifactId>spring-cloud-dependencies</artifactId>  
                <version>${spring-cloud.version}</version>  
                <type>pom</type>  
                <scope>import</scope>  
            </dependency>  
            <dependency>  
                <groupId>org.springframework.boot</groupId>  
                <artifactId>spring-boot-dependencies</artifactId>  
                <version>${spring-boot.version}</version>  
                <type>pom</type>  
                <scope>import</scope>  
            </dependency>  
            <dependency>  
                <groupId>com.alibaba.cloud</groupId>  
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>  
                <version>${spring-cloud-alibaba.version}</version>  
                <type>pom</type>  
                <scope>import</scope>  
            </dependency>  
        </dependencies>  
    </dependencyManagement>  
</project>

服務(wù)提供者 provider

這里我們計劃引入?nacos, 所以先創(chuàng)建一個 nacos 配置文件?dataId?為?provider.properties, 這里用默認(rèn)的命名空間?public, 默認(rèn)分組?DEFAULT_GROUP

version=2

provider 的 pom 配置依賴

<dependencies>  
    <dependency>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-web</artifactId>  
    </dependency>  
  
    <dependency>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-test</artifactId>  
        <scope>test</scope>  
        <exclusions>  
            <exclusion>  
                <groupId>org.junit.vintage</groupId>  
                <artifactId>junit-vintage-engine</artifactId>  
            </exclusion>  
        </exclusions>  
    </dependency>  
</dependencies>

application.yml

server:  
  port: 9001  
spring:  
  application:  
    name: provider  
  cloud:  
    nacos:  
      config:  
        server-addr: 127.0.0.1:8848  
      discovery:  
        server-addr: 127.0.0.1:8848

啟動類上添加 @EnableDiscoveryClient 注解

@EnableDiscoveryClient
@SpringBootApplication
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }

}

然后添加測試 controller

@RefreshScope
@RestController
@RequestMapping("/test")
public class TestController {

    @Autowired
    private Environment env;

    @Value("${version:0}")
    private String version;
    /**
     * http://localhost:9001/test/port
     * @return
     */
    @GetMapping("/port")
    public Object port() {
        return String.format("port=%s, version=%s", env.getProperty("local.server.port"), version);
    }
}

注意,這里配置 nacos 的時候需要配置下面兩個文件 provider.propertiesprovider,然后實際配置最終 nacos 是采用的 provider 文件,否則后端控制臺就會持續(xù)輸出 400 錯誤,可能是新版本問題,其他版本暫時不清楚(后面網(wǎng)關(guān)配置也是同理)

Spring Cloud Gateway + Nacos 灰度發(fā)布,運維筆記,灰度發(fā)布,Gateway,Nacos,部署發(fā)布,SpringCloud,微服務(wù)

后端控制臺輸出,也可以看出需要兩個

[fixed-localhost_8848] [subscribe] provider.properties+DEFAULT_GROUP
[fixed-localhost_8848] [add-listener] ok, tenant=, dataId=provider.properties, group=DEFAULT_GROUP, cnt=1
[fixed-localhost_8848] [subscribe] provider+DEFAULT_GROUP
[fixed-localhost_8848] [add-listener] ok, tenant=, dataId=provider, group=DEFAULT_GROUP, cnt=1

Nacos 版本:2.3.0-BETA

網(wǎng)關(guān) gateway

gateway 服務(wù)的 pom 依賴配置如下:

    <dependencies>  
        <dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-starter-gateway</artifactId>  
        </dependency>  
  
        <dependency>  
            <groupId>org.projectlombok</groupId>  
            <artifactId>lombok</artifactId>  
            <optional>true</optional>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-test</artifactId>  
            <scope>test</scope>  
            <exclusions>  
                <exclusion>  
                    <groupId>org.junit.vintage</groupId>  
                    <artifactId>junit-vintage-engine</artifactId>  
                </exclusion>  
            </exclusions>  
        </dependency>  
  
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-actuator</artifactId>  
        </dependency>  
    </dependencies>  

application.yml

# 應(yīng)用服務(wù) WEB 訪問端口  
server:  
  port: 9000  
# 應(yīng)用名稱  
spring:  
  application:  
    name: gateway  
  cloud:  
    nacos:  
      config:  
        server-addr: 127.0.0.1:8848  
      discovery:  
        server-addr: 127.0.0.1:8848  
    gateway:  
      routes: # http://127.0.0.1:9000/actuator/gateway/routes  
        - id: provider  # 路由 ID,保持唯一  
          uri: lb://provider # uri指目標(biāo)服務(wù)地址,lb代表從注冊中心獲取服務(wù)  
          predicates:  
            - Path=/provider/**  # http://127.0.0.1:9000/provider/port 會轉(zhuǎn)發(fā)到 http://localhost:9001/provider/port, 和預(yù)期不符合, 需要StripPrefix來處理  
          filters:  
            - StripPrefix=1 # StripPrefix=1就代表截取路徑的個數(shù)為1, 這樣請求 http://127.0.0.1:9000/provider/test/port 會轉(zhuǎn)發(fā)到 http://localhost:9001/test/port  
management:  
  endpoint:  
    gateway:  
      enabled: true  
  endpoints:  
    web:  
      exposure:  
        include: gateway

同樣啟動類上添加 @EnableDiscoveryClient 注解

查看所有路由:/actuator/gateway/routes
查看指定路由(GET):/actuator/gateway/routes/{id}
查看全局過濾器:/actuator/gateway/globalfilters
查看路由過濾器:/actuator/gateway/routefilters
POST 方式刷新路由緩存:/actuator/gateway/refresh

測試

curl http://127.0.0.1:9001/test/port
port=9001, version=2
curl http://127.0.0.1:9000/provider/test/port
port=9001, version=2

動態(tài)路由

實現(xiàn)動態(tài)路由有兩種方式,一個是改寫?RouteDefinitionRepository(實測失?。?,一個是基于?nacos?的監(jiān)聽器給?RouteDefinitionRepository?動態(tài)更新值。實現(xiàn)邏輯大同小異

Spring Cloud Gateway 中加載路由信息分別由以下幾個類負(fù)責(zé)
1、PropertiesRouteDefinitionLocator:從配置文件中讀取路由信息 (如 YML、Properties 等)
2、RouteDefinitionRepository:從存儲器中讀取路由信息 (如內(nèi)存、配置中心、Redis、MySQL 等)
3、DiscoveryClientRouteDefinitionLocator:從注冊中心中讀取路由信息(如 Nacos、Eurka、Zookeeper 等)

下面使用 RouteDefinitionRepository 配置動態(tài)路由

gateway-router.json

[{
    "id": "provider",
    "predicates": [{
        "name": "Path",
        "args": {
            "_genkey_0": "/provider/**"
        }
    }],
    "filters": [{
        "name": "StripPrefix",
        "args": {
            "_genkey_0": "1"
        }
    }],
    "uri": "lb://provider",
    "order": 0
}]

NacosRouteDefinitionRepository 配置類

@Component  
public class NacosRouteDefinitionRepository implements RouteDefinitionRepository, ApplicationEventPublisherAware {  
  
    private static final Logger log = LoggerFactory.getLogger(NacosRouteDefinitionRepository.class);  
  
    @Autowired  
    private NacosConfigManager nacosConfigManager;  
  
    // 更新路由信息需要的  
    private ApplicationEventPublisher applicationEventPublisher;  
  
    private String dataId = "gateway-router.json";  
  
    private String group = "DEFAULT_GROUP";  
  
    @Value("${spring.cloud.nacos.config.server-addr}")  
    private String serverAddr;  
  
    private ObjectMapper objectMapper = new ObjectMapper();  
  
    @PostConstruct  
    public void dynamicRouteByNacosListener() {  
        try {  
            nacosConfigManager.getConfigService().addListener(dataId, group, new Listener() {  
  
                public void receiveConfigInfo(String configInfo) {  
                    log.info("自動更新配置...\r\n{}", configInfo);  
                    applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this));  
                }  
  
                public Executor getExecutor() {  
                    return null;  
                }  
            });  
        } catch (NacosException e) {  
            e.printStackTrace();  
        }  
    }  
  
    @Override  
    public Flux<RouteDefinition> getRouteDefinitions() {  
        try {  
            String configInfo = nacosConfigManager.getConfigService().getConfig(dataId, group, 5000);  
            List<RouteDefinition> gatewayRouteDefinitions = objectMapper.readValue(configInfo, new TypeReference<List<RouteDefinition>>() {  
            });  
            return Flux.fromIterable(gatewayRouteDefinitions);  
        } catch (NacosException e) {  
            e.printStackTrace();  
        } catch (JsonMappingException e) {  
            e.printStackTrace();  
        } catch (JsonProcessingException e) {  
            e.printStackTrace();  
        }  
        return Flux.fromIterable(Lists.newArrayList());  
    }  
  
    @Override  
    public Mono<Void> save(Mono<RouteDefinition> route) {  
        return null;  
    }  
  
    @Override  
    public Mono<Void> delete(Mono<String> routeId) {  
        return null;  
    }  
  
    @Override  
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {  
        this.applicationEventPublisher = applicationEventPublisher;  
    }  
}

然后重啟網(wǎng)關(guān),訪問 http://127.0.0.1:9000/actuator/gateway/routes ,查看是否生效

[
    {
        "predicate": "Paths: [/provider/**], match trailing slash: true",
        "route_id": "provider",
        "filters": [
            "[[StripPrefix parts = 1], order = 1]"
        ],
        "uri": "lb://provider",
        "order": 0
    }
]

灰度發(fā)布

首先需要明白灰度的場景, 因為有不同版本的服務(wù)需要共存, 所以新的節(jié)點升級的時候必然代碼及配置會存在差別, 所以我們根據(jù)這種差別來判斷服務(wù)版本是新版本還是線上穩(wěn)定版本。這里我們用?prod?和?gray?來標(biāo)識 2 個版本。

實現(xiàn)的整體思路:

  1. 編寫帶版本號的灰度路由(負(fù)載均衡策略)
  2. 編寫自定義 filter
  3. nacos 服務(wù)配置需要灰度發(fā)布的服務(wù)的元數(shù)據(jù)信息以及權(quán)重(在服務(wù) jar 中配置)

注意, 應(yīng)該先修改 nacos 配置實現(xiàn)動態(tài)路由, 然后再升級灰度節(jié)點. 本案例只是簡單示例灰度原理。

下面進(jìn)行網(wǎng)關(guān)配置

依賴配置

首先排除掉默認(rèn)的 ribbon 依賴

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

引入官方新的負(fù)載均衡包

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

負(fù)載均衡策略

public class VersionGrayLoadBalancer implements ReactorServiceInstanceLoadBalancer {

    private ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider;
    private String serviceId;
    private final AtomicInteger position;


    public VersionGrayLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider, String serviceId) {
        this(serviceInstanceListSupplierProvider, serviceId, new Random().nextInt(1000));
    }

    public VersionGrayLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider, String serviceId, int seedPosition) {
        this.serviceId = serviceId;
        this.serviceInstanceListSupplierProvider = serviceInstanceListSupplierProvider;
        this.position = new AtomicInteger(seedPosition);
    }

    @Override
    public Mono<Response<ServiceInstance>> choose(Request request) {
        HttpHeaders headers = (HttpHeaders) request.getContext();
        ServiceInstanceListSupplier supplier = this.serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new);
        return ((Flux) supplier.get()).next().map(list -> processInstanceResponse((List<ServiceInstance>) list, headers));
    }

    private Response<ServiceInstance> processInstanceResponse(List<ServiceInstance> instances, HttpHeaders headers) {
        if (instances.isEmpty()) {
            return new EmptyResponse();
        } else {
            String reqVersion = headers.getFirst("version");

            if (StringUtils.isEmpty(reqVersion)) {
                return processRibbonInstanceResponse(instances);
            }

            List<ServiceInstance> serviceInstances = instances.stream()
                    .filter(instance -> reqVersion.equals(instance.getMetadata().get("version")))
                    .collect(Collectors.toList());

            if (serviceInstances.size() > 0) {
                return processRibbonInstanceResponse(serviceInstances);
            } else {
                return processRibbonInstanceResponse(instances);
            }
        }
    }

    /**
     * 負(fù)載均衡器
     * 參考 org.springframework.cloud.loadbalancer.core.RoundRobinLoadBalancer#getInstanceResponse
     *
     * @author javadaily
     */
    private Response<ServiceInstance> processRibbonInstanceResponse(List<ServiceInstance> instances) {
        int pos = Math.abs(this.position.incrementAndGet());
        ServiceInstance instance = instances.get(pos % instances.size());
        return new DefaultResponse(instance);
    }
}

過濾器加載負(fù)載均衡

public class GrayReactiveLoadBalancerClientFilter implements GlobalFilter, Ordered {  
  
    private static final Log log = LogFactory.getLog(ReactiveLoadBalancerClientFilter.class);  
    private static final int LOAD_BALANCER_CLIENT_FILTER_ORDER = 10150;  
    private final LoadBalancerClientFactory clientFactory;  
    private LoadBalancerProperties properties;  
  
    public GrayReactiveLoadBalancerClientFilter(LoadBalancerClientFactory clientFactory, LoadBalancerProperties properties) {  
        this.clientFactory = clientFactory;  
        this.properties = properties;  
    }  
  
    @Override  
    public int getOrder() {  
        return LOAD_BALANCER_CLIENT_FILTER_ORDER;  
    }  
  
    @Override  
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {  
        URI url = exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);  
        String schemePrefix = exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR);  
        if (url != null && ("grayLb".equals(url.getScheme()) || "grayLb".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 {  
                    URI uri = exchange.getRequest().getURI();  
                    String overrideScheme = null;  
                    if (schemePrefix != null) {  
                        overrideScheme = url.getScheme();  
                    }  
  
                    DelegatingServiceInstance serviceInstance = new DelegatingServiceInstance((ServiceInstance) response.getServer(), 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);  
        }  
    }  
  
    protected URI reconstructURI(ServiceInstance serviceInstance, URI original) {  
        return LoadBalancerUriTools.reconstructURI(serviceInstance, original);  
    }  
  
    private Mono<Response<ServiceInstance>> choose(ServerWebExchange exchange) {  
        URI uri = (URI) exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);  
        VersionGrayLoadBalancer loadBalancer = new VersionGrayLoadBalancer(clientFactory.getLazyProvider(uri.getHost(), ServiceInstanceListSupplier.class), uri.getHost());  
        if (loadBalancer == null) {  
            throw new NotFoundException("No loadbalancer available for " + uri.getHost());  
        } else {  
            return loadBalancer.choose(this.createRequest(exchange));  
        }  
    }  
  
    private Request createRequest(ServerWebExchange exchange) {  
        HttpHeaders headers = exchange.getRequest().getHeaders();  
        Request<HttpHeaders> request = new DefaultRequest<>(headers);  
        return request;  
    }  
}

注入過濾器

@Configuration
public class GrayGatewayReactiveLoadBalancerClientAutoConfiguration {

    @Bean
    @ConditionalOnMissingBean({GrayReactiveLoadBalancerClientFilter.class})
    public GrayReactiveLoadBalancerClientFilter grayReactiveLoadBalancerClientFilter(LoadBalancerClientFactory clientFactory, LoadBalancerProperties properties) {
        return new GrayReactiveLoadBalancerClientFilter(clientFactory, properties);
    }
}

發(fā)布灰度服務(wù)

生產(chǎn)環(huán)境配置文件 application-prod.yml

server:  
  port: 9002  
spring:  
  application:  
    name: provider  
  cloud:  
    nacos:  
      config:  
        server-addr: 127.0.0.1:8848  
      discovery:  
        metadata:  
          version: prod  
        server-addr: 127.0.0.1:8848

灰度環(huán)境配置文件 application-gray.yml

server:  
  port: 9003  
spring:  
  application:  
    name: provider  
  cloud:  
    nacos:  
      config:  
        server-addr: 127.0.0.1:8848  
      discovery:  
        metadata:  
          version: gray  
        server-addr: 127.0.0.1:8848

idea 啟動參數(shù)指定配置文件

Spring Cloud Gateway + Nacos 灰度發(fā)布,運維筆記,灰度發(fā)布,Gateway,Nacos,部署發(fā)布,SpringCloud,微服務(wù)

同時注意配置兩個環(huán)境的 nacos 文件(prod version: 4,gray version: 5

Spring Cloud Gateway + Nacos 灰度發(fā)布,運維筆記,灰度發(fā)布,Gateway,Nacos,部署發(fā)布,SpringCloud,微服務(wù)

測試

然后分別啟動三個服務(wù):9000 端口網(wǎng)關(guān) gateway 服務(wù),9002 端口生產(chǎn)環(huán)境 provider-prod 服務(wù),9003 端口灰度環(huán)境 provider-gray 服務(wù)

E:\Nacos\nacos>curl http://127.0.0.1:9000/provider/test/port
port=9003, version=5
E:\Nacos\nacos>curl -X GET -H "version:prod" http://127.0.0.1:9000/provider/test/port
port=9003, version=5
E:\Nacos\nacos>curl -X GET -H "version:gray" http://127.0.0.1:9000/provider/test/port
port=9002, version=4

倉庫地址

如果對于文章中代碼有疑問,可以直接查看下方作者倉庫

倉庫地址:ReturnTmp/spring-gateway-demo: 網(wǎng)關(guān)配置 + 灰度發(fā)布 + 配置中心 示例倉庫 (github.com)

參考鏈接

  • Spring Cloud Gateway+nacos灰度發(fā)布 - 掘金 (juejin.cn)
  • SpringCloud gateway Actuator - shigp1 - 博客園 (cnblogs.com)
  • Spring Cloud Gateway監(jiān)控 周立的博客
  • 前端灰度發(fā)布落地方案-騰訊云開發(fā)者社區(qū)-騰訊云 (tencent.com)
  • 后端 - 灰度發(fā)布架構(gòu)設(shè)計!值得品鑒

本文由博客一文多發(fā)平臺 OpenWrite 發(fā)布!文章來源地址http://www.zghlxwxcb.cn/news/detail-777812.html

到了這里,關(guān)于Spring Cloud Gateway + Nacos 灰度發(fā)布的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!

本文來自互聯(lián)網(wǎng)用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務(wù),不擁有所有權(quán),不承擔(dān)相關(guān)法律責(zé)任。如若轉(zhuǎn)載,請注明出處: 如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實不符,請點擊違法舉報進(jìn)行投訴反饋,一經(jīng)查實,立即刪除!

領(lǐng)支付寶紅包贊助服務(wù)器費用

相關(guān)文章

  • Spring Cloud Gateway集成Nacos實現(xiàn)負(fù)載均衡

    Spring Cloud Gateway集成Nacos實現(xiàn)負(fù)載均衡

    ??Nacas可以用于實現(xiàn)Spring Cloud Gateway中網(wǎng)關(guān)動態(tài)路由功能,也可以基于Nacos來實現(xiàn)對后端服務(wù)的負(fù)載均衡,前者利用Nacos配置中心功能,后者利用Nacos服務(wù)注冊功能。 接下來我們來看下Gateway集成Nacos實現(xiàn)負(fù)載均衡的架構(gòu)圖 一. 環(huán)境準(zhǔn)備 1. 版本環(huán)境 Jdk: java.version1.8/java.version Spr

    2024年02月10日
    瀏覽(98)
  • Spring Cloud Gateway + Nacos 實現(xiàn)服務(wù)上下線無縫切換

    Spring Cloud Gateway + Nacos 實現(xiàn)服務(wù)上下線無縫切換

    大家好,我是不才陳某~ 最近知識星球的球友在學(xué)習(xí)星球中的《精盡Spring Cloud Alibaba》專欄提到一個問題,相信也有很多人在線上環(huán)境遇到過,或許也因此被批過:一個集群中有某個服務(wù)突然下線,但是網(wǎng)關(guān)還是會去請求這個實例,所以線上就報錯了,報錯信息如下圖: 究其

    2024年02月15日
    瀏覽(15)
  • Spring Cloud Gateway集成Nacos作為注冊中心和配置中心

    本篇文章將介紹Spring Cloud Alibaba體系下Spring Cloud Gateway的搭建,服務(wù)注冊中心和分布式配置中心使用Nacos,后續(xù)將會持續(xù)更新,介紹集成Sentinel,如何做日志鏈路追蹤,如何做全鏈路灰度發(fā)布設(shè)計,以及Spring Cloud Gateway的擴(kuò)展等。 ? Spring Boot,Spring Cloud,Discovery,Config等基礎(chǔ)依

    2024年02月11日
    瀏覽(510)
  • 優(yōu)化 spring cloud gateway+nacos時服務(wù)恢復(fù)調(diào)用太慢問題

    問題描述 在使用 spring cloud gateway + nacos 做服務(wù)發(fā)現(xiàn)時,會發(fā)現(xiàn)當(dāng)下游的服務(wù)器恢復(fù)了,但是還有經(jīng)過一段時間 gateway 才成功轉(zhuǎn)發(fā)請求到剛恢復(fù)的下游服務(wù)上。于是我就深入源碼進(jìn)行企圖通過修改相關(guān)配置的方式優(yōu)化gateway服務(wù)發(fā)現(xiàn)的恢復(fù)時間。 相關(guān)依賴版本 源碼 經(jīng)過漫長的

    2024年02月01日
    瀏覽(93)
  • spring cloud整合spring boot,整合nacos、gateway、open-feign等組件

    想看具體詳情的可以看我的github鏈接:codeking01/platform-parent: spring cloud整合spring boot、nacos、gateway、open feign等組件 (github.com) 由于我升級了jdk17,所以用上了spring boot 3.0.2了。 踩坑無數(shù),一堆無用文章,寫來寫去,本文主要是提供給有基礎(chǔ)的開發(fā)者再次快速搭建使用(確定版本

    2024年02月11日
    瀏覽(95)
  • Spring Cloud 2022.x版本使用gateway和nacos實現(xiàn)動態(tài)路由和負(fù)載均衡

    Spring Cloud 2022.x版本使用gateway和nacos實現(xiàn)動態(tài)路由和負(fù)載均衡

    Spring Cloud Alibaba官方:https://sca.aliyun.com/zh-cn/ Spring Cloud官網(wǎng):https://spring.io/projects/spring-cloud Spring Cloud與Spring Cloud Alibaba版本對應(yīng)說明:https://sca.aliyun.com/zh-cn/docs/2022.0.0.0/overview/version-explain 下載地址:https://github.com/alibaba/nacos/releases 下載編譯壓縮并解壓:nacos-server-2.2.3.zip。 1.1、

    2024年02月11日
    瀏覽(50)
  • Spring Cloud Day2 Nacos配置管理、Feign遠(yuǎn)程調(diào)用與Gateway服務(wù)網(wǎng)關(guān)

    Spring Cloud Day2 Nacos配置管理、Feign遠(yuǎn)程調(diào)用與Gateway服務(wù)網(wǎng)關(guān)

    Nacos除了可以做注冊中心,同樣可以做配置管理來使用。 當(dāng)微服務(wù)部署的實例越來越多,達(dá)到數(shù)十、數(shù)百時,逐個修改微服務(wù)配置就會讓人抓狂,而且很容易出錯。我們需要一種統(tǒng)一配置管理方案,可以集中管理所有實例的配置。 Nacos一方面可以將配置集中管理,另一方可以

    2024年02月10日
    瀏覽(21)
  • 【合集】Spring Cloud 組件——架構(gòu)進(jìn)化史話 & Eureka,Nacos,OpenFeign,Ribbon,Sentinel,Gateway ,Seata+事務(wù). . .

    【合集】Spring Cloud 組件——架構(gòu)進(jìn)化史話 & Eureka,Nacos,OpenFeign,Ribbon,Sentinel,Gateway ,Seata+事務(wù). . .

    Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn),斷路器,智能路由,微代理,控制總線,一次性令牌,全局鎖,領(lǐng)導(dǎo)選舉,分布式會話,集群狀態(tài))。 注意: 首先,盡管Spring Cloud帶有“Cloud”這個單詞,但它并不是云計算解

    2024年02月08日
    瀏覽(23)
  • 【合集】Spring Cloud 組件——架構(gòu)進(jìn)化史話 & Eureka,Nacos,Apollo,OpenFeign,Ribbon,Sentinel,Gateway ,Seata+事務(wù). . .

    【合集】Spring Cloud 組件——架構(gòu)進(jìn)化史話 & Eureka,Nacos,Apollo,OpenFeign,Ribbon,Sentinel,Gateway ,Seata+事務(wù). . .

    Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn),斷路器,智能路由,微代理,控制總線,一次性令牌,全局鎖,領(lǐng)導(dǎo)選舉,分布式會話,集群狀態(tài))。 注意: 首先,盡管Spring Cloud帶有“Cloud”這個單詞,但它并不是云計算解

    2024年02月03日
    瀏覽(640)
  • Spring Cloud Gateway集成聚合型Spring Boot API發(fā)布組件knife4j,增強(qiáng)Swagger

    Spring Cloud Gateway集成聚合型Spring Boot API發(fā)布組件knife4j,增強(qiáng)Swagger

    大家都知道,在前后端分離開發(fā)的時代,前后端接口對接是一項必不可少的工作。 可是, 作 為后端開發(fā),怎么和前端更好的配合,才能讓自己不心累、腦累 ,直接扔給前端一個后端開放api接口文檔或者頁面,讓前端不用看著難受,也不用前端老問你,來愉快的合作呢? 原

    2024年04月22日
    瀏覽(23)

覺得文章有用就打賞一下文章作者

支付寶掃一掃打賞

博客贊助

微信掃一掃打賞

請作者喝杯咖啡吧~博客贊助

支付寶掃一掃領(lǐng)取紅包,優(yōu)惠每天領(lǐng)

二維碼1

領(lǐng)取紅包

二維碼2

領(lǐng)紅包