配置发布、服务注册发现框架:Nacos
概述
Nacos
是一个更易于构建云原生应用的动态服务发现、配置管理和服务的管理平台。
Nacos
帮助您更敏捷和容易地构建、交付和管理微服务平台。 Nacos 是构建以“服务”为中心的现代应用架构 (例如微服务范式、云原生范式) 的服务基础设施。
Nacos
的关键特性包括:
-
服务发现和服务健康监测
-
动态配置服务
-
动态配置服务
安装
源码安装
git clone https://github.com/alibaba/nacos.git
cd nacos/
mvn -Prelease-nacos clean install -U
ls -al distribution/target/
// change the $version to your actual path
cd distribution/target/nacos-server-$version/nacos/bin
压缩包安装
unzip nacos-server-$version.zip 或者 tar -xvf nacos-server-$version.tar.gz
cd nacos/bin
启动与关闭
- Linux/Unix/Mac:启动命令(standalone代表着单机模式运行,非集群模式):
sh startup.sh -m standalone
sh shutdown.sh
- Windows
cmd startup.cmd
cmd shutdown.cmd
服务注册,发现与配置管理
- 服务注册:
curl -X PUT 'http://127.0.0.1:8848/nacos/v1/ns/instance?serviceName=nacos.naming.serviceName&ip=20.18.7.10&port=8080'
-
服务发现:
curl -X GET 'http://127.0.0.1:8848/nacos/v1/ns/instances?serviceName=nacos.naming.serviceName'
-
发布配置:
curl -X POST "http://127.0.0.1:8848/nacos/v1/cs/configs?dataId=nacos.cfg.dataId&group=test&content=HelloWorld"
-
获取配置:
curl -X GET "http://127.0.0.1:8848/nacos/v1/cs/configs?dataId=nacos.cfg.dataId&group=test"
nacos的编程使用
配置的读取与发布
编写应用程序配置文件的管理是一项繁杂的任务,如qa,dev,prod3个环境的数据库配置各有不同,上线时一不留神,极易容易搞错,那势必造成上线失败,另一方面,但配置修改时,你还得重启服务,借助nacos
这一切将变得更加简单,以下代码用来发布配置和读取配置,代码如下:
@RequestMapping(value = "/config/get",method=RequestMethod.GET)
@ResponseBody
public String get(@RequestParam("dataId") String dataId,@RequestParam(name="group",defaultValue="DEFAULT_GROUP") String group) {
try {
Properties properties = new Properties();
properties.put("serverAddr", nacos);
ConfigService configService = NacosFactory.createConfigService(properties);
String content = configService.getConfig(dataId, group, 5000);
return content;
} catch (NacosException e) {
e.printStackTrace();
}
return "";
}
@RequestMapping(value = "/config/save",method=RequestMethod.GET)
@ResponseBody
public boolean save(@RequestParam("dataId") String dataId,@RequestParam(name="group",defaultValue="DEFAULT_GROUP") String group,@RequestParam("content") String content) {
try {
Properties properties = new Properties();
properties.put("serverAddr", nacos);
ConfigService configService = NacosFactory.createConfigService(properties);
boolean res = configService.publishConfig(dataId, group, content);
configService.addListener(dataId, group, new Listener() {
@Override
public void receiveConfigInfo(String configInfo) {
System.out.println("receiveConfigInfo:"+configInfo);
}
@Override
public Executor getExecutor() {
return null;
}
});
return res;
} catch (NacosException e) {
e.printStackTrace();
}
return false;
}
在listener里,但配置项发生变更时,会实时通知到您的应用。
服务的注册、发现
在我们开发系统中,经常会碰到服务的冗余部署,以便在某些服务器出现故障时,不影响最终服务的运行。比如聊天系统里的消息投递服务,各种微服务等,nacos通过API帮助您快速定位一个健康的服务以供您使用,通过如下代码:
Instance selectOneHealthyInstance(String serviceName) throws NacosException;
你可以注册一个服务到nacos
里,nacos
自动帮您检测服务的健康状态,注册服务代码如下:
NamingService namingService = NamingFactory.createNamingService("IP:8848");
//日志中心服务注册,非集群模式
Instance instance = new Instance();
instance.setIp("192.168.1.154");
instance.setPort(23105);
instance.setHealthy(true);
instance.setWeight(2.0);
Map<String, String> instanceMeta = new HashMap<>();
instanceMeta.put("site", "et2");
instance.setMetadata(instanceMeta);
namingService.registerInstance(serviceName, instance);
在控制台你可以看到当前服务的健康状态(准实时检测):
image通过nacos
的客户端API,你就可以编写高可靠性的后台服务了。