提交 933009c8 编写于 作者: 偏锋书生's avatar 偏锋书生

使用示例,init

上级 8f5bfcdd
/.settings/
/.project
......@@ -9,15 +9,15 @@ duckula的使用demo
#### 安装教程
1. xxxx
2. xxxx
3. xxxx
1. 在监听的数据实例上创建一个数据库叫“tams”,并给监听帐号对它具有创建表的权限。
2.
3.
#### 使用说明
1. xxxx
2. xxxx
3. xxxx
1.
2.
3.
#### 参与贡献
......@@ -27,11 +27,3 @@ duckula的使用demo
4. 新建 Pull Request
#### 码云特技
1. 使用 Readme\_XXX.md 来支持不同的语言,例如 Readme\_en.md, Readme\_zh.md
2. 码云官方博客 [blog.gitee.com](https://blog.gitee.com)
3. 你可以 [https://gitee.com/explore](https://gitee.com/explore) 这个地址来了解码云上的优秀开源项目
4. [GVP](https://gitee.com/gvp) 全称是码云最有价值开源项目,是码云综合评定出的优秀开源项目
5. 码云官方提供的使用手册 [https://gitee.com/help](https://gitee.com/help)
6. 码云封面人物是一档用来展示码云会员风采的栏目 [https://gitee.com/gitee-stars/](https://gitee.com/gitee-stars/)
/target/
/.settings/
/.classpath
/.project
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>net.wicp.tams</groupId>
<artifactId>duckula3-dev-demo</artifactId>
<version>0.0.1</version>
</parent>
<artifactId>duckula3-dev-demo-cuslistener</artifactId>
<dependencies>
<dependency>
<groupId>net.wicp.tams</groupId>
<artifactId>common-binlog-alone</artifactId>
<version>3.6.14</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
</dependency>
</dependencies>
</project>
\ No newline at end of file
package net.wicp.tams.duckula.demo.cuslistener;
import java.io.IOException;
import java.util.Properties;
import net.wicp.tams.common.Conf;
import net.wicp.tams.common.apiext.IOUtil;
import net.wicp.tams.common.binlog.alone.BusiAssit;
public class Main {
public static void main(String[] args) throws IOException {
Properties props = IOUtil.fileToProperties("/common-binlog-chk-mysql.properties", Main.class);
Conf.overProp(props);
BusiAssit.startListenerForConfig();
System.in.read();
}
}
package net.wicp.tams.duckula.demo.cuslistener;
import java.io.Serializable;
import net.wicp.tams.common.Result;
import net.wicp.tams.common.binlog.alone.DuckulaAssit;
import net.wicp.tams.common.binlog.alone.ListenerConf.ColHis;
import net.wicp.tams.common.binlog.alone.ListenerConf.DuckulaEvent;
import net.wicp.tams.common.binlog.alone.binlog.bean.Rule;
import net.wicp.tams.common.binlog.alone.binlog.listener.AbsBinlogListener;
public class TestListener extends AbsBinlogListener {
@Override
public void doBusiTrue(Rule rule, DuckulaEvent duckulaEvent) {
Integer age = DuckulaAssit.getValue(duckulaEvent, "age", 0);
System.out.println("age=" + age);
Serializable postNo = DuckulaAssit.getValue(duckulaEvent, "postNo", 0);
System.out.println("postNo=" + postNo);
}
@Override
public Result doAlterTableCallBack(Rule rule, ColHis colHis, String sql) {
// TODO Auto-generated method stub
return null;
}
@Override
public void doInit(Rule rule, int index) {
}
}
#\u63d2\u4ef6\u53ef\u4ee5\u770bcommon-es-plugin\u7684test
common.binlog.alone.binlog.global.busiPluginDir=null
#\u9ed8\u8ba4\u7684\u76d1\u542c\u670d\u52a1\u914d\u7f6e,\u5982\u679c\u6709\u591a\u5957\uff0c\u590d\u5236\u6b64\u914d\u7f6e\u5e76\u4fee\u6539global.conf\u4e3aconf.XXXX(\u89c1\u4e0b\u9762\u793a\u4f8b)
common.binlog.alone.binlog.global.conf.host= localhost
common.binlog.alone.binlog.global.conf.port = 3307
common.binlog.alone.binlog.global.conf.username = root
common.binlog.alone.binlog.global.conf.password = mysql
common.binlog.alone.binlog.global.conf.listener = net.wicp.tams.duckula.demo.cuslistener.TestListener
common.binlog.alone.binlog.global.conf.rds = false
#\u8bbe\u7f6e\u4e86groupId\u8868\u793a\u9700\u8981\u505a\u5206\u5e03\u5f0f\u9501\uff0c\u540c\u4e00\u4e2agroupId+ip\u5c31\u662f\u4e00\u4e2a\u96c6\u7fa4\u5206\u5e03\u5f0f\u9501
common.binlog.alone.binlog.global.conf.groupId = 20000
#\u9ed8\u8ba4\u4f7f\u7528CheckPointH2db\uff0c\u8fd8\u63d0\u4f9b\u4e86CheckPointMemory\u7684chk\u5b9e\u73b0,CheckPointMysql\u591a\u8fdb\u7a0b\u7684HA\u673a\u5236
common.binlog.alone.binlog.global.chk=net.wicp.tams.common.binlog.alone.checkpoint.CheckPointMysql
#\u5982\u679c\u5176\u5b83\u4e0e\u914d\u7f6e\u76f8\u540c\u5c31\u53ef\u4ee5\u4e0d\u914d\u7f6e
common.binlog.alone.binlog.global.chk.mysql.defaultdb=tams
#cur\u8868\u793a\u4ece\u5f53\u524d\u6700\u65b0\u4f4d\u70b9\u542f\u52a8\uff0clast\u8868\u793a\u4ece\u8bb0\u5f55\u7684\u6700\u540e\u4f4d\u70b9\u542f\u52a8\uff0cpos\u8868\u793a\u4ece\u4e0a\u9762\u8bbe\u7f6e\u7684gtids\u542f\u52a8
common.binlog.alone.binlog.global.conf.haType = last
#\u4e3a\u4e86\u505aHA,\u5fc5\u987b\u586b\u4e00\u4e2a\uff0c\u5426\u5219\u4e0d\u80fd\u533a\u5206lastPo
common.binlog.alone.binlog.conf.abc.clientId=20000
common.binlog.alone.binlog.conf.abc.rule=test`user_info`{}&test`user_addr`{}
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<!-- 只需配置好 log.dir 和 projectname 属性-->
<configuration debug="false">
<property name="log.dir" value="/alidata1" />
<property name="projectname" value="common-binlog-alone" />
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<target>System.out</target>
<encoder charset="UTF-8">
<pattern>%d [%thread] %-5p [%c] [%F:%L] - %msg%n</pattern>
</encoder>
</appender>
<appender name="infoAppender"
class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.dir}/logs/${projectname}.log</file>
<filter class="ch.qos.logback.classic.filter.LevelFilter"><!-- 只打印INFO日志 -->
<level>INFO</level>
<onMatch>ACCEPT</onMatch>
<onMismatch>DENY</onMismatch>
</filter>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.dir}/logs/${projectname}-%d{yyyy-MM-dd}.log
</fileNamePattern>
<maxHistory>30</maxHistory>
</rollingPolicy>
<encoder charset="UTF-8">
<pattern>%d [%thread] %-5p [%c] [%F:%L] - %msg%n</pattern>
</encoder>
</appender>
<appender name="errorAppender"
class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.dir}/logs/${projectname}-error.log</file>
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> <!-- 只打印WARN和ERROR日志 -->
<level>WARN</level>
</filter>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.dir}/logs/${projectname}-error-%d{yyyy-MM-dd}.log
</fileNamePattern>
<maxHistory>30</maxHistory>
</rollingPolicy>
<encoder charset="UTF-8">
<pattern>%d [%thread] %-5p [%c] [%F:%L] [trace=%X{X-Trace-Id:-},span=%X{X-Span-Id:-},parent=%X{X-Parent-Id:-},name=%X{X-Span-Name:-},appname=%X{appname:-},begintime=%X{begintime:-}] - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.apache">
<level value="INFO" />
<appender-ref ref="errorAppender" />
<appender-ref ref="infoAppender" />
</logger>
<logger name="org.springframework">
<level value="INFO" />
<appender-ref ref="errorAppender" />
<appender-ref ref="infoAppender" />
</logger>
<logger name="net.wicp.tams.demo">
<level value="INFO" />
<appender-ref ref="errorAppender" />
<appender-ref ref="infoAppender" />
</logger>
<root>
<level value="INFO" />
<appender-ref ref="STDOUT" />
</root>
</configuration>
\ No newline at end of file
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>duckula3-dev-demo</artifactId>
<version>0.0.1</version>
<packaging>pom</packaging>
<parent>
<groupId>net.wicp.tams</groupId>
<artifactId>common</artifactId>
<version>3.6.13</version>
</parent>
<modules>
<module>duckula3-dev-demo-cuslistener</module>
</modules>
</project>
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册