【推荐】开源动态配置ares服务让业务飞起来，”赶超nacos、apollo，从此不再依靠 spring cloud config“

What is ARES?

Open source dynamic configuration center with easy deployment and high stability

Ares系统是基于Java语言开发的，部署简单且高稳定性的动态配置系统.

让您可以集中化、动态化管理自己应用中的配置.

允许您的应用以监听和拉取结合的方式快速变更运行时的应用配置

具有丰富的配置管理UI简化操作，同时也保障数据的隔离性与灵活性

About

Ares系统目前在橙鹰公司内部使用，并稳定的提供服务：

• 长时间稳定运行：自上线以来已经稳定运行长达吗1年 以上

• 支持多条业务线：公司内 *3条* 环境隔离的业务线同时使用 1套 Ares动态配置

• 接入众多服务：一共支持了 *23个* 先上服务，包括 600多条 配置信息

• 支持多个环境：同时支撑开发、测试、预发、线上 *4套* 环境

• 完成大量配置推送：自上线以来总共进行过接近 *2000次* 配置修改

 

项目地址：https://github.com/ChengYingOpenSource/ares

开源不易，我们会持续维护和优化，惊喜不断请大家点赞收藏！

为迎接2021，经过内部使用多年，正式开源并发布正式版本，欢迎大家使用和共同参与开发和维护。

 

• 欢迎大家钉钉扫码加入 

常见配置服务比较

 

功能点	Spring Cloud Config	Apollo	Nacos	Ares
分布式部署	部署复杂	部署复杂	部署简单	部署简单
配置格式校验	不支持	支持	支持	支持
通信协议	HTTP和AMQP	HTTP	HTTP	TCP
数据一致性	Git保证数据一致性，从Git读数据	数据库模拟消息队列，Apollo定时读消息	HTTP异步通知	Ack+心跳时间戳
注册中心	不支持	不支持	支持AP和CP模型	后续支持
权限管理	不支持	支持	不支持	可优化
易用性	无界面易用性差	有界面支持，使用复杂	简单	简单

 

Features

高效的动态配置

• 多环境、多层次的配置管理，支持复杂的业务场景和网络环境

• 支持websocket模式，方便非Java语言的接入

• 客户端自适应的负载均衡，避免服务端抖动带来的配置丢失

• 基于TCP的长连接，监听模式让配置生效更实时

可扩展的集群服务

• 分布式部署的服务端，远程协调，构成一个集群

• 去中心化的集群服务，每个服务端对外服务都是一致的

• 服务器集群化过程不依赖其它中间件

• 允许运行时对服务端集群进行扩容

• 服务端与管理端统一部署，不需要额外部署SLB

---

Overall architecture

 

 

 

Performance and restrictions（性能测试）

测试环境：

1 server / 50 clients

server specification: 2c4g, JVM -Xmx512m

CilentsNumber	StartPushingTime	LastReceivedTime	ElapsedTime	Failure
10	10:34:15.400	10:34:15.482	82ms	0
20	10:39:51.080	10:39:51.183	103ms	0
50	10:58:32.301	10:58:32.490	190ms	0

Modules

• ares-biz : 核心逻辑模块，包括主要的配置管理和推送流程

• ares-client : 客户端SDK模块，负责实现与服务器集群的通讯和配置的更新

• ares-client-spring : 基于Spring框架实现的可快速接入SDK

• ares-cluster : 基于Akka框架实现的，去中心化的集群模块

• ares-common : 常用的工具类集合和主要的基础数据模型

• ares-dao : 数据库访问层

• ares-deploy : 构建和部署程序，保护配置文件

• ares-model : 数据模型集合

• ares-webapi : 接口逻辑模块

部署文档

 https://github.com/ChengYingOpenSource/ares/blob/master/doc/UserGuide/Deployment.md

接口文档

https://github.com/ChengYingOpenSource/ares/blob/master/ares-doc/api-doc.md

 Ares中的发布订阅机制

 https://github.com/ChengYingOpenSource/ares/blob/master/doc/DesignAndPattern/Architecture.md

配置同步机制

https://github.com/ChengYingOpenSource/ares/blob/master/doc/DesignAndPattern/Flow.md

