这是一个创建于 870 天前的主题，其中的信息可能已经有所发展或是发生改变。
各位大佬们，碰到一个消息发送的需求，想请教一下： 消息体里面的字段是主表+关联表的属性字段，当这些属性字段发生变更时，要把变更的字段内容发出去。 目前的情形是：主表，关联表的字段修改，后端有差不多 10 个接口，我的方案是使用 AOP 去拦截这些接口在 before 和 after 做处理就好了。 但我上司觉得不好，后面如果其他人开发其他接口时也有修改这些属性的可能，可能会漏掉。我上司希望这个东西不会影响后面人的开发，但我比较菜，想不出来其他方法了，希望大家能指点一二
第 1 条附言 2023-05-29 11:31:35 +08:00
统一回复一下：
属性修改有业务逻辑，设计到属性状态这些的，有些属性修改要审批通过后才发消息。cannal 我看了下是支持带业务逻辑的处理，但目前时间比较紧，应该来不及去研究了，准备穷举接口先把需求完成吧。
刚入职一个月，对项目还不是很熟悉，真是鸭梨山大啊，谢谢大家的回复
属性修改有业务逻辑，设计到属性状态这些的，有些属性修改要审批通过后才发消息。cannal 我看了下是支持带业务逻辑的处理，但目前时间比较紧，应该来不及去研究了，准备穷举接口先把需求完成吧。
刚入职一个月，对项目还不是很熟悉，真是鸭梨山大啊，谢谢大家的回复
 | 1 k9990009 2023-05-29 06:28:24 +08:00 via Android canal |
 | 2 xuanbg 2023-05-29 08:33:41 +08:00 binlog |
 | 3 cloud107202 2023-05-29 08:43:46 +08:00 debezium |
 | 4 96XL 2023-05-29 08:49:28 +08:00 拦截这些表的 update sql ？ |
 | 5 4lieS 2023-05-29 08:57:18 +08:00 canal |
 | 6 bugprovider 2023-05-29 09:03:30 +08:00 binlog |
 | 7 chenPiMeiHaoChi 2023-05-29 09:50:43 +08:00 发哪去啊？发给其他平台的话就用 mq ，记好日志，留好证据吵架用。 |
 | 8 siweipancc 2023-05-29 10:24:49 +08:00 最近写了个类似的东西，如果是 java 跟 Hibernate 有几个类给你关注一下 `org.hibernate.integrator.spi.Integrator`,`org.hibernate.event.spi.PostUpdateEventListener` 然后可以参照一下官方的缓存实现 `org.hibernate.cache.internal.CollectionCacheInvalidator` 其他的实现 JPA 标准的提供商都应该都有这一块的逻辑，非 service 驱动的话 hook 进去即可。如果不是 JPA 标准，那么你只能自己实现了，注意`脏值`这个语义, 拦截 sql 大部分是无意义的 |
 | 9 jiakme 2023-05-29 12:00:18 +08:00 flink-cdc |
 | 10 yinaqu 2023-05-29 12:39:19 +08:00  1 兄弟，你拦截接口层，那必然会导致后续有新接口也要加拦截，甚至不是接口去修改，就是个定时任务或者其他 service 修改了字段，你或者其他开发人员忘记了有这么个更新字段业务的情况（没忘每次都要额外处理也烦）。反正你这种实现方式确实不合适。binlog 的方案我感觉相对也麻烦，思路切换到在表格映射 java 实体这一层做钩子我觉得会好很多。如果你们用的是 jpa hibernate 之类的，可以尝试直接在 entity 这一层使用 @PreUpdate 和 @PrePersist 。 |
| 11 yinaqu 2023-05-29 12:46:23 +08:00 @yinaqu 如果你们用的是其它 orm 框架，比如 mybatis 之类的，就去查它有没有类似的功能，感觉这是个相当基础的功能，一般来说都有 |
 | 12 cnoder 2023-05-29 12:53:23 +08:00 canal |
 | 13 fengpan567 2023-05-29 15:15:06 +08:00 canal |
 | 你担心 deadline ，可以和上级商量。花时间去研究 canal ，这对项目来说是好事。好过你去写一个未来肯定会废弃的东西，浪费时间。 |
 | 15 KimAndBella 2023-05-29 17:25:57 +08:00 可以考虑字节码编程，在驱动层拦截 sql ，并且抛出来，项目实现接口自定义处理方法，这样不管哪里来的 sql 都可以抓到。 以上可能描述不是很准确，不过我觉得应该可以满足你的需求。 |
 | 16 ycvk 2023-05-29 17:32:11 +08:00 flink cdc |
 | 17 andrew2558 2023-05-29 17:36:12 +08:00 你这个字段变更时，是要时实的发出去吗？如果不需要实时的话。可以用触发器呀，有更新时将修改内容插入到一个特定表内，再用程序去定时观察这张表不就可以了？ |
 | 18 SANJI59 2023-05-29 19:20:55 +08:00 用的什么 orm 框架，拦截 sql 就可以啊。 |
 | 19 urnoob 2023-05-29 19:40:40 +08:00 via Android 拦 sql 会有可靠性问题。 flink debezium 之类的可以。而且实现起来也简单 |
 | 20 lbprivateacc OP @yinaqu 用的是 mybaties ，想过在 dao 层做，但这些字段更新，消息发送存在着业务逻辑。处理起来感觉要就放弃了 |
| 21 lbprivateacc OP @Gobling 要和其他项目，没办法往后推了 |
| 22 lbprivateacc OP 联调，漏打了 |
 | 23 MIUIOS 2023-05-30 09:08:00 +08:00 canal 无脑上啊 ，简简单单， 搞个 client 就行了 |
 | 24 nanjingwuyanzu 2023-05-30 10:01:47 +08:00 直接 canal ，你用其他的方式出了问题研究的时间肯定大于等于你研究 canal 的时间了、 |
 | 25 chachae 2023-08-07 09:34:05 +08:00 debezium cdc ，有用 flink 的可以直接上 flink-cdc |
Select Language