最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

如何使用Maxwell實(shí)時(shí)同步mysql數(shù)據(jù)

 更新時(shí)間:2021年04月08日 11:22:07   作者:周小董  
這篇文章主要介紹了如何使用Maxwell實(shí)時(shí)同步mysql數(shù)據(jù),幫助大家更好的理解和學(xué)習(xí)使用MySQL,感興趣的朋友可以了解下

Maxwell簡(jiǎn)介

maxwell是由java編寫(xiě)的守護(hù)進(jìn)程,可以實(shí)時(shí)讀取mysql binlog并將行更新以JSON格式寫(xiě)入kafka、rabbitMq、redis等中,  這樣有了mysql增量數(shù)據(jù)流,使用場(chǎng)景就很多了,比如:實(shí)時(shí)同步數(shù)據(jù)到緩存,同步數(shù)據(jù)到ElasticSearch,數(shù)據(jù)遷移等等。

maxwell官網(wǎng):http://maxwells-daemon.io
 maxwell源代碼:https://github.com/zendesk/maxwell

Maxwell的配置與使用

maxwell 依賴java sdk,所以需要先配置JDK環(huán)境。

1.下載Maxwell安裝包

root@xxx maxwell]# pwd
/usr/local/maxwell
[root@xxx maxwell]# wget https://github.com/zendesk/maxwell/releases/download/v1.19.5/maxwell-1.19.5.tar.gz
[root@xxx maxwell]# tar zxvf maxwell-1.19.5.tar.gz 
[root@xxx maxwell]# cd maxwell-1.19.5

2.配置mysql,打開(kāi)mysql binlog日志

[root@xxx mysql]# vi /usr/local/mysql/my.cnf 

[mysqld]
log-bin=mysql-bin #添加這一行就
binlog-format=ROW #選擇row模式
server_id=1 #隨機(jī)指定一個(gè)不能和其他集群中機(jī)器重名的字符串,如果只有一臺(tái)機(jī)器,那就可以隨便指定了

重啟mysql服務(wù),登陸mysql,查看binlog日志模式

mysql> show variables like '%log_bin%'
+---------------------------------+-------------------------------+
| Variable_name                   | Value                         |
+---------------------------------+-------------------------------+
| log_bin                         | ON                            |
| log_bin_basename                | /data/mysqldb/mysql-bin       |
| log_bin_index                   | /data/mysqldb/mysql-bin.index |
| log_bin_trust_function_creators | OFF                           |
| log_bin_use_v1_row_events       | OFF                           |
| sql_log_bin                     | ON                            |
+---------------------------------+-------------------------------+
6 rows in set (0.11 sec)

Maxwell需要在schema_database選項(xiàng)指定的數(shù)據(jù)庫(kù)中存儲(chǔ)狀態(tài)的權(quán)限(默認(rèn)庫(kù)名稱為maxwell),所以需要提前給權(quán)限:

#創(chuàng)建一個(gè)有同步數(shù)據(jù)的用戶yhrepl
mysql> create user 'yhrepl'@'*' identified by 'scgaopan'; 
Query OK, 0 rows affected (0.10 sec)

#此用戶yhrepl要有對(duì)需要同步的數(shù)據(jù)庫(kù)表有操作權(quán)限
mysql> grant all privileges on test.* to 'yhrepl'@'%' identified by 'scgaopan'; 
Query OK, 0 rows affected (0.13 sec)

#給yhrepl有同步數(shù)據(jù)的權(quán)限
mysql> grant select,replication client,replication slave on *.* to 'yhrepl'@'%' identified by 'scgaopan';
Query OK, 0 rows affected (0.10 sec)
# Maxwell需要在schema_database選項(xiàng)指定的數(shù)據(jù)庫(kù)中存儲(chǔ)狀態(tài)的權(quán)限(默認(rèn)庫(kù)名稱為maxwell)
mysql> grant all privileges on maxwell.* to 'yhrepl'@'%' identified by 'scgaopan';
Query OK, 0 rows affected (0.09 sec)

3.啟動(dòng)Maxwell,主要介紹數(shù)據(jù)寫(xiě)入rabbitmq的實(shí)戰(zhàn):

[root@xxx maxwell-1.19.5]# vi /usr/local/maxwell/maxwell-1.19.5/config.properties
#日志級(jí)別
log_level=DEBUG

