小记MySQL的mysql-udf-http效率测试

看到张宴的博客上关于"http/rest客户端的文章"，怎样安装啥的直接都跳过，下面直接进入测试阶段，测试环境：虚拟机 

 
 
 
    
  
  
  
  1. [root@localhost ~]# uname -a  
    2.   
  
  
  2. Linux sunss 2.6.18-128.el5 #1 SMP Wed Jan 21 10:44:23 EST 2009 i686 i686 i386 GNU/Linux  
    3.

内存和交换分区： 

 
 
 
    
  
  
  
  1. [root@localhost ~]# free -m  
    2.   
  
  
  2.              total       used       free     shared    buffers     cached  
    3.   
  
  
  3. Mem:           376        363         13          0         23        105  
    4.   
  
  
  4. -/+ buffers/cache:        233        142  
    5.   
  
  
  5. Swap:         1023        133        890  
    6.   
  
  
  6. mysql：  
    7.   
  
  
  7. [root@localhost ~]# mysql -u root -p  
    8.   
  
  
  8. Enter password:   
    9.   
  
  
  9. Welcome to the MySQL monitor. Commands end with ; or \g.  
    10.   
  
  
  10. Your MySQL connection id is 57  
    11.   
  
  
  11. Server version: 5.1.26-rc-log Source distribution  
    12.   
  
  
  12.  
    13.   
  
  
  13. Type 'help;' or '\h' for help. Type '\c' to clear the buffer.  
    14.   
  
  
  14. mysql>  
    15.

使用的表结构： 

 
 
 
    
  
  
  
  1. DROP TABLE IF EXISTS `mytable`;  
    2.   
  
  
  2.  
    3.   
  
  
  3. CREATE TABLE `mytable` (  
    4.   
  
  
  4.  `id` int(10) NOT NULL AUTO_INCREMENT,  
    5.   
  
  
  5.  `addtime` int(10) NOT NULL,  
    6.   
  
  
  6.  `title` varchar(255) NOT NULL,  
    7.   
  
  
  7.  PRIMARY KEY (`id`)  
    8.   
  
  
  8. ) ENGINE=MyISAM DEFAULT CHARSET=utf8;  
    9.

php操作
MySQL的程序： 

 
 
 
    
  
  
  
  1.   
  
  
  2.     $type = $_GET['type'];  
    3.   
  
  
  3.     print_r($_GET);  
    4.   
  
  
  4.     include_once("gettime.php");  
    5.   
  
  
  5.     $btime = getmicrotime();  
    6.   
  
  
  6.     $loop_cnt= 1000; //循环次数  
    7.   
  
  
  7.     $db_host = '127.0.0.1'; //  
    8.   
  
  
  8.     $db_user = 'sunss'; //  
    9.   
  
  
  9.     $db_pass = '123456'; //  
    10.   
  
  
  10.     $db_name = 'test'; //  
    11.   
  
  
  11.     $db_link = mysql_connect($db_host, $db_user, $db_pass) or die("Connected failed: ".mysql_error()."\n");  
    12.   
  
  
  12.     mysql_query('set names utf8');  
    13.   
  
  
  13.     mysql_db_query($db_name, $db_link);  
    14.   
  
  
  14.     if ("put" == $type) {//修改  
    15.   
  
  
  15.     $i = 1;  
    16.   
  
  
  16.     while ($i <= $loop_cnt) {  
    17.   
  
  
  17.         $title = "jkjkjkjkjkjkjkjkjkjkjkjkjk";  
    18.   
  
  
  18.         $tt    = time();  
    19.   
  
  
  19.         $sql = "update mytable set addtime=".$tt.",title='".$title."' where id='".$i."'";  
    20.   
  
  
  20.         $res = mysql_query($sql);  
    21.   
  
  
  21.         if (FALSE == $res) {  
    22.   
  
  
  22.             echo "update failed!\n";  
    23.   
  
  
  23.         }  
    24.   
  
  
  24.         $i++;  
    25.   
  
  
  25.     }  
    26.   
  
  
  26.     } else if ("delete" == $type) { //删除  
    27.   
  
  
  27.     $i = 1;  
    28.   
  
  
  28.     while ($i <= $loop_cnt) {  
    29.   
  
  
  29.         $sql = "delete from mytable where id='".$i."'";  
    30.   
  
  
  30.         echo "delete sql: ".$sql."
    ";  
    31.   
  
  
  31.         $res = mysql_query($sql);  
    32.   
  
  
  32.         if (FALSE == $res) {  
    33.   
  
  
  33.         echo "delete failed!\n";  
    34.   
  
  
  34.         }  
    35.   
  
  
  35.         $i++;  
    36.   
  
  
  36.     }  
    37.   
  
  
  37.       
    38.   
  
  
  38.     } else if ("post" == $type) { //添加  
    39.   
  
  
  39.     $i = 0;  
    40.   
  
  
  40.     while ($i < $loop_cnt) {  
    41.   
  
  
  41.         $title = "hahahahahahahahahahahahahahahahahaha";  
    42.   
  
  
  42.         $tt    = time();  
    43.   
  
  
  43.         $sql = "insert into mytable(addtime, title) values($tt, '".$title."')";  
    44.   
  
  
  44.         //print "SQL: ".$sql."
    ";  
    45.   
  
  
  45.         $res = mysql_query($sql);  
    46.   
  
  
  46.         if (FALSE == $res) {  
    47.   
  
  
  47.         echo "insert failed!\n";  
    48.   
  
  
  48.         }  
    49.   
  
  
  49.         $i++;  
    50.   
  
  
  50.     }  
    51.   
  
  
  51.     }  
    52.   
  
  
  52.     mysql_close();  
    53.   
  
  
  53.     $etime = getmicrotime();  
    54.   
  
  
  54.     $runTime = round($etime - $btime, 4);  
    55.   
  
  
  55.     echo "runTime: ".$runTime."\r\n
    ";  
    56.   
  
  
  56. ?>  
    57.

