這幾天快速寫了一個粗糙的版本,html
具體原理:java
技術選型 mysql
mysql-binlog-connector-java-0.2.4 + open-replicator-1.0.7 + Netty-4.0.33 web
原理及流程 sql
1)建立到主數據庫的socket鏈接 數據庫
2)定製Netty4.0.33的源碼,接管上述鏈接。 後端
3)處理相應的IO流並解析對應的ROW event事件. socket
4)提取數據存入後端存儲MQ供實時分析spa
--------------------------------------------------------------------------------下面是截圖orm
慢慢推動。
發現好東西: http://dev.mysql.com/doc/internals/en/binlog-event.html
官方的協議分析