So verwenden Sie Maxwell zum Synchronisieren von MySQL-Daten in Echtzeit

root@xxx maxwell]# Passwort
/usr/lokal/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

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

[mysqld]
log-bin=mysql-bin #füge diese Zeile hinzu binlog-format=ROW #wähle Zeilenmodus server_id=1 #gebe nach dem Zufallsprinzip eine Zeichenfolge an, die nicht mit dem Namen anderer Maschinen im Cluster identisch sein darf. Wenn nur eine Maschine vorhanden ist, kannst du sie nach Belieben angeben

mysql> Variablen wie '%log_bin%' anzeigen
+---------------------------------+------------------------------+
| Variablenname | Wert |
+---------------------------------+------------------------------+
| log_bin | EIN |
| log_bin_basename | /data/mysqldb/mysql-bin |
| log_bin_index | /data/mysqldb/mysql-bin.index |
| log_bin_trust_function_creators | AUS |
| log_bin_use_v1_row_events | AUS |
| sql_log_bin | EIN |
+---------------------------------+------------------------------+
6 Reihen im Satz (0,11 Sek.)

#Erstellen Sie einen Benutzer yhrepl mit synchronisierten Daten
mysql> Benutzer ‚yhrepl‘@‚*‘ erstellen, identifiziert durch ‚scgaopan‘; 
Abfrage OK, 0 Zeilen betroffen (0,10 Sek.)

#Dieser Benutzer yhrepl muss die Berechtigung zum Bedienen der Datenbanktabelle haben, die synchronisiert werden muss mysql> gewähre test.* alle Berechtigungen an „yhrepl“@„%“, identifiziert durch „scgaopan“; 
Abfrage OK, 0 Zeilen betroffen (0,13 Sek.)

#Geben Sie yhrepl die Berechtigung zum Synchronisieren von datamysql> grant select,replication client,replication slave on *.* to 'yhrepl'@'%' identified by 'scgaopan';
Abfrage OK, 0 Zeilen betroffen (0,10 Sek.)
# Maxwell benötigt die Berechtigung, den Status in der durch die Option schema_database angegebenen Datenbank zu speichern (der Standarddatenbankname ist maxwell).
mysql> gewähre 'yhrepl'@'%', identifiziert durch 'scgaopan', alle Privilegien auf maxwell.*;
Abfrage OK, 0 Zeilen betroffen (0,09 Sek.)

[root@xxx maxwell-1.19.5]# vi /usr/local/maxwell/maxwell-1.19.5/config.properties
#Protokollebene log_level=DEBUG

Produzent = Kaninchenmq
daemon=true

#Überwachte Datenbank, MySQL-Benutzer muss über die Berechtigung zum Lesen des Binärprotokolls und zum Erstellen neuer Datenbanktabellen verfügen host=47.105.110.xxx
Benutzer=yhrepl
Passwort=scgaopan

output_nulls=true
jdbc_options=autoReconnet=true

#Welche Tabellen in der Datenbank werden überwacht? filter=exclude: *.*,include: test.AA

#replica_server_id und client_id eindeutige Kennung, wird für die Clusterbereitstellung verwendet replica_server_id=64
client_id=Test-ID

#metrics_type=http
#metrics_slf4j_interval=60
#http_port=8111
#http_diagnostic=true # Standardwert: false

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

[root@xxx maxwell-1.19.5]# ./bin/maxwell
#Kann im Hintergrund gestartet werden [root@xxx maxwell-1.19.5]# nohub ./bin/maxwell &

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

./bin/maxwell --client_id maxwell_dev