mysql主动通知业务系统数据发生变化,mysql表数据发生变化时，主动通知业务系统(mysql-udf-http)...

妖狐艹你老母 2023-01-14 05:59 192阅读 0赞

近期接到一个任务，在商家的商品信息发生改变后，要及时通知商家的业务系统，并将变更后的数据同步过去。

第一时间想法是，在主系统的商家编辑模块插入对应代码，当商品编辑后，发送商品id至MQ中，子系统消息订阅，并进行相应处理，感觉不错，但是在主系统进行扩展，系统代码会越来越臃肿。

有没有更好的解决方案，比如让mysql主动通知业务系统，数据发生变化了？于是找到了mysql-udf-http。

mysql-udf-http 是一款简单的MySQL用户自定义函数，具有http\_get()、http\_post()、http\_put()、http\_delete()四个函数，可以在MySQL数据库中利用HTTP协议进行REST相关操作，它的安装方式如下：

tar zxvf mysql-udf-http-1.0.tar.gz

cd mysql-udf-http-1.0/

./configure --prefix=/usr/local/mysql --with-mysql=/usr/local/mysql/bin/mysql\_config

make && make install

如果提示缺少libcurl，就安装curl

yum install curl\*

正常的情况mysql-udf-http.so等文件将安装至/usr/local/mysql/lib/plugin下，不知什么原因我的装在了/usr/local/mysql/lib/mysql/plugin下，于是加个软链

ln -s /usr/local/mysql/lib/mysql/plugin/mysql-udf-http.so /usr/local/mysql/lib/plugin/mysql-udf-http.so

安装成功后，进到mysql控制台，注册相关函数

create function http\_get returns string soname 'mysql-udf-http.so';

create function http\_post returns string soname 'mysql-udf-http.so';

create function http\_put returns string soname 'mysql-udf-http.so';

create function http\_delete returns string soname 'mysql-udf-http.so';

然后在业务表中加入更新操作的触发器

DELIMITER |

DROP TRIGGER IF EXISTS test\_update;

CREATE TRIGGER test\_update

AFTER UPDATE ON test

FOR EACH ROW BEGIN

SET @tt\_re = (SELECT http\_get(CONCAT('http://192.168.0.1:8080/my.do?id=', OLD.id)));

END |

DELIMITER ;

经测试，当商品表中的数据有更新时，mysql会发送get请求至业务系统。

INSERT 触发器

DELIMITER |

DROP TRIGGER IF EXISTS test\_insert;

CREATE TRIGGER test\_insert

AFTER INSERT ON test

FOR EACH ROW BEGIN

SET @tt\_re = (SELECT http\_get(CONCAT('http://192.168.0.1:8080/my.do?id=', OLD.id)));

END |

DELIMITER ;

DELETE 触发器

DELIMITER |

DROP TRIGGER IF EXISTS test\_delete;

CREATE TRIGGER test\_delete

AFTER DELETE ON test

FOR EACH ROW BEGIN

SET @tt\_re = (SELECT http\_get(CONCAT('http://192.168.0.1:8080/my.do?id=', OLD.id)));

END |

DELIMITER ;

作者： cyantide

链接： https://blog.csdn.net/cyantide/article/details/50828746

著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

到此这篇关于“mysql表数据发生变化时，主动通知业务系统(mysql-udf-http)”的文章就介绍到这了,更多文章或继续浏览下面的相关文章，希望大家以后多多支持Go语言编程网！

相关文章：

发表评论取消回复

表情：

评论列表（有 0 条评论，192人围观）

还没有评论，来说两句吧...

相关阅读

相关当MySQL表结构发生变化，如何确保数据的完整迁移？

确保MySQL表结构变化的数据完整迁移，可以遵循以下几个步骤： 1. **备份现有数据**：在开始任何改变之前，确保对当前表中的所有数据进行备份。这可以通过导出数据到

心已赠人/ 2025年03月08日 05:27/ 0 赞/ 51 阅读

相关 MySQL数据插入后字段发生变化的可能原因

遇到一个bug，往MySQL插入的数据，有一个字段的数据不对，通过Slf4j打印出来的debug日志发现，插入语句中，该字段的参数是正确的，但是表里的数据就是不对，百思不得其解

ゝ一世哀愁。/ 2023年10月02日 21:54/ 0 赞/ 41 阅读

相关 mysql主动通知业务系统数据发生变化,mysql表数据发生变化时，主动通知业务系统(mysql-udf-http)...

近期接到一个任务，在商家的商品信息发生改变后，要及时通知商家的业务系统，并将变更后的数据同步过去。第一时间想法是，在主系统的商家编辑模块插入对应代码，当商品编辑后，发送商品

妖狐艹你老母/ 2023年01月14日 05:59/ 0 赞/ 193 阅读

相关 postgres数据库发生变化后，实时通知前端

[PostgreSQL的数据变化捕获和实时通知——基于Listen-Notify和Server-Sent Events\_黑帽子技术的博客-CSDN博客][Postgre

Myth丶恋晨/ 2022年09月15日 05:36/ 0 赞/ 204 阅读

相关启动mysql服务时：发生系统错误

1. 启动mysql服务时：发生系统错误5 使用命令行 net start MySql 后报错：发生系统错误 5。 ![在这里插入图片描述][20200226091

柔情只为你懂/ 2022年09月11日 09:24/ 0 赞/ 342 阅读

相关【MySQL】——发生系统错误2

最近项目的需要，重装系统后，需要安装MySQL数据库。根据上次的经验([MySQL—服务无法启动][MySQL])，一步一步的安装，但是到了最后，还是遇到了问题。

野性酷女/ 2022年08月20日 12:08/ 0 赞/ 290 阅读

相关 route的值发生变化请求数据

有时候我们想根据route值发生变化时请求数据 //一个组件一个唯一的数据标识，我这里是叫mac watch: { '$route' (to, f

小咪咪/ 2022年05月10日 03:58/ 0 赞/ 264 阅读

相关 CentOS切换Scala版本时未发生变化

背景当前虚拟机CentOS7，且已位于root用户安装的是2.10.5版本的Scala，且在.bashrc中配置了相应的环境变量此时需要更改Scala

快来打我*/ 2022年03月29日 13:49/ 0 赞/ 278 阅读

相关 DOM input 事件值发生变化时触发

input事件当`<input>、<select>、<textarea>`的值发生变化时触发。对于复选框（`<input type=checkbox>`）或单选框（`<inpu

╰+哭是因爲堅強的太久メ/ 2022年03月11日 09:10/ 0 赞/ 330 阅读

相关监控标签发生变化时，发送请求

需求：当选中下拉列表框的选项时，把选中的值作为请求参数，发送给后台。再根据收到的参数赋值给下一个下拉框 < el-select

绝地灬酷狼/ 2021年09月14日 14:28/ 0 赞/ 375 阅读