配置发布、服务注册发现框架:Nacos

2018-12-05  本文已影响0人  空山雪林

概述

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

启动与关闭

sh startup.sh -m standalone

sh shutdown.sh

cmd startup.cmd

cmd shutdown.cmd

服务注册,发现与配置管理

  1. 服务注册:

curl -X PUT 'http://127.0.0.1:8848/nacos/v1/ns/instance?serviceName=nacos.naming.serviceName&ip=20.18.7.10&port=8080'

  1. 服务发现:curl -X GET 'http://127.0.0.1:8848/nacos/v1/ns/instances?serviceName=nacos.naming.serviceName'

  2. 发布配置:curl -X POST "http://127.0.0.1:8848/nacos/v1/cs/configs?dataId=nacos.cfg.dataId&group=test&content=HelloWorld"

  3. 获取配置: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,你就可以编写高可靠性的后台服务了。

上一篇下一篇

猜你喜欢

热点阅读