producer=rabbitmq
daemon=true

#監(jiān)控的數(shù)據(jù)庫(kù), mysql用戶必須擁有讀取binlog權(quán)限和新建庫(kù)表的權(quán)限
host=47.105.110.xxx
user=yhrepl
password=scgaopan

output_nulls=true
jdbc_options=autoReconnet=true

#監(jiān)控?cái)?shù)據(jù)庫(kù)中的哪些表
filter=exclude: *.*,include: test.AA

#replica_server_id 和 client_id 唯一標(biāo)示,用于集群部署
replica_server_id=64
client_id=test-id

#metrics_type=http
#metrics_slf4j_interval=60
#http_port=8111
#http_diagnostic=true # default false

#rabbitmq
rabbitmq_host=47.105.110.xxx
rabbitmq_port=5672
rabbitmq_user=guest
rabbitmq_pass=guest
rabbitmq_virtual_host=/
rabbitmq_exchange=maxwell
rabbitmq_exchange_type=topic
rabbitmq_exchange_durable=false
rabbitmq_exchange_autodelete=false
rabbitmq_routing_key_template=%db%.%table%
rabbitmq_message_persistent=false
rabbitmq_declare_exchange=true

啟動(dòng)Maxwell:

[root@xxx maxwell-1.19.5]# ./bin/maxwell
#可以后臺(tái)啟動(dòng)
[root@xxx maxwell-1.19.5]# nohub ./bin/maxwell &

啟動(dòng)成功,此時(shí)會(huì)自動(dòng)生成maxwell庫(kù),該庫(kù)記錄了maxwell同步的狀態(tài),最后一次同步的id等等信息,在主庫(kù)失敗或同步異常后,只要maxwell庫(kù)存在,下次同步會(huì)根據(jù)最后一次同步的id。如果沒(méi)有生成maxwell庫(kù)或報(bào)錯(cuò),可能config.properties中配置的mysql用戶權(quán)限不夠

rabbitmq的操作

rabbitmq的操作,啟動(dòng)maxwell后就有一個(gè)maxwell的exchage生成

但對(duì)應(yīng)的queue和exchange和queue的綁定需要用戶自己去實(shí)現(xiàn)

新建一個(gè)maxwell-test的queue:

把queue與exchange進(jìn)行綁定:

注意,這里的Routing key 是區(qū)分大小寫(xiě)的

在數(shù)據(jù)庫(kù)中修改一條記錄,可以看到maxwell-test隊(duì)列里面有一第記錄了。

全量同步

使用maxwell-bootstrap命令

./bin/maxwell-bootstrap --database xhd --table xhd-sso --host 127.0.0.1 --user xiehd --password xiehd2018 --client_id maxwell_dev

同步xhd.xhd-sso表的所有數(shù)據(jù),并指定client_id示maxwell_dev的maxwell執(zhí)行同步

上一個(gè)命令先開(kāi)著,然后再啟動(dòng)client_id=maxwell_dev的maxwell

./bin/maxwell --client_id maxwell_dev

等待執(zhí)行完成即可

