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  --Vevb.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)  --Vevb.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  --Vevb.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 first，Or ./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.  
73. $retval = $hs->executeSingle(1, '=', array('k1'), 1, 0); 
74. var_dump($retval); 
75.  
76. $retval = $hs->executeMulti( 
77.     array( 
78.         array(1, '=', array('k1'), 1, 0), 
79.         array(1, '=', array('k2'), 1, 0) 
80.     ) 
81. ); 
82. var_dump($retval); 
83. unset($hs); 
84.  
85. //UPDATE 
86. $hs = new HandlerSocket($host, $port_wr); 
87. if (!($hs->openIndex(2, $dbname, $table, '', 'v'))) { 
88.     echo $hs->getError(), PHP_EOL; 
89.     die(); 
90. } 
91.  
92. if ($hs->executeUpdate(2, '=', array('k1'), array('V1'), 1, 0) === false) { 
93.     echo $hs->getError(), PHP_EOL; 
94.     die(); 
95. } 
96.  
97. unset($hs); 
98.  
99. //INSERT 
100. $hs = new HandlerSocket($host, $port_wr); 
101. if (!($hs->openIndex(3, $dbname, $table, '', 'k,v'))) { 
102.     echo $hs->getError(), PHP_EOL; 
103.     die(); 
104. } 
105.  
106. if ($hs->executeInsert(3, array('k2', 'v2')) === false) { 
107.     echo $hs->getError(), PHP_EOL; 
108. } 
109. if ($hs->executeInsert(3, array('k3', 'v3')) === false) { 
110.     echo 'A', $hs->getError(), PHP_EOL; 
111. } 
112. if ($hs->executeInsert(3, array('k4', 'v4')) === false) { 
113.     echo 'B', $hs->getError(), PHP_EOL; 
114. } 
115.  
116. unset($hs); 
117.  
118. //DELETE 
119. $hs = new HandlerSocket($host, $port_wr); 
120. if (!($hs->openIndex(4, $dbname, $table, '', ''))) { 
121.     echo $hs->getError(), PHP_EOL; 
122.     die(); 
123. } 
124.  
125. if ($hs->executeDelete(4, '=', array('k2')) === false) { 
126.     echo $hs->getError(), PHP_EOL; 
127.     die(); 
128. } 
129. ?> 

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形式,所以仍然有生存空間.