mbinlogmq 一個基于MySQL binlog協議的數據同步中間件

什么是mbinlogmq?

mbinlogmq?是一個使用C語言開發的基于 MySQL?binlog?協議的一個中間件，通過模擬Slave 來實時獲取 MySQL binlog日志，并將數據變更信息以及?DB?語句發送到?RabbitMQ，中間通過監聽機制與校驗機制來確保不宕機的情況下的100%抵達?RMQ

設計架構

安裝&編譯

• mbinlog依賴于一些第三方庫：

請先安裝依賴軟件：?cURL?、mysql、rabbitmq，安裝完成后記住其安裝的路徑，進入下面的步驟

• 下載mbinlogmq源碼

git clone https://gitee.com/josinli/mbinlogmq.git

• 修改?CMakeLists.txt，將如下的幾行變為您上面安裝的路徑：

set(MYSQL_INCLUDE     /usr/local/mysql/include)      # 您系統的MySQL頭文件路徑
set(MYSQL_LIBRARY_DIR /usr/local/mysql/lib)          # 您系統的MySQL庫文件路徑
set(CURL_DIR          /usr/local/Cellar/curl/7.58.0) # 您系統的curl安裝路徑

• 執行編譯安裝命令

mkdir build
cd build
cmake .. && make && sudo make install	

• 修改?/etc/mbinlogmq/binlog.xml?您的配置信息

    rabbitmq 
    127.0.0.1
    root
    3333
    3306
    6
    1




    127.0.0.1
    guest
    guest
    15672
    1
    amq.default
    Invalid
    fanout
    /

• 啟動您的?minblogmq

mbinlogmq -k start

此時進入?MySQL?操作，同時登錄?RabbitMQ?查看消息是否成功抵達，目前的版本存在一些或多或少的問題，切勿生產環境使用。

mbinlogmq會針對不同的binlog日志生成四種類型的消息，消息類型如下

• 消息全部為?JSON?格式
• 格式如下

1、UPDATE?語句，etype等于 1，包含一個pre對象 和?new對象，分別對應修改之前的數據和新的數據

{
    "etype": 1,
    "data" : {
        "pre": {
            "id":1,
            "ad":2
        },
        "new": {
            "id":1,
            "ad":3
        }
    }
}

2、INSERT?消息， etype 等于 2

{
    "etype": 1,
    "data" : {
        "id":1,
        "ad":3
    }
}

3、DELETE?消息， etype 等于 3

{
    "etype": 3,
    "data" : {
        "id":1,
        "ad":3
    }
}

4、SQL 語句?消息， etype 等于 4

{
    etype: 4,
    data: "ALTER TABLE `books`.`test_at` MODIFY COLUMN `cc` datetime(0) NULL DEFAULT NULL AFTER `bb`"
}

示例消息如下：

 [x] Received {"etype":4,"data":"ALTER TABLE `books`.`test_at` \nMODIFY COLUMN `bb` date NULL DEFAULT NULL AFTER `aa`"}
 [x] Received {"etype":4,"data":"ALTER TABLE `books`.`test_at` \nMODIFY COLUMN `bb` date NOT NULL AFTER `aa`"}
 [x] Received {"etype":4,"data":"BEGIN"}
 [x] Received {"etype":1,"data":{"pre":{"id":1,"book_name":"傲世丹神1","book_cover":"http://img.c0m.io/quanben.io/upload/thumbnail/book_0_999/book_1.jpg","add_time":"2019-7-23 14:28:43","author_name":"寂小賊111","introduction":"廢柴少年得無上傳承,獲逆天神脈,學絕世神功,掌握超絕丹術,這使他...","test_date":"2019-7-29"},"new":{"id":1,"book_name":"傲世丹神1","book_cover":"http://img.c0m.io/quanben.io/upload/thumbnail/book_0_999/book_1.jpg","add_time":"2019-7-23 21:47:36","author_name":"寂小賊","introduction":"廢柴少年得無上傳承,獲逆天神脈,學絕世神功,掌握超絕丹術,這使他...","test_date":"2019-7-29"}}}
 [x] Received {"etype":4,"data":"COMMIT"}
 [x] Received {"etype":4,"data":"BEGIN"}
 [x] Received {"etype":1,"data":{"pre":{"id":1,"book_name":"傲世丹神1","book_cover":"http://img.c0m.io/quanben.io/upload/thumbnail/book_0_999/book_1.jpg","add_time":"2019-7-23 21:47:36","author_name":"寂小賊","introduction":"廢柴少年得無上傳承,獲逆天神脈,學絕世神功,掌握超絕丹術,這使他...","test_date":"2019-7-29"},"new":{"id":1,"book_name":"傲世丹神","book_cover":"http://img.c0m.io/quanben.io/upload/thumbnail/book_0_999/book_1.jpg","add_time":"2019-7-23 21:47:54","author_name":"寂小賊","introduction":"廢柴少年得無上傳承,獲逆天神脈,學絕世神功,掌握超絕丹術,這使他...","test_date":"2019-7-29"}}}
 [x] Received {"etype":4,"data":"COMMIT"}

有問題可以及時通過 ISSUE 反饋，反饋地址：GITEE Go Go Go!!!