PHP操作MongoDB时的整数问题及...-php HandlerSocket的使用-深入理解PHP原理之错误抑制与内嵌HTML分析

当前位置: 编程技术>php

本页文章导读:

▪PHP操作MongoDB时的整数问题及对策说明 MongoDB本身有两种整数类型，分别是：32位整数和64位整数，但旧版的PHP驱动不管操作系统是32位还是64位，把所有整数都当做32位整数处理，结果导致64位整数被截断。为了在尽可能保持兼容.........

▪php HandlerSocket的使用 Memcache数据一致性的问题：当MySQL数据变化后，如果不能及时有效的清理掉过期的数据，就会造成数据不一致。这在强调即时性的Web2.0时代，不可取。 Memcache崩溃后的雪崩效应：作为缓存的.........

▪深入理解PHP原理之错误抑制与内嵌HTML分析 PHP提供了一个错误抑制符'@', 它是通过什么方式来阻止错误输出呢? 我又该在什么时候使用它呢? 这是这俩天一些网友提到的共同问题, 今天就索性整体回答下, 备后来人翻阅. PHP文件内嵌HTML.........

[1]PHP操作MongoDB时的整数问题及对策说明

来源: 互联网发布时间: 2013-11-30

MongoDB本身有两种整数类型，分别是：32位整数和64位整数，但旧版的PHP驱动不管操作系统是32位还是64位，把所有整数都当做32位整数处理，结果导致64位整数被截断。为了在尽可能保持兼容性的前提下解决这个问题，新版PHP驱动加入了mongo.native-long选项，以期在64位操作系统中把整数都当做64位来处理，有兴趣的可参考：64-bit integers in MongoDB。

那么PHP驱动真的完全解决了整数问题么？NO！在处理group操作的时候还有BUG：

为了说明问题，我们先来生成一些测试数据：

代码如下:

<?php
ini_set('mongo.native_long', 1);
$instance = new Mongo();
$instance = $instance->selectCollection('test', 'test');
for ($i = 0; $i < 10; $i++) {
$instance->insert(array(
'group_id' => rand(1, 5),
'count' => rand(1, 5),
));
}
?>

下面让我们使用group操作，根据group_id分组，汇总计算count：

代码如下:

<?php
ini_set('mongo.native_long', 1);
$instance = new Mongo();
$instance = $instance->selectCollection('test', 'test');
$keys = array('group_id' => 1);
$initial = array('count' => 0);
$reduce = '
function(obj, prev) {
prev.count += obj.count;
}
';
$result = $instance->group($keys, $initial, $reduce);
var_dump($result);
?>

结果和预想的有出入，count没有实现累加，而是变成了［object Object］，目前，如果必须使用group操作，那么有两种方法可以缓解这个问题：

代码如下:

ini_set('mongo.native_long', 0);
$initial = array('count' => (float)0);

这两种方法都是治标不治本的权宜之计，既然当前PHP驱动里group的实现有问题，那我们就绕开它，用其它的方式实现同样的功能，这个方式就是MapReduce：

代码如下:

<?php
ini_set('mongo.native_long', 1);
$instance = new Mongo();
$instance = $instance->selectDB('test');
$map = '
function() {
emit(this.group_id, this.count);
}
';
$reduce = '
function(key, values) {
var sum = 0;
for (var index in values) {
sum += values[index];
}
return sum;
}
';
$result = $instance->command(array(
'mapreduce' => 'test',
'map' => $map,
'reduce' => $reduce
));
$result = iterator_to_array($instance->{$result['result']}->find());
var_dump($result);
?>

把大象放冰箱里需要三步，而使用MapReduce仅仅需要Map和Reduce两步即可，这里有一个PDF文档生动的说明了MySQL中GROUP BY和MongoDB中MapReduce的对应关系：

SQL to MongoDB

此外，还有很多资料可供参考，如：MongoDB Aggregation III： Map-Reduce Basics。

说明：软件版本为MongoDB（1.6.5），PECL Mongo（1.1.4）。不同版本结论可能不同。

[2]php HandlerSocket的使用

来源: 互联网发布时间: 2013-11-30

Memcache数据一致性的问题：当MySQL数据变化后，如果不能及时有效的清理掉过期的数据，就会造成数据不一致。这在强调即时性的Web2.0时代，不可取。
Memcache崩溃后的雪崩效应：作为缓存的Memcache一旦崩溃，MySQL很可能在短时间内承受高负载而宕机。据说前段时间新浪微博就遭遇了这样的问题。

注：关于清理过期数据的问题，可以在程序架构上想办法，如果数据操作有统一DAO封装的话，可以利用Observer模式来清理过期数据，非主题内容，资料自查。

