当前位置:首页 > Mysql教程 > 列表

MySQL HandlerSocket 插件安装配置详解

发布:smiling 来源: PHP粉丝网  添加日期:2015-04-17 16:11:07 浏览: 评论:0 

HandlerSocket 是MySQL的一个插件,用于跳过MySQL的SQL层面,直接访问内部的InnoDB存储引擎,下面我们来看看MySQL HandlerSocket 插件安装配置详解.

系统信息约定:

系统版本:CentOS 6.3 X86

php安装目录:/usr/local/webserver/php5318

MySQL安装目录:/usr/local/webserver/mysql5520

HandlerSocket安装路径:/usr/local/webserver/handlersocket

安装配置HandlerSocket

安装之前建议你先安装相关支持及需要的组件包:yum install gcc gcc-c++ libtool make openssl-devel perl-DBI perl-DBD-MySQL(如果为64bit OS注意perl-DBD-MySQL.x86_64).

yum install rpm-build gperf readline-devel ncurses-devel time perl-Time-HiRes

安装:如果使用Percona Server版本的MySQL就简单了,因为它已经内置了HandlerSocket支持,不过考虑到其内置的版本不够新,存在一些早已修复的BUG,所以最好采用源代码编译,HandlerSocket是基于MySQL数据库的,因此在安装HanderSocket前需要先按照常规方式部署MySQL服务,同时需注意HandlerSocket时需要MySQL的源码,因此还需要MySQL源码编译方式安装.

  1. [root@iredmail opt]# git clone https://github.com/ahiguti/HandlerSocket-Plugin-for-MySQL.git  --phpfensi.com 
  2. [root@iredmail opt]# cd HandlerSocket-Plugin-for-MySQL 
  3. [root@iredmail HandlerSocket-Plugin-for-MySQL]# ./autogen.sh 
  4. [root@iredmail HandlerSocket-Plugin-for-MySQL]#./configure --prefix=/usr/local/webserver/handlersocket --with-mysql-source=/opt/mysql-5.5.20 --with-mysql-bindir=/usr/local/webserver/mysql5520/bin --with-mysql-plugindir=/usr/local/webserver/mysql5520/lib/mysql/plugin 

Tips:

--with-mysql-source 指定MySQL源码所在目录

--with-mysql-bindir 表示MySQL二进制可执行文件目录

--with-mysql-plugindir 指定MySQL插件的存储路径,如果不清楚这个目录在哪,可以按如下方法查询:

  1. mysql> show variables like 'plugin%'
  2. +---------------+-------------------------------------------+ 
  3. | Variable_name | Value                                     | 
  4. +---------------+-------------------------------------------+ 
  5. | plugin_dir    | /usr/local/webserver/mysql5520/lib/plugin | 
  6. +---------------+-------------------------------------------+ 
  7. 1 row in set (0.00 sec)  --phpfensi.com 
  8. [root@iredmail HandlerSocket-Plugin-for-MySQL]# make 

常见错误:

  1. libtool: link: only absolute run-paths are allowed 
  2. make[2]: *** [handlersocket.la] Error 1 
  3. make[2]: Leaving directory `/opt/HandlerSocket-Plugin-for-MySQL/handlersocket' 
  4. make[1]: *** [all-recursive] Error 1 
  5. make[1]: Leaving directory `/opt/HandlerSocket-Plugin-for-MySQL' 
  6. make: *** [all] Error 2 

解决方法:

  1. [root@iredmail HandlerSocket-Plugin-for-MySQL]# vi handlersocket/Makefile 
  2. line 301: 
  3. $(handlersocket_la_LINK) -rpath $(pkgplugindir) $(handlersocket_la_OBJECTS) $(handlersocket_la_LIBADD) $(LIBS) 
  4. --> 
  5. $(handlersocket_la_LINK) -rpath /opt/HandlerSocket-Plugin-for-MySQL/handlersocket $( handlersocket_la_OBJECTS) $(handlersocket_la_LIBADD) $(LIBS) 
  6. [root@iredmail HandlerSocket-Plugin-for-MySQL]#make install 