服务端核心流程

 

• NettyServer: 通过netty创建server, 接受客户端的channel链接和数据接受发送;

• Coordinator: 当NettyServer接受到请求时，通过coordinator进行处理, 同时coordinator订阅eventbus的事件 ; 当server端配置变更时，需要主动推送数据，会通过eventbus 传递给coordinator;

• ConfManager: 配置管理的核心类，响应配置的查找、变更;

• ServerCluster: 集群服务管理入口的类; 提供配置变更在集群内的publish;

• ClusterNotify：集群内消息通知的类， 底层实现可以是AkkaCluster，也可以是自定义其它方式;

• AkkaCluster: 通过akka 实现集群管理和消息的publish;

• Cache: 用于配置的缓存, 加快配置的查找和读取;

缓存设计 &数据一致性

https://github.com/ChengYingOpenSource/ares/blob/master/doc/DesignAndPattern/Server.md

 

配置管理的五大核心概念

应用: 实际使用配置的应用, 每个应用都需要有唯一的身份标识 —— appCode
环境: 配置对应的环境 , 环境和代码无关，同一份代码部署在不同的环境就应该能够获取到不同环境的配置。
集群: 一个应用下不同实例的分组 ; 对不同的cluster，同一个配置可以有不一样的值，如zookeeper地址
配置组: 一个应用下不同配置的分组, 如数据库配置文件，RPC配置文件，应用自身的配置文件等
配置项: KV配置对的内容; key使用dataId进行表示; Value即配置的Content

关系如下图所示

 

配置管理操作

命名空间

命名空间（namespace）的主要作用是为了更清楚的将不同业务线的应用做划分，方便我们管理不同业务线的各个应用。命名空间页面主要提供对命名空间的管理功能，包括：新建命名空间，删除命名空间，命名空间列表。 如下图所示： 

新建命名空间

新建命名空间需要填写：命名空间编码，命名空间名称，描述三个字段。具体如下图所示。 

环境空间

环境空间的主要作用是划分应用不同的部署环境，应用与环境是一对多的关系，即同一个应用在不同环境下，可以有不同的配置。目前定义了：开发，测试，预发，生产四个环境。 具体界面如下所示： 

应用配置

应用配置主页面主要是对已有应用的展示，并提供了新建应用，删除应用，应用搜索功能。 

应用配置页面

点击应用配置主页面中的应用名称，会进入应用配置页面，我们对应用配置的设置都会在这里完成。新增一个应用配置主要有以下几个步骤。
1、首先检查左侧菜单栏中，该应用是否已经绑定环境。如果没有绑定环境，则通过“绑定环境”按钮来绑定环境，如果已经绑定环境，则选择要新增配置的环境。
2、选择要新增配置的分组，默认为default分组，如果对分组有需要，可以通过“新增分组”来完成分组的创建
3、选择好分组之后，我们就可以创建新的应用配置了。ares中对于value提供了丰富的类型，能够满足我们开发过程中的不同需求，主要有：TEXT JSON，XML，YAML，HTML，Properties。
4、保存完配置之后，可以通过配置列表中右侧“push轨迹”查看已经接收配置的应用实例，描述或配置内容的改变都会触发push操作。 

应用接入教程

 https://github.com/ChengYingOpenSource/ares/blob/master/doc/UserGuide/QuickStart.md

本案例基于spring boot 2.X

关键操作步骤

1. 搭建spring boot 2.X项目，引入关键依赖

 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.1.1.RELEASE</version>
</dependency>

2. 添加 spring ares client，具体版本以最新为主

 <dependency><groupId>com.cy.ares</groupId><artifactId>ares-client-spring</artifactId><version>${ares-client-spring.version}</version>
</dependency>

3. 根据实际需要，添加其它依赖包

4. 主程序配置，添加自动扫描 ares client包，注入bean

@SpringBootConfiguration
@EnableAutoConfiguration
@ComponentScan(basePackages = "com.cy.ares")

5. 添加关键配置，具体配置根据实际环境配置

