序 本文主要研究一下kingbus的resp.go writeOK kingbus/mysql/resp.go {代码…} writeOK方法写入gomysql.OK_HEADER writeError kingbus/mysql/resp.go {代码…} writeError方法写入gomysql.ERR_HEADER writeEOF kingbus/mysql/resp.go {代码…} writeEOF方法写入gomysql.EOF_HEADER writeResultset kingbus/mysql/res…

BinlogProgress定义了currentGtid、lastSaveGtid、lastBinlogFile、lastFilePosition、executedGtidSetStr、trxBoundaryParser、persistentTime、persistentAppliedIndex、executedGtidSet、store属性

DumpBinlogAt方法通过s.store.NewEntryReaderAt(startRaftIndex)获取reader，然后获取nextRaftIndex，之后通过utils.DecodeBinlogEvent(raftEntry)获取event，然后通过s.skipEvent(event, slaveGtids, inExcludeGroup)来判断是否该skip，之后将event写入到eventC

序 本文主要研究一下kingbus的command.go Close kingbus/mysql/command.go {代码…} Close方法执行c.closed.Store(true)、c.Conn.Close()、c.cancel() handleQuery kingbus/mysql/command.go {代码…} handleQuery方法通过sqlParser来解析stmt，然后根据stmt的type来执行不同的方法；对于ShowStmt执行c.handleShow(v)…

序 本文主要研究一下kingbus的startMasterServer startMasterServer kingbus/server/server.go {代码…} startMasterServer方法先执行NewBinlogServer创建master，然后执行master的Start方法 NewBinlogServer kingbus/server/binlog_server.go {代码…} NewBinlogServer方法通过new方法创建BinlogServer，之后设置其li…

StartBinlogServer方法主要是通过h.svr.StartServer(config.BinlogServerType, &args)来启动binlog server

StartBinlogSyncer方法先执行echoCtx.Bind(&args)，然后针对h.svr.IsLeader()为false的通过h.sendToLeader(“PUT”, “/binlog/syncer/start”, req)将请求转发给leader；为true的则执行h.svr.StartServer(config.SyncerServerType, &args)启动syncer server，然后执行h.ProposeSyncerArgs(&args)启动propose sy…