以上就是如何使用Maxwell實(shí)時(shí)同步mysql數(shù)據(jù)的詳細(xì)內(nèi)容,更多關(guān)于用Maxwell同步mysql數(shù)據(jù)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • MySql二進(jìn)制連接方式詳解

    MySql二進(jìn)制連接方式詳解

    這篇文章主要介紹了MySql二進(jìn)制連接方式詳解的相關(guān)資料,需要的朋友可以參考下
    2016-05-05
  • mysql如何將sql查詢的結(jié)果以百分比展示出來(lái)

    mysql如何將sql查詢的結(jié)果以百分比展示出來(lái)

    這篇文章主要給大家介紹了關(guān)于mysql如何將sql查詢的結(jié)果以百分比展示出來(lái)的相關(guān)資料,用到了MySQL字符串處理中的兩個(gè)函數(shù)concat()和left()實(shí)現(xiàn)查詢結(jié)果以百分比顯示,需要的朋友可以參考下
    2023-08-08
  • mysql 數(shù)據(jù)插入優(yōu)化方法

    mysql 數(shù)據(jù)插入優(yōu)化方法

    當(dāng)一個(gè)線程對(duì)一個(gè)表執(zhí)行一個(gè)DELAYED語(yǔ)句時(shí),如果不存在這樣的處理程序,一個(gè)處理器線程被創(chuàng)建以處理對(duì)于該表的所有DELAYED語(yǔ)句。
    2010-12-12
  • mysql如何設(shè)置主從數(shù)據(jù)庫(kù)的同步

    mysql如何設(shè)置主從數(shù)據(jù)庫(kù)的同步

    這篇文章主要介紹了mysql如何設(shè)置主從數(shù)據(jù)庫(kù)的同步問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-10-10
  • Navicat無(wú)法連接MySQL報(bào)錯(cuò)1251的解決方案

    Navicat無(wú)法連接MySQL報(bào)錯(cuò)1251的解決方案

    這篇文章主要為大家詳細(xì)介紹了Navicat無(wú)法連接MySQL報(bào)錯(cuò)1251的解決方案,文中解決方法介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2023-12-12
  • 基于MySQL數(shù)據(jù)庫(kù)的數(shù)據(jù)約束實(shí)例及五種完整性約束介紹

    基于MySQL數(shù)據(jù)庫(kù)的數(shù)據(jù)約束實(shí)例及五種完整性約束介紹

    今天小編就為大家分享一篇關(guān)于基于MySQL數(shù)據(jù)庫(kù)的數(shù)據(jù)約束實(shí)例及五種完整性約束介紹,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧
    2019-01-01
  • MySQL數(shù)據(jù)庫(kù)十大優(yōu)化技巧

    MySQL數(shù)據(jù)庫(kù)十大優(yōu)化技巧

    WEB開(kāi)發(fā)者不光要解決程序的效率問(wèn)題,對(duì)數(shù)據(jù)庫(kù)的快速訪問(wèn)和相應(yīng)也是一個(gè)大問(wèn)題。希望本文能對(duì)大家掌握MySQL優(yōu)化技巧有所幫助。
    2011-03-03
  • MySQL數(shù)據(jù)庫(kù)的約束使用實(shí)例

    MySQL數(shù)據(jù)庫(kù)的約束使用實(shí)例

    約束是用來(lái)限制表中的數(shù)據(jù)長(zhǎng)什么樣子的,即什么樣的數(shù)據(jù)可以插入到表中,什么樣的數(shù)據(jù)插入不到表中,下面這篇文章主要給大家介紹了關(guān)于如何通過(guò)一文理解MySQL數(shù)據(jù)庫(kù)的約束與表的設(shè)計(jì)的相關(guān)資料,需要的朋友可以參考下
    2022-12-12
  • MySQL主鍵批量修改的坑與解決方案

    MySQL主鍵批量修改的坑與解決方案

    在日常開(kāi)發(fā)中,我們可能會(huì)遇到需要批量修改 MySQL 數(shù)據(jù)表主鍵的情況,乍一看,修改主鍵 ID 似乎是一個(gè)簡(jiǎn)單的操作,但如果處理不當(dāng),會(huì)導(dǎo)致操作失敗甚至數(shù)據(jù)丟失,本文將詳細(xì)剖析問(wèn)題成因,并總結(jié)多種安全高效的解決方案,需要的朋友可以參考下
    2024-12-12
  • mysql安裝時(shí)出現(xiàn)各種常見(jiàn)問(wèn)題的解決方法

    mysql安裝時(shí)出現(xiàn)各種常見(jiàn)問(wèn)題的解決方法

    mysql數(shù)據(jù)庫(kù)安裝不了了!mysql最后一步安裝不上?真頭疼!這篇文章主要為大家詳細(xì)介紹了解決mysql安裝時(shí)出現(xiàn)各種經(jīng)典問(wèn)題的方法,感興趣的小伙伴們可以參考一下
    2016-08-08

最新評(píng)論

和硕县| 云霄县| 怀安县| 滁州市| 蒙阴县| 淮南市| 凌海市| 大关县| 高要市| 红桥区| 修武县| 彩票| 通许县| 来宾市| 名山县| 陆河县| 东丰县| 长宁县| 台湾省| 安丘市| 渭源县| 颍上县| 宁南县| 石林| 明水县| 桑日县| 房产| 繁昌县| 汶川县| 元谋县| 容城县| 盖州市| 二连浩特市| 泗洪县| 天峨县| 稻城县| 象州县| 桂东县| 和平县| 漳州市| 阳城县|