天天看点

SOUL网关的数据同步模式-websocket

1、介绍

         soul网关选用websocket的方式进行同步,websocket的通讯是双向全双工的,在soul网关当中,当souladmin的配置数据进行更新时,会将数据推送至网关服务器中,并由网关服务器进行缓存。

2、同步步骤

  服务器连接开启:

souladmin启动项目,由于引入了javax.websocket包,使用@ServerEndpoint注解建立了一个服务端点。

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

客户机开启,即soul-bootstrap项目

在该项目中,初始化了bean:WebsocketSyncDataService

SOUL网关的数据同步模式-websocket

于此之后,客户端开启一个定时的调度线程池,10秒钟执行次,如果连接关闭,则重新连接,否则发送ping命令查看是否连接正常。

SOUL网关的数据同步模式-websocket

客户端与服务端成功建立连接后,客户端发送一个MYSELF的消息,服务端收到后,会进行数据同步

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

同步所有数据,使用ThreadLocal记录该连接对象,在后续同步时,直接将数据发送至该连接。

type匹配,当前连接通过线程取ThreadLocal中的session值,进行发送

SOUL网关的数据同步模式-websocket

客户端接收到消息,并进行缓存,这整个过程,会将souladmin所有配置pull下来,存储到客户机的内存当中

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

以上过程便是客户机启动后,从Souladmin拉取配置的过程

建立好连接,先在souladmin界面中,修改一下选择器的配置。请求会进入到SelectorController中

SOUL网关的数据同步模式-websocket

进入到了实现类当中

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

其中关键方法为publishEvent(),发布了一个消息,那么,可以在消息监听器中查看,订阅后进行了什么操作。

 DataChangedEventDispatcher订阅数据更新操作

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

该类实现了InitializingBean接口,注入了applicationContext,并将改变的数据按照类别,分发到对应的监听器执行器当中。执行器配置在DataSyncConfiguration当中,此配置即采用的数据同步配置,在yml中配置。此处我们选择的是websocket,那么,请求进入WebsocketDataChangedListener 当中。

在WebsocketDataChangedListener当中,可以看到,它将数据封装成了websoke数据格式,包含数据改变类型、数据类型等

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

进入发送方法, 明显这里的type是前面传过来的,不是MYSELF,会将消息发送给所有的websocket客户端,由客户端进行缓存。

SOUL网关的数据同步模式-websocket
SOUL网关的数据同步模式-websocket

以上便是服务端推送配置到客户机的过程