课程服务mysql
mysql
4.发送数据信息
直播服务
5.发送binlog id位置
Config
+ serviceName+ serviceUrl
elasticsearch
用户服务
搜索服务
api网关
canal client
Gateway
+ request+ response+ filter+ route+ config
数据同步服务
8.数据存储
2.读取解析binlog
redis
3.获取binlog id位置
Key
+ name:String+ type:String
Route
+ url+ serviceName+ api
课程服务
9.响应请求
7.消费端接受消息
教师服务mysql
课程主页
zookpeer
教师服务
用户课程列表
canal server
直播间管理
1.数据变更
Filter
+ seviceName+ strategyName
登录服务
kafka
Response
+ code+ message
Request
+ url+ parameter+ requestType+ header
Filed
DB
+ key:Key+ filed:Filed+ value:Value
短信服务
Value
+ type:String+ array:Array
6.发送到指定的Partition
