如何實(shí)時(shí)獲取 MySQL 新增數(shù)據(jù)并發(fā)送短信通知?

如何實(shí)時(shí)獲取 MySQL 新增數(shù)據(jù)并發(fā)送短信通知?

如何通過(guò)實(shí)時(shí)更新獲取數(shù)據(jù)庫(kù)新增數(shù)據(jù)

問(wèn)題:

用戶需要及時(shí)獲取 mysql 表中的新增數(shù)據(jù),以便通過(guò)短信發(fā)送給指定號(hào)碼。傳統(tǒng)的方法是通過(guò)服務(wù)器計(jì)劃任務(wù)每 30 秒讀取數(shù)據(jù)庫(kù),但這會(huì)增加服務(wù)器負(fù)擔(dān)并延遲獲取數(shù)據(jù)。

解決方案:

使用 MySQL Binary Log (Binlog) 和 Canal

  1. 打開(kāi) MySQL 的 Binlog:

    • 在 my.cnf 文件中,找到 binlog-do-db 和 binlog-ignore-db 選項(xiàng),并將其設(shè)置為指定要記錄的數(shù)據(jù)庫(kù)。
    • 確保 Binlog 已打開(kāi),并通過(guò) SHOW MASTER LOGS 命令驗(yàn)證。
  2. 安裝 Canal:

    • Canal 是一個(gè)開(kāi)源組件,用于訂閱 MySQL 的 Binlog。
    • 在服務(wù)器上安裝 Canal,并按照其文檔進(jìn)行配置。
  3. 配置 Canal 訂閱 Binlog:

    • 打開(kāi) Canal 的配置文件 canal.properties,并配置以下內(nèi)容:

      • canal.destinations=example
      • canal.app.destination.example.dw.dbAddress=localhost (數(shù)據(jù)庫(kù)地址)
      • canal.app.destination.example.dw.dbPort=3306 (數(shù)據(jù)庫(kù)端口)
      • canal.app.destination.example.dw.dbUsername=root (數(shù)據(jù)庫(kù)用戶名)
      • canal.app.destination.example.dw.dbPassword=password (數(shù)據(jù)庫(kù)密碼)
      • canal.app.destination.example.dw.database=mysql (要訂閱的數(shù)據(jù)庫(kù)名稱)
      • canal.app.destination.example.dw.table=tbl_name (要訂閱的表名稱)
  4. 啟動(dòng) Canal 服務(wù):

    • 運(yùn)行 sh bin/startup.sh 命令啟動(dòng) Canal。
  5. 實(shí)現(xiàn) php 監(jiān)聽(tīng)器:

    • 編寫(xiě)一個(gè) PHP 監(jiān)聽(tīng)器,連接到 Canal 并處理 Binlog 事件
    • 當(dāng)收到新增數(shù)據(jù)的 Binlog 事件時(shí),監(jiān)聽(tīng)器會(huì)提取數(shù)據(jù)并發(fā)送短信。

通過(guò)上述方法,可以實(shí)現(xiàn)實(shí)時(shí)獲取數(shù)據(jù)庫(kù)新增數(shù)據(jù)的需求,無(wú)需使用計(jì)劃任務(wù),并且可以減少服務(wù)器負(fù)擔(dān)。

? 版權(quán)聲明
THE END
喜歡就支持一下吧
點(diǎn)贊11 分享