#应用端口
server.port=30000
#应用名
spring.application.name=ares_demo
#动态配置应用名
ares.config.appCode=test
#动态配置环境编码
ares.config.envCode=cy-platform-dev
#动态配置项目空间名
ares.config.namespaceCode=fd_saas
#动态配置服务节点ip：port 多个逗号分隔
ares.config.serverAddr=192.168.101.32:30333

对应关键配置作用 

6. 添加动态配置管理类,加载动态配置核心bean SpcpContext;详细可参照本项目AresConfig类

@Component
public class AresConfig {private static final Logger LOGGER = LoggerFactory.getLogger(AresConfig.class);
private static final String TEST_PUSH_ACTION_CFG_KEY = "test.push.cfg.key";private static final String TEST_GET_ACTION_CFG_KEY = "test.get.action.cfg.key";@Resourceprivate SpcpContext spcpContext;
}

支持两种方式，一种是配置变更监听器通知更新，一种是主动获取最新配置。

方式1：配置变更监听器通知更新

 /*** 测试配置*/@Getterprivate List<String> testPushActionCfg = Collections.emptyList();@PostConstructpublic void init() {ConfigFetchActor fetchActor = spcpContext.getConfFetchActor();try {fetchActor.addListener(TEST_PUSH_ACTION_CFG_KEY, this::setTestPushActionCfg);setTestPushActionCfg(spcpContext.getConfFetchActor().getConfig(TEST_PUSH_ACTION_CFG_KEY));} catch (Exception e) {LOGGER.error("AresConfig fetchActor riskFilterTenantCodes config fail. e:{}", e);}}/*** 更新本地配置** @param dataItem*/private void setTestPushActionCfg(DataItem dataItem) {String value = dataItem != null ? dataItem.getContent() : null;// 配置变更打印LOGGER.warn("setSpecialTenantCodesConfig value={}", value);if (org.apache.commons.lang3.StringUtils.isBlank(value)) {testPushActionCfg = Collections.emptyList();} else {try {testPushActionCfg = JSONObject.parseObject(value, new TypeReference<List<String>>() {});} catch (Exception e) {LOGGER.error("parse fail e:{}", e);testPushActionCfg = Collections.emptyList();}}}

方式2：主动获取最新配置

/*** 根据key查询value** @param key 配置key* @return 配置value*/private String getValue(String key) {try {ConfigFetchActor fetchActor = spcpContext.getConfFetchActor();DataItem dataItem = fetchActor.getConfig(key);if (dataItem == null) {return null;}return dataItem.getContent();} catch (Exception e) {LOGGER.error("get ares config exception!key:" + key, e);}return null;}/*** 根据key查询value** @param key        配置key* @param defaultVal 默认值* @return 配置value*/public String getValue(String key, String defaultVal) {try {String configValue = getValue(key);if (StringUtils.isBlank(configValue)) {return defaultVal;}return configValue;} catch (Exception e) {LOGGER.warn("get ares config key:{} fail! defaultVal:{}", key, defaultVal);return defaultVal;}}public int getTestConfig() {// 默认值30String val = getValue(TEST_GET_ACTION_CFG_KEY, String.valueOf(30));int days = Integer.valueOf(val);return days;}

8. 在动态配置管理界面添加对应项目空间（namespace）环境（envCode）应用（appCode）对应配置项

如不需要经常修改可使用默认值，可不需要在管理界面上添加配置项。

9. 添加配置获取使用，本样例定时打印

@Slf4j
@Component
@AutoConfigureAfter(AresConfig.class)
public class ConfigPrintTask {@Resourceprivate AresConfig aresConfig;@Scheduled(cron = "*/5 * * * * *")public void configShow() {log.info("TEST_GET_ACTION_CFG_KEY value:{}", aresConfig.getTestConfig());log.info("=============================");log.info("TEST_PUSH_ACTION_CFG_KEY value:{}", aresConfig.getTestPushActionCfg());log.info("=============================");}
}

10. 启动项目可以看到ares启动关键信息

客户端配置加载启动，关键信息

2020-10-13 20:26:19.857 [INFO ] [main] com.cy.ares.spcp.context.SpcpContext - [Ares2Client] addShutdownHook success.
2020-10-13 20:26:20.288 [INFO ] [main] c.c.a.spcp.client.network.netty.NettyPoolManager - newClient created!,currentNode={"host":"192.168.101.32","port":30333}
2020-10-13 20:26:21.635 [INFO ] [nioEventLoopGroup-2-2] c.c.a.spcp.client.network.netty.LogicClientHandler - channel Active!ctx=LogicClientHandler#0
2020-10-13 20:26:21.639 [INFO ] [main] c.c.a.spcp.client.network.netty.NettyPoolManager - check channel ,active=true
2020-10-13 20:26:21.642 [INFO ] [main] c.c.a.spcp.client.network.netty.NettyPoolManager - newClient success!
2020-10-13 20:26:21.644 [INFO ] [main] c.c.a.spcp.client.network.netty.NettyPoolManager - check channel ,active=true
2020-10-13 20:26:21.646 [INFO ] [main] c.c.a.spcp.client.network.netty.NettyPoolManager - checkClient =true!

客户端注册监听器，并获取配置初始化，关键信息

2020-10-13 20:26:21.818 [INFO ] [main] c.cy.ares.spcp.actor.register.ServiceRegisteActor - registe success result={"count":0,"eventId":"ca64639d-e4d4-4866-b025-95e0dca5ea29","header":{},"name":"resp:service:registe"}
2020-10-13 20:26:21.890 [WARN ] [main] com.cy.ares.spcp.actor.fetcher.ConfigFetchActor - fetch data item is empty!
2020-10-13 20:26:21.899 [INFO ] [main] com.cy.ares.client.spring.SpringAresContextCreater - create spcpContext,config={"confNodes":[{"host":"192.168.101.32","port":30333}],"connectTimeout":3000,"heartbeatInterval":3000,"heartbeatMaxFailedCount":3,"heartbeatRespTimeout":3000,"initReadTimeout":10000,"maxChannel":2,"maxPoolTry":3,"readTimeout":5000,"respExecuteMaxThread":16,"serverAddr":"192.168.101.32:30333"},instanceInfo={"appCode":"test","clusterCode":"default","envCode":"cy-platform-dev","hostName":"CYSJ-GDDN-0157.hz.ali.com","instanceId":"30.14.204.136;CYSJ-GDDN-0157.hz.ali.com;90185;91979769","ipAddr":"30.14.204.136","namespaceCode":"fd_saas","serverPort":0}
2020-10-13 20:26:21.931 [WARN ] [main] com.cy.ares.spcp.actor.fetcher.ConfigFetchActor - fetch data item is empty!dataId=test.push.cfg.key,group=default

客户端配置主动获取，关键信息

2020-10-13 20:26:25.025 [WARN ] [scheduling-1] com.cy.ares.spcp.actor.fetcher.ConfigFetchActor - fetch data item is empty!dataId=test.get.action.cfg.key,group=default
2020-10-13 20:26:25.032 [INFO ] [scheduling-1] com.cy.ares.demo.task.ConfigPrintTask - TEST_GET_ACTION_CFG_KEY value:30
2020-10-13 20:26:25.033 [INFO ] [scheduling-1] com.cy.ares.demo.task.ConfigPrintTask - =============================
2020-10-13 20:26:25.033 [INFO ] [scheduling-1] com.cy.ares.demo.task.ConfigPrintTask - TEST_PUSH_ACTION_CFG_KEY value:[]
2020-10-13 20:26:25.033 [INFO ] [scheduling-1] com.cy.ares.demo.task.ConfigPrintTask - =============================

11. 管理界面配置变更，监听器会主动打印配置变更信息，并更新。

12.打包操作

mvn clean package -Dmaven.test.skip=true

13. 打包完后在项目target目录下找到jar包，执行启动操作

默认端口 30000 启动操作

 java -jar ares-demo.jar

Planning

• 灰度发布：允许按照流量标识或者机器IP等标识生效配置，来让配置生效过程更加平稳

• 平滑扩容：新的机器加入集群后，客户端可以快速感知和负载均衡

• 支持spring注解：支持动态修改spring注解的配置项

• 多语言支持：后续将有更多语言的SDK以websocket或者TCP的方式接入Ares

• 云原生的部署：优化集群建立方式，支持如K8S环境下的部署

• 可扩展的管理端权限：使用方可以将自己的权限体系接入管理端