Soul网关websocket同步数据

港控/mmm° 2022-11-19 09:53 188阅读 0赞

# websocket同步数据 #

## 初始化属性部分 ##

首先启动soul-admin项目，然后启动soul-boostrap项目，可以明显发现websocket连接成功 ![file][] 奇怪的是，使用昨天测试SpringCloud的数据库发现webosocket无法连接成功。后续可以继续尝试下这种问题发生的原因

分析pom文件的依赖可知。由于soul-boostrap是springboot项目，所以websocket相关的配置是从soul-spring-boot-starter-sync-data-websocket加载 ![file][file 1] 这个例子中涉及到starter相关的知识不做解读了。在这个configration中通过注入bean注入了websocket的配置以及几个空的订阅器包括插件订阅器pluginSubscriber，元数据订阅器metaSubscribers和认证订阅器authSubscribers用来监听admin项目的数据的改变。 此处的websocketConfig属性由配置文件注入。其他属性特别是pluginSubscriber数据的ObjectProvider是Spring4.3之后的一个新特性。简单来说就是可以代替@Autowired的作用。具体的示例，可以参考[https://www.cnblogs.com/fightingting/p/14300409.html][https_www.cnblogs.com_fightingting_p_14300409.html] 和 [/images/20221119/6655f296615e42a5a0700678b9b8d952.png][https_www.cnblogs.com_fengxueyi_p_13888562.html]

## 数据准备和连接部分 ##

![file][file 2] 从代码可以看到。对于websocket这一块。做好了多个websocket的连接的做法。随后阻塞的连接每个客户端。然后利用线程池每隔30秒检测是否关闭。关闭的话回去尝试重连接。如果不能重新连接会抛出错误

## 发送消息部分 ##

关于websocket发送消息的部分，我之前使用spring-websocket做过一个类似的案例[https://zhaozhen.blog.csdn.net/article/details/80356392][https_zhaozhen.blog.csdn.net_article_details_80356392] 。其实主要就是利用onMessage来传递数据。即在修改时由admin发送数据。随后网关部分做相应操作 ![file][file 3] 接下来有了这样的问题。接收到了数据之后WebsocketDataHandler的executor并没有实现什么实际的操作，这个需要后续在组件操作时继续研究

## 问题 ##

*  在保存有其他同步机制的情况下，websocket的通信问题
 *  数据变化时WebsocketDataHandler的executor会做什么样的操作

> 欢迎搜索关注本人与朋友共同开发的微信面经小程序【大厂面试助手】和公众号【微瞰技术】,以及总结的分类面试题[https://github.com/zhendiao/JavaInterview][https_github.com_zhendiao_JavaInterview]

![file][file 4] ![file][file 5]

[file]: /images/20221119/2f2c667f1ea041048232dc93eac08306.png
[file 1]: https://img-blog.csdnimg.cn/20210121004619118.png
[https_www.cnblogs.com_fightingting_p_14300409.html]: https://www.cnblogs.com/fightingting/p/14300409.html
[https_www.cnblogs.com_fengxueyi_p_13888562.html]: /images/20221119/6655f296615e42a5a0700678b9b8d952.png
[file 2]: /images/20221119/fc5451db699d49a2ad95d5fd5e049009.png
[https_zhaozhen.blog.csdn.net_article_details_80356392]: https://zhaozhen.blog.csdn.net/article/details/80356392
[file 3]: https://img-blog.csdnimg.cn/20210121004620237.png
[https_github.com_zhendiao_JavaInterview]: https://github.com/zhendiao/JavaInterview
[file 4]: https://img-blog.csdnimg.cn/20210121004620388.png
[file 5]: https://img-blog.csdnimg.cn/20210121004620534.png