单独执行php连接MySQL，单条连接添加1000条记录需要：0.9s左右php操作memcache的程序：

 
 
 
    
  
  
  
  1.   
  
  
  2.     include_once("gettime.php");  
    3.   
  
  
  3.     $btime = getmicrotime();  
    4.   
  
  
  4.     //   
    5.   
  
  
  5.     $mem_host = "192.168.0.134";  
    6.   
  
  
  6.     $mem_port = "11311";  
    7.   
  
  
  7.     $timeout = 3600;  
    8.   
  
  
  8.     $i = 0;  
    9.   
  
  
  9.     $cnt = 1000;  
    10.   
  
  
  10.     while ($i < $cnt) {  
    11.   
  
  
  11.     $mem = new Memcache;  
    12.   
  
  
  12.     $mem->connect($mem_host, $mem_port) or die("Could not connect!");  
    13.   
  
  
  13.     $ret = $mem->set($i, "11111111111", 0, $timeout);  
    14.   
  
  
  14.     if (false == $ret) {  
    15.   
  
  
  15.         file_put_contents("insert_failed.log", "post failed!\n", FILE_APPEND);  
    16.   
  
  
  16.     }  
    17.   
  
  
  17.     $mem->close();  
    18.   
  
  
  18.     $i++;  
    19.   
  
  
  19.     }  
    20.   
  
  
  20.  
    21.   
  
  
  21.     //   
    22.   
  
  
  22.     $etime = getmicrotime();  
    23.   
  
  
  23.     $runTime = round($etime - $btime, 4);  
    24.   
  
  
  24.     echo "runTime: ".$runTime."\r\n
    ";  
    25.   
  
  
  25. ?>  
    26.

单条连接添加1000条记录，需要0.8s左右，创建触发器：

 
 
 
    
  
  
  
  1. DELIMITER $$  
    2.   
  
  
  2.  
    3.   
  
  
  3. DROP TRIGGER /*!50032 IF EXISTS */ `test`.`mytable_insert`$$  
    4.   
  
  
  4.  
    5.   
  
  
  5. CREATE 
    6.   
  
  
  6.     /*!50017 DEFINER = 'root'@'localhost' */  
    7.   
  
  
  7.     TRIGGER `mytable_insert` AFTER INSERT ON `mytable`   
    8.   
  
  
  8.     FOR EACH ROW BEGIN   
    9.   
  
  
  9.     SET @tt_resu = (SELECT http_put(CONCAT('http://192.168.0.134/mem_ss.php?type=post&id=', NEW.id, "&data=", NEW.addtime), 11));  
    10.   
  
  
  10. END;  
    11.   
  
  
  11. $$  
    12.

为触发器写个php更新memcache,代码如下：

 
 
 
    
  
  
  
  1.   
  
  
  2.     $id        = $_GET['id'];  
    3.   
  
  
  3.     $type      = $_GET['type'];  
    4.   
  
  
  4.     $json_data = $_GET['data'];  
    5.   
  
  
  5.     var_dump($_GET);  
    6.   
  
  
  6.     //  
    7.   
  
  
  7.     $mem_host = "192.168.0.134";  
    8.   
  
  
  8.     $mem_port = "11211";  
    9.   
  
  
  9.     $timeout = 3600;  
    10.   
  
  
  10.     $mem = new Memcache;  
    11.   
  
  
  11.     $mem->connect($mem_host, $mem_port) or die("Could not connect!");  
    12.   
  
  
  12.       
    13.   
  
  
  13.     if ("get" == $type ) {  
    14.   
  
  
  14.     $val = $mem->get($id);  
    15.   
  
  
  15.     echo $val;  
    16.   
  
  
  16.     //$arr = jsonDecode($val,'utf-8');  
    17.   
  
  
  17.     //print_r($arr);  
    18.   
  
  
  18.     } else if ("put" == $type) {  
    19.   
  
  
  19.     $ret = $mem->replace($id, $json_data, 0, $timeout);  
    20.   
  
  
  20.     if (false == $ret) {  
    21.   
  
  
  21.         file_put_contents("replace_failed.log", "replace failed!\n", FILE_APPEND);  
    22.   
  
  
  22.     }   
    23.   
  
  
  23.     } else if ("delete" == $type) {   
    24.   
  
  
  24.     $ret = $mem->delete($id);  
    25.   
  
  
  25.     if (false == $ret) {  
    26.   
  
  
  26.         file_put_contents("delete_failed.log", "delete failed!\n", FILE_APPEND);  
    27.   
  
  
  27.     }  
    28.   
  
  
  28.     } else if ("post" == $type) {  
    29.   
  
  
  29.     $ret = $mem->set($id, $json_data, 0, $timeout);  
    30.   
  
  
  30.     if (false == $ret) {  
    31.   
  
  
  31.         file_put_contents("post_failed.log", "post failed!\n", FILE_APPEND);  
    32.   
  
  
  32.     }  
    33.   
  
  
  33.     }  
    34.   
  
  
  34.  
    35.   
  
  
  35.     $mem->close();  
    36.   
  
  
  36. ?>  
    37.

