SpringBoot+Nacos+Kafka实现微服务流编排

微服务开发涉及了一些数据处理模块的开发，每个处理业务都会开发独立的微服务，便于后面拓展和流编排。,学习了 SpringCloud Data Flow 等框架，感觉这个框架对于我们来说太重了，维护起来也比较麻烦，于是根据流编排的思想，基于我们目前的技术栈实现简单的流编排功能。,简单的说，我们希望自己的流编排就是微服务可插拔，微服务数据入口及输出可不停机修改。,自己学习的话推荐使用 docker 安装，命令如下：,拉取镜像：,创建服务：,然后在浏览器输入 ip:8848/nacos，账号 nacos；密码 nacos。,,docker 能够帮助我们快速安装服务，减少再环境准备花的时间。,配置文件：,建议配置本机 host 就可以填写 xxx-server 不用填写服务 ip。,我们现在需要对三个服务进行编排，保障每个服务可以插拔，也可以调整服务的位置。,,示意图如上：,①创建配置,通常流编排里面每个服务都有一个输入及输出，分别为 input 及 sink，所以每个服务我们需要配置两个 topic，分别是 input-topic output-topic，我们就在 nacos 里面添加输入输出配置。,nacos 配置项需要配置 groupId，dataId，通常我们用服务名称作为 groupId，配置项的名称作为 dataId。,如 node1-server 服务有一个 input 配置项，配置如下：,,完成其中一个服务的配置，其它服务参考下图配置即可：,,②读取配置,代码如下：,③监听配置改变,服务的输入需要在服务启动时候创建消费者，在 topic 发生改变时候重新创建消费者，移除旧 topic 的消费者，输出是业务驱动的，无需监听改变，在每次发送时候读取到的都是最新配置的 topic。,因为在上面的配置类中 autoRefreshed = true，这个只会刷新 nacosConfig 中的配置值，服务需要知道配置改变去驱动消费的创建业务，需要创建 nacos 配置监听。,流编排的思路整体来说就是数据流方向可调，我们以此为需求，根据一些主流框架提供的 api 实现自己的动态调整方案，可以帮助自己更好的理解流编码思想及原理。,在实际业务中，还有许多业务问题需要去突破，我们这样处理更多是因为服务可插拔，便于流处理微服务在项目灵活搭配。,