canal源码流程
2021-04-15 17:14:36 13 举报canal源码流程
作者其他创作
大纲/内容
start()
CanalServerWithNetty
tryPut
MysqlConnection
EntryEventSink
consumeTheEventAndProfilingIfNecessary
MysqlMultiStageCoprocessor$SinkStoreStage
admin
自选监听事件
发送给客户端
MemoryEventStoreWithBuffer
flush()
CanalServerWithEmbedded
shutdown()
AbstractEventParser
DummyEventStore
SessionHandler
注册和启动instance
sendBinlogDump
MQ
doSink
CanalLauncher.main
CanalController
CanalStarter
EventTransactionBuffer
MessageEvent事件
从数据仓库getEvents获取数据
doGet
启动netty
add()
case GET:
runningMonitor.start()
0 条评论
下一页
