add java with binlog demo

Author: rongfengliang

.gitignore

@@ -0,0 +1,7 @@
+db
+db2
+.settings
+.classpath
+.project
+target
+dependency-reduced-pom.xml

README.md

@@ -0,0 +1,53 @@
+# mysql master-slave-demo
+
+## config
+
+* grant 
+
+```code
+GRANT replication slave ON *.* TO'root'@'%' identified by 'root';
+```
+
+* flush privaliges
+
+```code
+
+```
+
+* view master info
+
+```code
+show master status
+```
+* config  slave 
+
+```code
+change master to master_host='mysql',master_user='root',master_port=3306,master_password='root',master_log_file='mysql-bin.000003',master_log_pos=1027
+```
+
+* start slave
+
+```code
+start slave
+```
+
+* view slave status
+
+```code
+show slave status
+```
+
+## java mysql binlog connector demo
+
+* build
+
+```code
+cd java-binlog
+mvn clean package
+```
+
+* running
+
+```code
+java -jar target/mysql-binglog-app.jar
+```

docker-compose.yaml

@@ -0,0 +1,28 @@
+version: "3"
+services: 
+  mysql:
+    image: mysql:5.7.16
+    environment: 
+    - "MYSQL_ROOT_PASSWORD=root"
+    - "MYSQL_DATABASE=demo"
+    - "MYSQL_USER=demo"
+    - "MYSQL_PASSWORD=demo"
+    command: --character-set-server=utf8mb4 --collation-server=utf8mb4_unicode_ci
+    volumes: 
+    - "./db:/var/lib/mysql"
+    - "./master.cnf:/etc/mysql/my.cnf"
+    ports:
+    - "3306:3306"
+  mysql2:
+    image: mysql:5.7.16
+    environment: 
+    - "MYSQL_ROOT_PASSWORD=root"
+    - "MYSQL_DATABASE=demo"
+    - "MYSQL_USER=demo"
+    - "MYSQL_PASSWORD=demo"
+    command: --character-set-server=utf8mb4 --collation-server=utf8mb4_unicode_ci
+    volumes: 
+    - "./db2:/var/lib/mysql"
+    - "./slave.cnf:/etc/mysql/my.cnf"
+    ports:
+    - "3307:3306"

init.sql

@@ -0,0 +1,11 @@
+-- database
+
+create database demo;
+
+--- table sql
+CREATE TABLE `appdemos` (
+  `id` varchar(100) COLLATE utf8mb4_unicode_ci DEFAULT NULL,
+  `appname` varchar(100) COLLATE utf8mb4_unicode_ci DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci
+
+

java-binlog/pom.xml

@@ -0,0 +1,52 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.dalong</groupId>
+    <artifactId>mysql-binlog-app</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <encoding>UTF-8</encoding>
+        <java.version>1.8</java.version>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>com.github.shyiko</groupId>
+            <artifactId>mysql-binlog-connector-java</artifactId>
+            <version>0.18.1</version>
+        </dependency>
+    </dependencies>
+    <build>
+        <finalName>mysql-binlog-app</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>2.3</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <transformers>
+                                <!-- add Main-Class to manifest file -->
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>com.dalong.Application</mainClass>
+                                </transformer>
+                            </transformers>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+
+    </build>
+
+</project>

java-binlog/src/main/java/com/dalong/Application.java

@@ -0,0 +1,30 @@
+package com.dalong;
+
+import com.github.shyiko.mysql.binlog.BinaryLogClient;
+import com.github.shyiko.mysql.binlog.BinaryLogClient.EventListener;
+import com.github.shyiko.mysql.binlog.event.Event;
+import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer;
+
+import java.io.IOException;
+
+/**
+ * application for mysql binlog demo
+ */
+public class Application {
+    public static void main(String[] args) throws IOException {
+        BinaryLogClient client = new BinaryLogClient("127.0.0.1", 3306, "root", "root");
+        EventDeserializer eventDeserializer = new EventDeserializer();
+        eventDeserializer.setCompatibilityMode(
+                EventDeserializer.CompatibilityMode.DATE_AND_TIME_AS_LONG,
+                EventDeserializer.CompatibilityMode.CHAR_AND_BINARY_AS_BYTE_ARRAY
+        );
+        client.setEventDeserializer(eventDeserializer);
+        client.registerEventListener(new EventListener() {
+            @Override
+            public void onEvent(Event event) {
+                System.out.println(event.toString());
+            }
+        });
+        client.connect();
+    }
+}

master.cnf

@@ -0,0 +1,10 @@
+[mysqld]
+log-bin=mysql-bin
+log-bin-index=mysql-bin.index
+server-id=1
+sync_binlog=1
+binlog_format=mixed
+binlog-do-db=demo
+binlog-ignore-db=mysql
+binlog-ignore-db=performance_schema
+binlog-ignore-db=information_schema

slave.cnf

@@ -0,0 +1,8 @@
+[mysqld]
+server-id=2
+log-bin=mysql-bin
+relay-log-index=slave-relay-bin.index
+relay-log=slave-relay-bin
+sync_master_info=1
+sync_relay_log=1
+sync_relay_log_info=1