ShardingSphere的注册中心

本篇文章源码基于4.0.1版本

注册中心在ShardingSphere的作用就是用来管理各种数据源，在使用的时候，所有数据源通过向注册中心的指定目录下创建节点，所有使用这些数据源的服务监听这个目录，当有新的数据源加入的时候会通知这些服务，当数据源宕机的时候，也会收到通知，ShardingSphere支持的注册中心有Zookeeper、Etcd等等

入口

在进行加载数据源的时候构造OrchestrationShardingDataSource对象，它的构造方法会创建分片编排门面类ShardingOrchestrationFacade，这个类一看名字就知道了这里使用了门面模式。它的成员变量有注册中心、配置服务、状态服务和监听管理器。

状态服务保存的是数据实例和数据源节点信息。

监听管理器ShardingOrchestrationListenerManager又分为配置变更监听管理器和状态变更监听管理器，初始化的过程是通过注册中心的watch()方法来发布相应的事件，被@Subscribe注解修饰的方法来处理相应的事件。

注册中心的加载是通过RegistryCenterServiceLoader的load()方法来进行加载，这里就使用了JDK的SPI机制来进行加载响应的注册中心

sharding-orchestration-reg模块是ShardingSphere注册中心的源码内容，它 的子模块有sharding-orchestration-reg-api、sharding-orchestration-reg-zookeeper-curator、sharding-orchestration-reg-nacos，分别是注册api提供的一些接口，Zookeeper注册中心的集成和nacos注册中心的集成，下面就分别看一下这三个模块

注册中心API

这一块的代码内容和我们上篇文章说的配置中心API模块的内容差不多，同样有监听类DataChangedEventListener、监听事件类DataChangedEvent、异常RegistryCenterException，注册中心配置类RegistryCenterConfiguration和注册中心接口RegistryCenter

它的实现类同样有两个，Zookeeper注册中心实现类CuratorZookeeperRegistryCenter和nacos注册中心实现类NacosRegistryCenter

Zookeeper模块

当看完配置中心模块的代码，再看注册中心模块的代码就很好理解了

使用Zookeeper配置中心

在使用上同样是加载CuratorZookeeperRegistryCenter实例，然后启动Zookeeper服务器，创建注册中心配置类，设置服务列表，调用CuratorZookeeperRegistryCenter的init()方法进行初始化，整体逻辑和配置中心十分相似，这里就不详细说了。

Nacos模块

使用Nacos注册中心

先进行初始化操作：

    public static void init() {
        Properties properties = new Properties();
        properties.setProperty("group", "SHARDING_SPHERE_DEFAULT_GROUP");
        properties.setProperty("timeout", "3000");
        RegistryCenterConfiguration configuration = new RegistryCenterConfiguration(nacosRegistryCenter.getType(), properties);
        configuration.setServerLists("127.0.0.1:8848");
        nacosRegistryCenter.init(configuration);
    }

调用了NacosRegistryCenter的init()方法：

    public void init(final RegistryCenterConfiguration config) {
        try {
            Properties properties = new Properties();
            properties.put("serverAddr", config.getServerLists());
            properties.put("namespace", null == config.getNamespace() ? "" : config.getNamespace());
            configService = NacosFactory.createConfigService(properties);
        } catch (final NacosException ex) {
            log.debug("exception for: {}", ex.toString());
        }
    }

设置服务地址和命名空间，利用Nacos工厂类NacosFactory来创建服务

增删改查

在获取数据的时候根据dataId、组名获取响应的数据：

configService.getConfig(dataId, group, timeoutMs);

在进行持久化操作的时候直接调用了更新方法，根据dataId，组名来设置相应的值更新配置：

configService.publishConfig(dataId, group, value);

总结

这篇文章我们将了ShardingSphere的注册中心，注册中心支持Nacos和Zookeeper，整体逻辑和配置中心的逻辑差不多，在注册中心加载的时候使用了JDK的SPI机制灵活加载注册中心，变更事件是通过 EventBus 来实现的。