完成后,mysql-plugindir目录下应有handlersocket相关文件.

配置MySQL,修改my.cnf配置文件:

  1. [root@iredmail HandlerSocket-Plugin-for-MySQL]# vi /etc/my.cnf 
  2. [mysqld] 
  3. plugin-load=handlersocket.so(plugin-load可略过不配) 
  4. loose_handlersocket_port = 9998 # 指定读请求端口号 
  5. # the port number to bind to (for read requests) 
  6. loose_handlersocket_port_wr = 9999 # 指定写请求端口号 
  7. # the port number to bind to (for write requests) 
  8. loose_handlersocket_threads = 16 # 指定读线程数目 
  9. # the number of worker threads (for read requests) 
  10. loose_handlersocket_threads_wr = 1 # 指定写线程数目 
  11. # the number of worker threads (for write requests) 
  12. open_files_limit = 65535 
  13. to allow handlersocket accept many concurren connections, make open_files_limit as large as possible. 

Tips:InnoDB的innodb_buffer_pool_size,或MyISAM的key_buffy_size等关系到缓存索引的选项尽可能设置大一些,这样才能发挥HandlerSocket的潜力.

登陆MySQL并激活HandlerSocket插件:

  1. [root@iredmail HandlerSocket-Plugin-for-MySQL]# mysql -uroot -p 
  2. mysql> install plugin handlersocket soname 'handlersocket.so'
  3. ERROR 1126 (HY000): Can't open shared library '/usr/local/webserver/mysql5520/lib/plugin/handlersocket.so' (errno: 2 cannot open shared object file: No such file or directory) 

说明:这里提示没有找到handlersocket.so扩展文件,请查看扩展文件是否存在.

  1. mysql> install plugin handlersocket soname 'handlersocket.so'
  2. Query OK, 0 rows affected (0.00 sec) 
  3. mysql> quit; 

至此,HandlerSocket插件安装完毕.

重启mysql服务:

[root@iredmail HandlerSocket-Plugin-for-MySQL]# service mysqld restart

HandlerSocket状态测试

也可以通过查询刚配置的端口是否已经被MySQL占用来确认是否安装成功:

  1. [root@iredmail HandlerSocket-Plugin-for-MySQL]# lsof -i -P | grep mysqld  --phpfensi.com 
  2. mysqld    26871 mysql   11u  IPv4  72467      0t0  TCP *:9998 (LISTEN) 
  3. mysqld    26871 mysql   29u  IPv4  72469      0t0  TCP *:9999 (LISTEN) 
  4. mysqld    26871 mysql   31u  IPv4  72474      0t0  TCP *:3306 (LISTEN) 
  5. Tips:If ports 9998 and 9999 don’t show up.  Make sure SELinux is not running. 

安装配置 php-handlersocket 扩展模块,安装php-handlersocket扩展:

  1. [root@iredmail opt]# wget http://php-handlersocket.googlecode.com/files/php-handlersocket-0.3.1.tar.gz 
  2. [root@iredmail opt]# tar -zxvf php-handlersocket-0.3.1.tar.gz 
  3. [root@iredmail opt]# cd handlersocket/ 
  4. [root@iredmail handlersocket]# /usr/local/webserver/php5318/bin/phpize 
  5. [root@iredmail handlersocket]# ./configure --with-php-config=/usr/local/webserver/php5318/bin/php-config 
  6. ./configure可加参数: 
  7. implemented   configure options       source file 
  8. hsclient   none (default)         handlersocket.cc 
  9. native     --disable-handlersocket-hsclient   handlersocet.c 
  10. Tips:If you get an error: 
  11. configure: error: Can't find hsclient  headers,please install libhsclient firstOr ./configure--disable-handlersocket-hsclient --with-php-config=/usr/local/webserver/php5318/bin/php-config use native type. 
  12. [root@iredmail handlersocket]#make && make install 
  13. A successful install will have created handlersocket.so and put it into the PHP extensions directory. You'll need to and adjust php.ini and add an extension=handlersocket.so line before you can use the extension. 
  14. [root@iredmail handlersocket]# vi /usr/local/webserver/php5318/etc/php.ini 
  15. extension=handlersocket.so 