面对这些问题，HandlerSocket项目是个不错的解决方案，它通过插件的方式赋予MySQL完整的NoSQL功能，从原理上讲，它跳过MySQL中最耗时的语法解析，查询计划等步骤，直接读取数据，如果内存够大，能装下索引，MySQL的查询效率能提高若干倍！

性能测试：Using MySQL as a NoSQL – A story for exceeding 750,000 qps （F*ck GFW）

因为HandlerSocket的性能足够好，所以就没有必要使用Memcache了，能节省大量的硬件资源，相当低碳！而且HandlerSocket操作的是MySQL放在内存中的索引，没有额外的缓存，所以自然就不存在数据一致性的问题。

安装

如果使用Percona Server版本的MySQL就简单了，因为它已经内置了HandlerSocket支持，不过考虑到其内置的版本不够新，存在一些早已修复的BUG，所以最好采用源代码编译。

注：旧版本HandlerSocket的一些问题可参见：What's up with HandlerSocket?

官方已经有了一份简单的安装文档，但在我实际安装时，遇到了一些其他未说明的问题，所以这里就把相应的安装过程再写一遍。

首先要确保已经安装了MySQL5.1以上的版本，我用的是Ubuntu操作系统，事先已经用apt安装了MySQL5.1.37，同时还需要相应的mysql_config，如果是Ubuntu的话，可以：

shell> aptitude install libmysqld-dev

注：如果你用的MySQL是从源代码编译的或官方提供的二进制版本，可以略过此步。

接着下载一份和系统MySQL版本一致的MySQL源代码和HandlerSocket源代码：

mysql-5.1.37.tar.gz
ahiguti-HandlerSocket-Plugin-for-MySQL-1.0.6-76-gf5f7443.tar.gz

shell> tar zxf mysql-5.1.37.tar.gz
shell> tar zxf ahiguti-HandlerSocket-Plugin-for-MySQL-1.0.6-76-gf5f7443.tar.gz
shell> cd ahiguti-HandlerSocket-Plugin-for-MySQL-f5f7443
shell> ./autogen.sh
shell> ./configure --with-mysql-source=../mysql-5.1.37 \
          --with-mysql-bindir=/usr/bin \
          --with-mysql-plugindir=/usr/lib/mysql/plugin

其中的参数含义如下：with-mysql-source表示MySQL源代码目录，with-mysql-bindir表示MySQL二进制可执行文件目录（也就是mysql_config所在目录），with-mysql-plugindir表示MySQL插件目录，如果不清楚这个目录在哪，可以按如下方法查询：

mysql> SHOW VARIABLES LIKE 'plugin%';
+---------------+-----------------------+
| Variable_name | Value         |
+---------------+-----------------------+
| plugin_dir  | /usr/lib/mysql/plugin |
+---------------+-----------------------+

运行命令后，如果你使用的是MySQL5.1.37版本的话，会遇到如下错误信息：

MySQL source version does not match MySQL binary version

明明我们的MySQL源代码版本和二进制版本都是5.1.37，为什么还会出现这个错误呢？通过查询HandlerSocket的编译脚本，发现原来它会检索MySQL源代码目录中的VERSION文件，可MySQL5.1.37的源代码目录里不知何故竟然没有这个文件，所以就报错了，既然知道了原因，那我们就照猫画虎做一个VERSION文件放到MySQL源代码目录，内容如下：

MYSQL_VERSION_MAJOR=5
MYSQL_VERSION_MINOR=1
MYSQL_VERSION_PATCH=37
MYSQL_VERSION_EXTRA=

再次运行configure脚本，应该就OK了，把剩下的步骤进行完：

shell> make
shell> make install

接着需要配置一下HandlerSocket，编辑MySQL配置文件，加入如下内容：

[mysqld]
loose_handlersocket_port = 9998
# the port number to bind to (for read requests)
loose_handlersocket_port_wr = 9999
# the port number to bind to (for write requests)
loose_handlersocket_threads = 16
# the number of worker threads (for read requests)
loose_handlersocket_threads_wr = 1
# the number of worker threads (for write requests)
open_files_limit = 65535
# to allow handlersocket accept many concurrent
# connections, make open_files_limit as large as
# possible.

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

注：apt包管理下的配置文件一般是/etc/mysql/my.cnf，否则一般是/etc/my.cnf

最后登陆MySQL并激活HandlerSocket插件：

mysql> INSTALL PLUGIN handlersocket soname 'handlersocket.so';

重启一下MySQL服务，如果没有问题，就能在MySQL里看到HandlerSocket的线程了：

mysql> SHOW PROCESSLIST;

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

shell> lsof -i :9998
shell> lsof -i :9999

完活儿！现在你的MySQL已经具备NoSQL的能力了！

实战

首先创建一个测试用的表：

