系列文章目錄
第一章 Java線程池技術(shù)應(yīng)用
第二章 CountDownLatch和Semaphone的應(yīng)用
第三章 Spring Cloud 簡介
第四章 Spring Cloud Netflix 之 Eureka
第五章 Spring Cloud Netflix 之 Ribbon
第六章 Spring Cloud 之 OpenFeign
第七章 Spring Cloud 之 GateWay
第八章 Spring Cloud Netflix 之 Hystrix
第九章 代碼管理gitlab 使用
第十章 SpringCloud Alibaba 之 Nacos discovery
第十一章 SpringCloud Alibaba 之 Nacos Config
前言
Nacos 提供用于存儲(chǔ)配置和其他元數(shù)據(jù)的 key/value 存儲(chǔ)，為分布式系統(tǒng)中的外部化配置提供服務(wù)器端和客戶端支持。使用 Spring Cloud Alibaba Nacos Config，您可以在 Nacos Server 集中管理你 Spring Cloud 應(yīng)用的外部屬性配置。
Spring Cloud Alibaba Nacos Config 是 Config Server 和 Client 的替代方案，客戶端和服務(wù)器上的概念與 Spring Environment 和 PropertySource 有著一致的抽象，在特殊的 bootstrap 階段，配置被加載到 Spring 環(huán)境中。當(dāng)應(yīng)用程序通過部署管道從開發(fā)到測試再到生產(chǎn)時(shí)，您可以管理這些環(huán)境之間的配置，并確保應(yīng)用程序具有遷移時(shí)需要運(yùn)行的所有內(nèi)容。
1、Nacos配置中心配置信息
準(zhǔn)備配置，nacos server中新建nacos-config.properties
2、項(xiàng)目里配置
2.1、添加依賴，配置pom.xml
<dependen?cy>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
<version>2021.0.4.0</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
2.2、添加bootstrap.yml
spring:
profiles:
#開發(fā)環(huán)境dev，測試環(huán)境test，生產(chǎn)環(huán)境prod
active: dev
application:
name: app-api-service #服務(wù)名
cloud:
nacos:
config:
server-addr: 127.0.0.1:8848
group: DEFAULT_GROUP
file-extension: yml #指定yaml格式的配置
refresh-enabled: true
2.3、添加bootstrap.yml
server:
port: 80
spring:
cloud:
nacos:
discovery:
server-addr: localhost:8848 #Nacos server 的地址
feign:
client:
config:
default:
#建立連接所用的時(shí)間，適用于網(wǎng)絡(luò)狀況正常的情況下，兩端連接所需要的時(shí)間
ConnectTimeOut: 3000
#指建立連接后從服務(wù)端讀取到可用資源所用的時(shí)間
ReadTimeOut: 5000
kelvin:
address: cat
2.3.1、增加Nacos配置
備注：Data ID為：服務(wù)名-環(huán)境名稱.yml
文章來源：http://www.zghlxwxcb.cn/news/detail-717761.html
2.4、動(dòng)態(tài)刷新配置驗(yàn)證
@RestController
@RequestMapping("/user")
//@DefaultProperties(defaultFallback = "userInfoListFallBack")
@RefreshScope
public class UserController {
@Value("${kelvin.address}")
private String url;
@GetMapping("/url")
public String url(){
return url;
}
}
2.5、網(wǎng)關(guān)與配置中心
2.5.1、添加依賴，配置pom.xml
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
<version>2021.0.4.0</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
2.5.2、添加bootstrap.yml文件
server:
port: 80
spring:
application:
name: drp-gateway-service
profiles:
#開發(fā)環(huán)境dev，測試環(huán)境test，生產(chǎn)環(huán)境prod
active: dev
jackson:
time-zone: GMT+8
cloud:
loadbalancer:
ribbon:
enabled: false
nacos:
discovery:
server-addr: localhost:8848 #Nacos server 的地址
config:
server-addr: localhost:8848
name: gateway-router
namespace: public
group: DEFAULT_GROUP
#file-extension: json #指定yaml格式的配置
refresh-enabled: true #支持刷新
2.5.3、Nacos添加配置
文章來源地址http://www.zghlxwxcb.cn/news/detail-717761.html
[{
"id": "user-router",
"order": 0,
"predicates": [{
"args": {
"pattern": "/user/userInfoList/**"
},
"name": "Path"
}],
"uri": "lb://user-service"
}
]
2.5.4、添加類
package com.kelvin.drp.gateway.config;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionWriter;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;
import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executor;
@RefreshScope
@Component
@Slf4j
public class DynamicRouteConfig implements ApplicationEventPublisherAware {
/**
* nacos 配置dataId
*/
@Value("${config.dynamic.route.dataId:gateway-router}")
private String dataId = "gateway-router";
/**
* nacos 配置group
*/
@Value("${config.dynamic.route.group:DEFAULT_GROUP}")
private String group = "DEFAULT_GROUP";
/**
* nacos 配置地址
*/
@Value("${spring.cloud.nacos.config.server-addr}")
private String serverAddr;
@Autowired
private RouteDefinitionWriter routeDefinitionWriter;
private ApplicationEventPublisher applicationEventPublisher;
private static final List<String> ROUTE_LIST = new ArrayList<>();
@PostConstruct
public void dynamicRouteByNacosListener() {
try {
ConfigService configService = NacosFactory.createConfigService(serverAddr);
// 程序首次啟動(dòng), 并加載初始化路由配置
String initConfigInfo = configService.getConfig(dataId, group, 5000);
this.addAndPublishBatchRoute(initConfigInfo);
//添加監(jiān)聽路由變化
configService.addListener(dataId, group, new Listener() {
@Override
public void receiveConfigInfo(String configInfo) {
clearRoute();
try {
List<RouteDefinition> gatewayRouteDefinitions = JSONObject.parseArray(configInfo, RouteDefinition.class);
for (RouteDefinition routeDefinition : gatewayRouteDefinitions) {
addRoute(routeDefinition);
}
publish();
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public Executor getExecutor() {
return null;
}
});
} catch (NacosException e) {
e.printStackTrace();
}
}
private void publish() {
this.applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this.routeDefinitionWriter));
}
@Override
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
this.applicationEventPublisher = applicationEventPublisher;
}
/**
* 批量 添加及發(fā)布 路由
*
* @param configInfo 配置文件字符串, 必須為json array格式
*/
private void addAndPublishBatchRoute(String configInfo) {
try {
clearRoute();
List<RouteDefinition> gatewayRouteDefinitions = JSONObject.parseArray(configInfo, RouteDefinition.class);
for (RouteDefinition routeDefinition : gatewayRouteDefinitions) {
addRoute(routeDefinition);
}
publish();
log.info("Dynamic config gateway route finished. {}", JSON.toJSONString(gatewayRouteDefinitions));
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 清除路由信息
*/
private void clearRoute() {
for (String id: ROUTE_LIST) {
this.routeDefinitionWriter.delete(Mono.just(id)).subscribe();
}
ROUTE_LIST.clear();
}
/**
* 添加路由
*
* @param definition
*/
private void addRoute(RouteDefinition definition) {
try {
routeDefinitionWriter.save(Mono.just(definition)).subscribe();
ROUTE_LIST.add(definition.getId());
} catch (Exception e) {
e.printStackTrace();
}
}
}
到了這里，關(guān)于Spring Cloud Alibaba nacos配置中心的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