至此php扩展安装完成,放问php.info页面,我们可以看到已经成功加载了handlersocket扩展.

php-handlersocket 使用示例

  1. <?php 
  2. /*  
  3.  * String  $host:MySQL ip; 
  4.  * String  $port:handlersocket插件的监听端口,它有两个端口可选:一个用于读、一个用于写  
  5.  */ 
  6. $hs = new HandlerSocket($host$port); 
  7. 打开一个数据表: 
  8. /* 
  9.  * Int       $index:这个数字相当于文件操作里的句柄,HandlerSocket的所有其他方法都会依据这个数字来操作由这个   openIndex打开的表, 
  10.  * String  $dbname:库名 
  11.  * String  $table:表名 
  12.  * String  $key:表的“主键”(HandlerSocket::PRIMARY)或“索引名”作为搜索关键字段,这就是说表必须有主键或索引 
  13.  *                 个人理解:要被当做where条件的key字段,这样可以认为handlersocket只有一个where条件 
  14.  * String  $column:'column1,column2' 所打开表的字段(以逗号隔开),就是说$table表的其他字段不会被操作 
  15.  */ 
  16. $hs->openIndex($index$dbname$table$key$column); 
  17. 查询: 
  18. /* 
  19.  * Int     $index: openIndex()所用的$index 
  20.  * String  $operation:openIndex方法中指定的$key字段所用的操作符,目前支持'=', '>=', '< =', '>',and '< ';可以理解为where条件 
  21.  * Array   $value 
  22.  * Int       $number(默认是1):获取结果的最大条数;相当于SQL中limit的第二个参数 
  23.  * Int     $skip(默认是0):跳过去几条;相当于SQL中limit的第一个参数 
  24.  */ 
  25. $retval = $hs->executeSingle($index$operation$value$number$skip); 
  26. 插入(注意:此处的openIndex要用$port_wr,即读写端口): 
  27. /* 
  28.  * Int     $index: openIndex()所用的$index 
  29.  * Array   $arr:数字元素数与openIndex的$column相同 
  30.  */ 
  31. $retval = $hs->executeInsert($index$arr); 
  32. 删除(注意:此处的openIndex要用$port_wr,即读写端口): 
  33. /* 
  34.  * Int     $index: openIndex()所用的$index 
  35.  * String  $operation:openIndex方法中指定的$key字段所用的操作符,目前支持'=', '>=', '< =', '>',and '< ';可以理解为where条件 
  36.  * Array   $value 
  37.  * Int     $number(默认是1):获取结果的最大条数;相当于SQL中limit的第二个参数 
  38.  * Int     $skip(默认是0):跳过去几条;相当于SQL中limit的第一个参数 
  39.  */ 
  40. $retval = $hs->executeDelete($index$operation$value$number$skip); 
  41. 更新(注意:此处的openIndex要用$port_wr,即读写端口): 
  42. /* 
  43.  * Int     $index: openIndex()所用的$index 
  44.  * String  $operation:openIndex方法中指定的$key字段所用的操作符,目前支持'=', '>=', '< =', '>',and '< ';可以理解为where条件 
  45.  * Array   $value 
  46.  * Int       $number(默认是1):获取结果的最大条数;相当于SQL中limit的第二个参数 
  47.  * Int     $skip(默认是0):跳过去几条;相当于SQL中limit的第一个参数 
  48.  */ 
  49. $retval = $hs->executeUpdate($index$operation$value$number$skip); 
  50. Example: 
  51. 测试库 hstestdb,测试表hstesttbl: 
  52. CREATE TABLE `hstesttbl` ( 
  53.   `id` int(11) NOT NULL AUTO_INCREMENT, 
  54.   `k` char(6) DEFAULT NULL, 
  55.   `v` char(6) DEFAULT NULL, 
  56.   PRIMARY KEY (`id`), 
  57.   KEY `idx_hstesttbl_k` (`k`) 
  58. ) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8; 
  59. PHP test Code: 
  60. $host       = 'localhost'
  61. $port       = 9998; 
  62. $port_wr    = 9999; 
  63. $dbname     = 'hstestdb'
  64. $table      = 'hstesttbl'
  65.  
  66. //GET 
  67. $hs = new HandlerSocket($host$port); 
  68. if (!($hs->openIndex(1, $dbname$table, HandlerSocket::PRIMARY, 'k,v'))) { 
  69.     echo $hs->getError(), PHP_EOL; 
  70.     die(); 
  71.  
  72. $retval = $hs->executeSingle(1, '='array('k1'), 1, 0); 
  73. var_dump($retval); 
  74.  
  75. $retval = $hs->executeMulti( 
  76.     array
  77.         array(1, '='array('k1'), 1, 0), 
  78.         array(1, '='array('k2'), 1, 0) 
  79.     ) 
  80. ); 
  81. var_dump($retval); 
  82. unset($hs); 
  83.  
  84. //UPDATE 
  85. $hs = new HandlerSocket($host$port_wr); 
  86. if (!($hs->openIndex(2, $dbname$table'''v'))) { 
  87.     echo $hs->getError(), PHP_EOL; 
  88.     die(); 
  89.  
  90. if ($hs->executeUpdate(2, '='array('k1'), array('V1'), 1, 0) === false) { 
  91.     echo $hs->getError(), PHP_EOL; 
  92.     die(); 
  93.  
  94. unset($hs); 
  95.  
  96. //INSERT 
  97. $hs = new HandlerSocket($host$port_wr); 
  98. if (!($hs->openIndex(3, $dbname$table'''k,v'))) { 
  99.     echo $hs->getError(), PHP_EOL; 
  100.     die(); 
  101.  
  102. if ($hs->executeInsert(3, array('k2''v2')) === false) { 
  103.     echo $hs->getError(), PHP_EOL; 
  104. if ($hs->executeInsert(3, array('k3''v3')) === false) { 
  105.     echo 'A'$hs->getError(), PHP_EOL; 
  106. if ($hs->executeInsert(3, array('k4''v4')) === false) { 
  107.     echo 'B'$hs->getError(), PHP_EOL; 
  108.  
  109. unset($hs); 
  110.  
  111. //DELETE 
  112. $hs = new HandlerSocket($host$port_wr); 
  113. if (!($hs->openIndex(4, $dbname$table''''))) { 
  114.     echo $hs->getError(), PHP_EOL; 
  115.     die(); 
  116.  
  117. if ($hs->executeDelete(4, '='array('k2')) === false) { 
  118.     echo $hs->getError(), PHP_EOL; 
  119.     die(); 
  120. ?> 

Tips:理论上HandlerSocket支持MyISAM,InnoDB等各种引擎,不过推荐使用InnoDB。

Tips:To avoid the insert error,Please remember set storage engine:InnoDB.

Tips:对HandlerSocket一个常见的误解是只能执行PRIMARY类型的KV查询,实际上只要支持索引,一般的简单查询它都能胜任,这里就不多说了,官方文档里有介绍.

HandlerSocket的缺陷:

1)写操作并没有淘汰查询缓存——如果执行了写操作通过HandlerSocket,由于没有失效查询缓存,那么你可能从MySQL读到旧的数据.

2)不支持自动递增——插入时无法从自增列上自动获得增量值.

鉴于以上问题,扬长避短,使用其合并查询操作,发挥其NoSQL性能获取MySQL的InnoDB类型表数据.

写在最后的:MySQL5.6提供原生的Memcached API,实际就是KV型NoSQL了,但HandlerSocket并不局限于KV形式,所以仍然有生存空间.

Tags: HandlerSocket MySQL安装配置

分享到: