- 博客(6)
- 收藏
- 关注
RSS订阅原创 flink 实现智能家居场景联动
整个流程分为通过APP 创建设备的场景数据，也就是规则会存到mysql，并且通过flink-cdc 同步到flink 内存中，后面设备上报数据，flink直接从内存中查找对应规则类似下面的代码。所以在这里还引入了S3，整个架构通过flink-mysql-s3 互相配合，架构如下图。在智能家居中总会有场景联动的情况，比如灯开了，怎么让其他智能设备进行联动比如窗帘自动打开。整个流程就结束了，当然这种架构带来的也是复杂度，适用于设备较多处理场景比较复杂的情况。// 存储设备最新状态（灯的状态）
2025-05-16 16:56:52
566
1
原创 SpringBoot 集成 dobbo + zookeeper Demo
之前在网上看了许多教程 但是 copy过来发现还是跑不了 所以自己写了个附加git 仓库可以直接拉下来就可以跑的主要模块为 提供者 消费者。集成了 apache-zookeeper-3.7.1 去官网就可以下载 执行zkServer 脚本就可以了 里面也有配置文件可以看得懂 直接拉下来就可以了 后续就可以自己发挥了git 代码地址：https://github.com/wangwanghui/dubbo-demo.git...
2022-05-19 11:20:38
252
原创 【FTP 文件上传 包含文件夹 和单个文件】
FTP 上传:需要通过判断当前要上传的文件是否是文件夹或者单独一个文件，单独文件直接通过ftpClient.changeWorkingDirectory(remoteDir) 再 ftpClient.storeFile(uploadFile.getName(), uploadStream)即可如果是文件夹 需要递归上传代码如下//上传文件夹 public boolean uploadDirectory(String localDirectory, String rem..
2021-11-23 17:54:37
704
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人