CREATE TABLE IF NOT EXISTS `test`.`t` (
 `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
 `a` varchar(10) NOT NULL,
 `b` varchar(10) NOT NULL,
 PRIMARY KEY (`id`),
 KEY `a_b` (`a`,`b`)
) ENGINE=InnoDB;

注：理论上HandlerSocket支持MyISAM，InnoDB等各种引擎，不过推荐使用InnoDB。

HandlerSocket的协议非常简单，指令通过TAB分割，一行就是一个请求。本文用到了：

打开索引：P <索引标识> <数据库> <表> <索引> <字段>
插入数据：<索引标识> ‘+' <参数个数> <参数1> … <参数N>
读取数据：<索引标识> <操作> <参数个数> <参数1> … <参数N> <条数> <偏移>

SQL原型：INSERT INTO test.t (id, a, b) VALUES (1, ‘a1′, ‘b1′), (2, ‘a2′, ‘b2′)

shell> telnet localhost 9999
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
P    1    test  t    PRIMARY id,a,b
0    1
1    +    3    1    a1   b1
0    1    0
1    +    3    2    a2   b2
0    1    0

注：使用HandlerSocket时，因为没有实际运行SQL，所以Binlog记录的是Row格式。

SQL原型：SELECT id, a, b FROM test.t WHERE id = 1 LIMIT 1

shell> telnet localhost 9999
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
P    1    test  t    PRIMARY id,a,b
0    1
1    =    1    1    1    0
0    3    1    a1   b1

SQL原型：SELECT id, a, b FROM test.t WHERE id >=1 LIMIT 2

shell> telnet localhost 9999
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
P    1    test  t    PRIMARY id,a,b
0    1
1    >=   1    1    2    0
0    3    1    a1   b1   2    a2   b2

SQL原型：SELECT id, a, b FROM test.t WHERE a = ‘a1′ AND b = ‘b1′ LIMIT 1

shell> telnet localhost 9999
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
P    1    test  t    a_b   id,a,b
0    1
1    =    2    a1   b1   1    0
0    3    1    a1   b1

对HandlerSocket一个常见的误解是只能执行PRIMARY类型的KV查询，实际上只要支持索引，一般的简单查询它都能胜任，篇幅所限，这里就不多说了，如果你觉得直接操作telnet有些吃力，也可以使用自己熟悉的客户端来测试，官方文档里有介绍。

注：HandlerSocket作者写了一个不错的PPT可以参考：HandlerSocket plugin for MySQL

记：MySQL5.6提供原生的Memcached API，实际就是KV型NoSQL了，但HandlerSocket并不局限于KV形式，所以仍然有生存空间。

互联网技术发展犹如一列高速运行的火车，下一站：HandlerSocket！大家做好准备吧。

[3]深入理解PHP原理之错误抑制与内嵌HTML分析

来源: 互联网发布时间: 2013-11-30

PHP提供了一个错误抑制符'@', 它是通过什么方式来阻止错误输出呢? 我又该在什么时候使用它呢?
这是这俩天一些网友提到的共同问题, 今天就索性整体回答下, 备后来人翻阅.
PHP文件内嵌HTML的处理方式
在PHP中, 所有在标签外的字符, 在词法分析过程中, 都会翻译成T_INLINE_HTML token, 在语法分析的时候, 所有的T_INLIE_HTML都会被分配ZEND_ECHO输出.
也就是说:

代码如下:

<?php
while($con) {
?>
laruence
<?php
}
?>

会生成一条OPLINE: T_ECHO, 而操作数是”laruence”;
就结果来说, 上面的代码, 其实和下面的结果一样:

代码如下:

<?php
while($con) {
echo "laruence";
}
?>

但有一个要注意的地方是, 对于PHP标签外的字符, 在词法分析过程中, 都会以400个字符为单位切分, 比如:

代码如下:

<?php
if(1) {
?>
laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence laruence
<?php
}
?>

上面的代码中, 标签外有531个字符(包含空格回车), 会被分成俩条T_INLINE_HTML输出.
错误抑制符
我们知道,在PHP中,可以通过错误抑制符来静默错误提示, 那么它是通过什么方式呢?
在语法分析的过程中, 对于:

代码如下:

<?php
@include('file');
?>

会分别在include语句前后插入俩条Opline(操作), 这俩个操作分别做:

代码如下:

1. 保存当前的error_reporting值, 并设置error_reporting(0); //关闭错误输出
2. 恢复之前保存的error_reporting值

也就是说, 其实上面的代码, 和下面的代码类似:

代码如下:

$old = error_reporting(0);
include('file');
error_reporting($old);

另外, 讲一句题外话:”什么时候才应用错误抑制呢?”, 我个人建议, 就是如果这条语句出错了对你影响不大, 你也不关心这个错误是什么, 你也不会安排额外的逻辑来处理这种错误, 那么你可以使用错误抑制. 否则, 请你使用额外的逻辑来判断错误.