1.4.1 数据同步方式

我们知道Soul数据同步可以配置为 Websocket，Http 长轮询，Zookeeper 和 Nacos 这四种方式，我们从更新Selector的接口作为切入点，根据调用链一步步分析各种数据同步方式。

1.4.1 通用处理链路

在决定使用那种方式发送前都会经过一个通用的分配流程，我们从新Selector的接口出发，SelectorController 的 updateSelector 方法会被端调用进行服务更新。这里调用了 SelectorServiceImpl服务进行更新。

image.png

这里先执行数据库操作，将对应的Selector更新，然后将旧的rule删除，然后再逐条插入新的规则，最终调用到了eventPubliser的publishEvent方法，这里使用了SpringBoot的消息发布机制，最终发布了一个DataChangedEvent类型的消息，我们接着看消息消费者 DataChangedEventDispatcher 。

image.png

image.png

我们看它主要就是查询里面所有实现了 DataChangedListener 方法的实现类，其主要实现类有如下几个。其实就是我们接下来要说的几种数据同步方式。

image.png

image.png

image.png

1.4.2 websocket Server 端更新流程

由于我们是更新selector ， 所以会调用listener 的 onSelectorChanged 方法，这里最终还是调用了WebsocketCollector 的send 方法。

源码

我们可以看出来，在Spring中使用WebSocket非常简单，我们只需要使用ServerEndpoint 这个注解定义这个是websocket处理类，OnOpen 这个注解类定义在websocket链接建立后生产对应的session然后回调这个服务，这里将session作为静态属性持有，OnMessage 接收消息处理方法，onClose 链接关闭处理方法。

image.png

image.png

在发送的时候会给所有的客户端进行发送，这里还有对自定义类型的处理。

发送

1.4.2 websocket Client 端

我们再来看看接收端，我们可以看到使用websocket同步数据，BootStrap需要使用以下依赖

        <dependency>
            <groupId>org.dromara</groupId>
            <artifactId>soul-spring-boot-starter-sync-data-websocket</artifactId>
            <version>${project.version}</version>
        </dependency>

我们找到该项目，这是一个标准的springboot-starter，这里定义个一个自动配置类。

image.png

我们来看一下配置类 WebsocketSyncDataConfiguration， 它主要是初始化了两个Bean 一个是 websocketSyncDataService 即为数据同步服务， 一个是 websocketConfig 即websocket的一些配置项。这里会将以soul.sync.websocket 开头的配置注入到这个类中，这里只有一个属性 urls。

image.png

• 如果注入实例为空时，使用ObjectProvider则避免了强依赖导致的依赖对象不存在异常；主要是 getIfAvailable 这个方法。
• 如果有多个实例，ObjectProvider的方法会根据Bean实现的Ordered接口或@Order注解指定的先后顺序获取一个Bean。从而了提供了一个更加宽松的依赖注入方式。主要通过 orderedStream 方法返回一个根据order注解的一个bean 的 stream。

    @Bean
    public SyncDataService websocketSyncDataService(final ObjectProvider<WebsocketConfig> websocketConfig, final ObjectProvider<PluginDataSubscriber> pluginSubscriber,
                                           final ObjectProvider<List<MetaDataSubscriber>> metaSubscribers, final ObjectProvider<List<AuthDataSubscriber>> authSubscribers) {
        log.info("you use websocket sync soul data.......");
        return new WebsocketSyncDataService(websocketConfig.getIfAvailable(WebsocketConfig::new), pluginSubscriber.getIfAvailable(),
                metaSubscribers.getIfAvailable(Collections::emptyList), authSubscribers.getIfAvailable(Collections::emptyList));
    }

我们根据debug数据看一下主要注入的参数，PluginDataSubscriber 这个主要是各个插件的Handler 主要负责插件内的数据更新。metaDataSubscribers 元数据订阅者，authDataSubscribers 认证数据订阅。

image.png

这里会根据websocket的配置生成一个SoulWebsocketClient 客户端，然后尝试链接服务端。

image.png

synAll

这里包括了插件数据，selector 数据和 rule 数据。

    @Override
    public boolean syncAll(final DataEventTypeEnum type) {
        appAuthService.syncData();
        List<PluginData> pluginDataList = pluginService.listAll();
        eventPublisher.publishEvent(new DataChangedEvent(ConfigGroupEnum.PLUGIN, type, pluginDataList));
        List<SelectorData> selectorDataList = selectorService.listAll();
        eventPublisher.publishEvent(new DataChangedEvent(ConfigGroupEnum.SELECTOR, type, selectorDataList));
        List<RuleData> ruleDataList = ruleService.listAll();
        eventPublisher.publishEvent(new DataChangedEvent(ConfigGroupEnum.RULE, type, ruleDataList));
        metaDataService.syncData();
        return true;
    }

我们再看看SoulWebsocketClient 做了什么，其主要是在接收到OnMessge的时候调用websocketDataHandler 进行消息处理。

image.png

websocketDataHandler 里面再注册了各种数据的处理器，如图 包括plugin selector rule app_auth meta 这几种数据的更新。

image.png

handle

我们更新selector主要是做以下操作，更新内存数据，然后通知各个插件数据更新。

image.png

1.4.4 总结

在这期的学习过程中，我学到很一些Spring的新特性如 ObjectProvider，还知道了在SpringBoot中如何写一个WebSocket的客户端。