no message

.gitignore

 .idea/
 target/
+*.log

pom.xml

@@ -17,7 +17,7 @@
     <name>schbrain-canal</name>
 
     <properties>
-        <revision>1.1.2-SNAPSHOT</revision>
+        <revision>1.1.2-RELEASE</revision>
     </properties>
 
     <modules>

schbrain-canal-client/src/main/java/com/schbrain/canal/client/core/MethodArgumentResolver.java

@@ -102,11 +102,11 @@ public class MethodArgumentResolver {
     }
 
     public List<EditMetaInfo> resolver(ResolverCanalEvent event, Dml dml) throws InvocationTargetException, IllegalAccessException, ParseException,ReflectionException {
-        EditMetaInfo metaInfo = new EditMetaInfo();
         Class c  = getArgumentClass(event);
         List<EditMetaInfo> editMetaInfos=new ArrayList<>();
         List<Dml.Row> datas = dml.getData();
         for (Dml.Row row : datas) {
+            EditMetaInfo metaInfo = new EditMetaInfo();
             Object after = columnsConvertObject(c,row.getData());
             metaInfo.setAfter(after);
             Object before = columnsConvertObject(c,row.getOld());

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent1.java

-package com.schbrain.web;
-
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.DefCanalEvent;
-import org.springframework.stereotype.Service;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-@Service("myCanalEvent1")
-@TableFilter(table = "wechat_user",schame = "kp_user")
-public class MyCanalEvent1 implements DefCanalEvent {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("======"+header.getSchemaName()+":"+header.getTableName()+":"+"insert");
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("======"+header.getSchemaName()+":"+header.getTableName()+":"+"update");
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("======"+header.getSchemaName()+":"+header.getTableName()+":"+"delete");
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent2.java

-package com.schbrain.web;
-
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.DefCanalEvent;
-import org.springframework.stereotype.Service;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-//@Service("myCanalEvent2")
-//@TableFilter(table = "ding_talk_user",schame = "kp_user")
-public class MyCanalEvent2 implements DefCanalEvent {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("======"+header.getSchemaName()+":"+header.getTableName()+":"+"insert");
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("======"+header.getSchemaName()+":"+header.getTableName()+":"+"update");
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("======"+header.getSchemaName()+":"+header.getTableName()+":"+"delete");
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent3.java

-package com.schbrain.web;
-
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.canal.client.annotation.CanalEventListener;
-import com.schbrain.canal.client.annotation.InsertListenPoint;
-import com.schbrain.canal.client.annotation.UpdateListenPoint;
-import org.springframework.beans.factory.annotation.Autowired;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-//@CanalEventListener
-public class MyCanalEvent3 {
-
-    @Autowired
-    private UserService userService;
-
-    @InsertListenPoint(destination = "kp_user",schema = {"kp_user"},table={"wechat_user"})
-    public void onInsert(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        String user = userService.getUser();
-        System.out.println("MyCanalEvent3======"+header.getSchemaName()+":"+header.getTableName()+":"+"onInsert,user:+"+user);
-    }
-
-    @UpdateListenPoint(destination = "kp_user",schema = {"kp_user"},table={"wechat_user"})
-    public void onUpdate(CanalEntry.Header header, CanalEntry.RowData rowData) {
-        System.out.println("MyCanalEvent3======"+header.getSchemaName()+":"+header.getTableName()+":"+"onUpdate");
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent4.java

-package com.schbrain.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.bean.User;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.SimpleResolverCanalEvent;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-//@Service("myCanalEvent4")
-//@TableFilter(table = "wechat_user",schame = "kp_user")
-@Slf4j
-public class MyCanalEvent4 extends SimpleResolverCanalEvent<User> {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onInsert：{}",s);
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, User before, User after) {
-        String s = JSONObject.toJSONString(before);
-        String b = JSONObject.toJSONString(after);
-        log.info("onUpdate,before:{},after:{}",s,b);
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onDelete：{}",s);
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent5.java

-package com.schbrain.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.bean.User;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.ResolverCanalEvent;
-import com.schbrain.canal.client.event.SimpleResolverCanalEvent;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-//@Service("myCanalEvent5")
-//@TableFilter(table = "wechat_user",schame = "kp_user")
-@Slf4j
-public class MyCanalEvent5 implements ResolverCanalEvent<User> {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onInsert：{}",s);
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, User before, User after) {
-        String s = JSONObject.toJSONString(before);
-        String b = JSONObject.toJSONString(after);
-        log.info("onUpdate,before:{},after:{}",s,b);
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onDelete：{}",s);
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent6.java

-package com.schbrain.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.bean.User;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.ResolverCanalEvent;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-@Slf4j
-//@Service("myCanalEvent6")
-//@TableFilter(table = "wechat_user",schame = "kp_user")
-public class MyCanalEvent6 extends MyCanalEvent4 {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onInsert：{}",s);
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, User before, User after) {
-        String s = JSONObject.toJSONString(before);
-        String b = JSONObject.toJSONString(after);
-        log.info("onUpdate,before:{},after:{}",s,b);
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onDelete：{}",s);
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent7.java

-package com.schbrain.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.bean.User;
-import com.schbrain.canal.client.annotation.TableFilter;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-@Slf4j
-//@Service("myCanalEvent7")
-//@TableFilter(table = "wechat_user",schame = "kp_user")
-public class MyCanalEvent7 extends MyCanalEvent6 {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onInsert：{}",s);
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, User before, User after) {
-        String s = JSONObject.toJSONString(before);
-        String b = JSONObject.toJSONString(after);
-        log.info("onUpdate,before:{},after:{}",s,b);
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, User user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onDelete：{}",s);
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent8.java

-package com.schbrain.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.bean.User;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.SimpleMapCanalEvent;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-import java.util.Map;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-@Slf4j
-@Service("myCanalEvent8")
-@TableFilter(table = "wechat_user",schame = "kp_user")
-public class MyCanalEvent8 extends SimpleMapCanalEvent {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, Map<String, Object> user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onInsert：{}",s);
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, Map<String, Object> before, Map<String, Object> after) {
-        String s = JSONObject.toJSONString(before);
-        String b = JSONObject.toJSONString(after);
-        log.info("onUpdate,before:{},after:{}",s,b);
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, Map<String, Object> user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onDelete：{}",s);
-    }
-}

schbrain-canal-web/src/main/java/com/schbrain/web/MyCanalEvent9.java

-package com.schbrain.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.schbrain.canal.client.annotation.TableFilter;
-import com.schbrain.canal.client.event.MapCanalEvent;
-import com.schbrain.canal.client.event.SimpleMapCanalEvent;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-import java.util.Map;
-
-/**
- * @author zhuyf
- * @date 2022/6/16
- */
-@Slf4j
-@Service("myCanalEvent9")
-@TableFilter(table = "wechat_user",schame = "kp_user")
-public class MyCanalEvent9 implements MapCanalEvent {
-
-    @Override
-    public void onInsert(CanalEntry.Header header, Map<String, Object> user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onInsert：{}",s);
-    }
-
-    @Override
-    public void onUpdate(CanalEntry.Header header, Map<String, Object> before, Map<String, Object> after) {
-        String s = JSONObject.toJSONString(before);
-        String b = JSONObject.toJSONString(after);
-        log.info("onUpdate,before:{},after:{}",s,b);
-    }
-
-    @Override
-    public void onDelete(CanalEntry.Header header, Map<String, Object> user) {
-        String s = JSONObject.toJSONString(user);
-        log.info("onDelete：{}",s);
-    }
-}

schbrain-canal-web/src/main/resources/application.properties

+spring.application.name = test-canal
+
 canal.client.instances.kp_user.addresses=192.168.36.66:11111
 canal.client.instances.kp_user.username=
 canal.client.instances.kp_user.password=
@@ -5,7 +7,7 @@ canal.client.instances.kp_user.retryCount=10
 canal.client.instances.kp_user.zkHosts=192.168.22.22:2181,192.168.22.26:2181,192.168.22.21:2181
 
 
-canal.client.instances.kp_user.addresses=canal-server-stable-0.canal-server-discovery-svc-stable.devops.svc.cluster.local:11111,canal-server-stable-1.canal-server-discovery-svc-stable.devops.svc.cluster.local:11111,canal-server-stable-2.canal-server-discovery-svc-stable.devops.svc.cluster.local:11111
+#canal.client.instances.kp_user.addresses=canal-server-stable-0.canal-server-discovery-svc-stable.devops.svc.cluster.local:11111,canal-server-stable-1.canal-server-discovery-svc-stable.devops.svc.cluster.local:11111,canal-server-stable-2.canal-server-discovery-svc-stable.devops.svc.cluster.local:11111