mysql表数据发生变化时,主动通知业务系统(mysql-udf-http)
2016-03-08 17:04
519 查看
近期接到一个任务,在商家的商品信息发生改变后,要及时通知商家的业务系统,并将变更后的数据同步过去。
第一时间想法是,在主系统的商家编辑模块插入对应代码,当商品编辑后,发送商品id至MQ中,子系统消息订阅,并进行相应处理,感觉不错,但是在主系统进行扩展,系统代码会越来越臃肿。
有没有更好的解决方案,比如让mysql主动通知业务系统,数据发生变化了?于是找到了mysql-udf-http。
mysql-udf-http 是一款简单的MySQL用户自定义函数,具有http_get()、http_post()、http_put()、http_delete()四个函数,可以在MySQL数据库中利用HTTP协议进行REST相关操作,它的安装方式如下:
如果提示缺少libcurl,就安装curl
正常的情况mysql-udf-http.so等文件将安装至/usr/local/mysql/lib/plugin下,不知什么原因我的装在了/usr/local/mysql/lib/mysql/plugin下,于是加个软链
安装成功后,进到mysql控制台,注册相关函数
然后在业务表中加入更新操作的触发器
经测试,当商品表中的数据有更新时,mysql会发送get请求至业务系统。
INSERT 触发器
DELETE 触发器
下载地址
http://code.google.com/p/mysql-udf-http
csdn下载
http://download.csdn.net/detail/cyantide/9455805
第一时间想法是,在主系统的商家编辑模块插入对应代码,当商品编辑后,发送商品id至MQ中,子系统消息订阅,并进行相应处理,感觉不错,但是在主系统进行扩展,系统代码会越来越臃肿。
有没有更好的解决方案,比如让mysql主动通知业务系统,数据发生变化了?于是找到了mysql-udf-http。
mysql-udf-http 是一款简单的MySQL用户自定义函数,具有http_get()、http_post()、http_put()、http_delete()四个函数,可以在MySQL数据库中利用HTTP协议进行REST相关操作,它的安装方式如下:
[code]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
[code]yum install curl*
正常的情况mysql-udf-http.so等文件将安装至/usr/local/mysql/lib/plugin下,不知什么原因我的装在了/usr/local/mysql/lib/mysql/plugin下,于是加个软链
[code]ln -s /usr/local/mysql/lib/mysql/plugin/mysql-udf-http.so /usr/local/mysql/lib/plugin/mysql-udf-http.so
安装成功后,进到mysql控制台,注册相关函数
[code]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';
然后在业务表中加入更新操作的触发器
[code]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 触发器
[code]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 触发器
[code]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 ;
下载地址
http://code.google.com/p/mysql-udf-http
csdn下载
http://download.csdn.net/detail/cyantide/9455805
相关文章推荐
- Http协议
- php读取网络文件 curl, fsockopen ,file_get_contents 几个方法的效率对比
- php读取网络文件 curl, fsockopen ,file_get_contents 几个方法的效率对比
- iOS 开发 网络实时监测
- (3)下载网络文件
- TCP/IP 协议族概述
- ACE中TCP通信
- iOS 怎样通过UDP发送广播寻找设备,拿到ip地址,然后用TCP 连接设备
- Http研究心得+面试心得
- 提升linux下tcp服务器并发连接数限制
- Ping检查服务器网络
- C++ 用libcurl库进行http通讯网络编程(转)
- HTTP头部详解
- http协议
- Tcp三次握手和四次挥手 流量控制和拥塞控制
- Nginx使用ssl模块配置https
- Spring MVC - HTTP Status 500 - Servlet.init() for servlet loginDispacher threw exception
- TCP和UDP的区别(转)
- http://www.molotang.com/articles/906.html
- 数据中心网络虚拟化 隧道技术