使用php触发MySQL添加1000条记录，同时触发器触动php更新memcache，使用时间9s左右，因为每次都关闭链接memcache，看是不是关闭链接导致慢，又写了一个程序： 

 
 
 
    
  
  
  
  1.   
  
  
  2.     include_once("gettime.php");  
    3.   
  
  
  3.     $btime = getmicrotime();  
    4.   
  
  
  4.     //连接  
    5.   
  
  
  5.     $mem_host = "192.168.0.134";  
    6.   
  
  
  6.     $mem_port = "11311";  
    7.   
  
  
  7.     $timeout = 3600;  
    8.   
  
  
  8.     $i = 0;  
    9.   
  
  
  9.     $cnt = 1000;  
    10.   
  
  
  10.     while ($i < $cnt) {  
    11.   
  
  
  11.     $mem = new Memcache;  
    12.   
  
  
  12.     $mem->connect($mem_host, $mem_port) or die("Could not connect!");  
    13.   
  
  
  13.     $ret = $mem->set($i, "11111111111", 0, 3600);  
    14.   
  
  
  14.     if (false == $ret) {  
    15.   
  
  
  15.         file_put_contents("insert_failed.log", "post failed!\n", FILE_APPEND);  
    16.   
  
  
  16.     }  
    17.   
  
  
  17.     $mem->close();  
    18.   
  
  
  18.     $i++;  
    19.   
  
  
  19.     }  
    20.   
  
  
  20.  
    21.   
  
  
  21.     //关闭连接  
    22.   
  
  
  22.     $etime = getmicrotime();  
    23.   
  
  
  23.     $runTime = round($etime - $btime, 4);  
    24.   
  
  
  24.     echo "runTime: ".$runTime."\r\n
    ";  
    25.   
  
  
  25. ?>  
    26.

耗时0.9s左右，比一个连接慢不了多少。为了定位是触发器慢还是http_put慢，创建一个临时表tmp_mytable，表结构如下：

 
 
 
    
  
  
  
  1. CREATE TABLE `mytable` (  
    2.   
  
  
  2.  `id` int(10) NOT NULL AUTO_INCREMENT,  
    3.   
  
  
  3.  `addtime` int(10) NOT NULL,  
    4.   
  
  
  4.  `title` varchar(255) NOT NULL 
    5.   
  
  
  5. ) ENGINE=MyISAM DEFAULT CHARSET=utf8;  
    6.

再次修改触发器，如下： 

 
 
 
    
  
  
  
  1. DELIMITER $$  
    2.   
  
  
  2.  
    3.   
  
  
  3. DROP TRIGGER /*!50032 IF EXISTS */ `test`.`mytable_insert`$$  
    4.   
  
  
  4.  
    5.   
  
  
  5. CREATE 
    6.   
  
  
  6.     /*!50017 DEFINER = 'root'@'localhost' */  
    7.   
  
  
  7.     TRIGGER `mytable_insert` AFTER INSERT ON `mytable`   
    8.   
  
  
  8.     FOR EACH ROW BEGIN   
    9.   
  
  
  9.      insert into tmp_mytable values(NEW.id,NEW.addtime,NEW.title);     
    10.   
  
  
  10. END;  
    11.   
  
  
  11. $$  
    12.

再次用php向MySQL中添加1000条记录，消耗时间0.7s左右，证明效率消耗在http_put，也就是mysql-udf-http慢。不知道我的测试有错没？还请正在使用mysql-udf-http的高手，或者对mysql-udf-http有研究的高手指教。

原文链接：http://www.cnblogs.com/sunss/archive/2011/05/09/2041283.html

文章题目：小记MySQL的mysql-udf-http效率测试
文章URL：http://www.csdahua.cn/qtweb/news30/477180.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

网站设计知识

分类信息网站

名片印刷厂　　 　成都网站建设　　 　东电技服　　 　成都防护栏　　 　消防工程　　 　网页设计制作　　 　百度推广公司　　 　成都画册设计公司　　 　东电技改　　 　成都包装设计公司　　 　成都网站推广公司　　 　做网站　　 　响应式网站　　 　成都网站建设公司　　 　支点广告　　 　高端品牌网站建设　　 　成都发电车出租　　 　娃娃鱼鱼苗　　 　网站域名　　 　雅安机房托管