php和redis处理回调处理,php如何解决redis中的并发问题详解

具体问题实例

有个键&＃xff0c;假设名称为myNum&＃xff0c;里面保存的是阿拉伯数字&＃xff0c;假设现在值为1&＃xff0c;存在多个连接对myNum进行操作的情况&＃xff0c;这个时候就会有并发的问题。假设有两个连接linkA和linkB&＃xff0c;这两个连接都执行下面的操作&＃xff0c;取出myNum的值&＃xff0c;&＃43;1&＃xff0c;然后再存回去&＃xff0c;看看下面的交互&＃xff1a;

linkA get myNum &＃61;> 1

linkB get myNum &＃61;> 1

linkA set muNum &＃61;> 2

linkB set myNum &＃61;> 2

执行完操作之后&＃xff0c;结果可能是2&＃xff0c;这和我们预期的3不一致。

再看一个具体的例子&＃xff1a;

require "vendor/autoload.php";

$client &＃61; new Predis\Client([

&＃39;scheme&＃39; &＃61;> &＃39;tcp&＃39;,

&＃39;host&＃39; &＃61;> &＃39;127.0.0.1&＃39;,

&＃39;port&＃39; &＃61;> 6379,

]);

for ($i &＃61; 0; $i <1000; $i&＃43;&＃43;) {

$num &＃61; intval($client->get("name"));

$num &＃61; $num &＃43; 1;

$client->setex("name", $num, 10080);

usleep(10000);

}

设置name初始值为0&＃xff0c;然后同时用两个终端执行上面的程序&＃xff0c;最后name的值可能不是2000&＃xff0c;而是一个<2000的值&＃xff0c;这也就证明了我们上面的并发问题的存在&＃xff0c;这个该怎么解决呢&＃xff1f;

redis中的事务

redis中也是有事务的&＃xff0c;不过这个事务没有mysql中的完善&＃xff0c;只保证了一致性和隔离性&＃xff0c;不满足原子性和持久性。

redis事务使用multi、exec命令

原子性&＃xff0c;redis会将事务中的所有命令执行一遍&＃xff0c;哪怕是中间有执行失败也不会回滚。kill信号、宿主机宕机等导致事务执行失败&＃xff0c;redis也不会进行重试或者回滚。

持久性&＃xff0c;redis事务的持久性依赖于redis所使用的持久化模式&＃xff0c;遗憾的是各种持久化模式也都不是持久化的。

隔离性&＃xff0c;redis是单进程&＃xff0c;开启事务之后&＃xff0c;会执行完当前连接的所有命令直到遇到exec命令&＃xff0c;才处理其他连接的命令。

一致性&＃xff0c;看了文档&＃xff0c;觉得挺扯的&＃xff0c;但是貌似说的没有问题。

redis中的事务不支持原子性&＃xff0c;所以解决不了上面的问题。

当然了redis还有一个watch命令&＃xff0c;这个命令可以解决这个问题&＃xff0c;看下面的例子&＃xff0c;对一个键执行watch&＃xff0c;然后执行事务&＃xff0c;由于watch的存在&＃xff0c;他会监测键a&＃xff0c;当a被修该之后&＃xff0c;后面的事务就会执行失败&＃xff0c;这就确保了多个连接同时来了&＃xff0c;都监测着a&＃xff0c;只有一个能执行成功&＃xff0c;其他都返回失败。

127.0.0.1:6379> set a 1

OK

127.0.0.1:6379> watch a

OK

127.0.0.1:6379> multi

OK

127.0.0.1:6379> incr a

QUEUED

127.0.0.1:6379> exec

1) (integer) 2

127.0.0.1:6379> get a

"2"

失败时候的例子&＃xff0c;从最后可以看出&＃xff0c;test的值被其他连接修改了&＃xff1a;

127.0.0.1:6379> set test 1

OK

127.0.0.1:6379> watch test

OK

127.0.0.1:6379> multi

OK

127.0.0.1:6379> incrby test 11

QUEUED

127.0.0.1:6379> exec

(nil)

127.0.0.1:6379> get test

"100"

我的问题如何解决

redis中命令是满足原子性的&＃xff0c;因此在值为阿拉伯数字的时候&＃xff0c;我可以将get和set命令修改为incr或者incrby来解决这个问题&＃xff0c;下面的代码开启两个终端同时执行&＃xff0c;得到的结果是满足我们预期的2000。

require "vendor/autoload.php";

$client &＃61; new Predis\Client([

&＃39;scheme&＃39; &＃61;> &＃39;tcp&＃39;,

&＃39;host&＃39;   &＃61;> &＃39;127.0.0.1&＃39;,

&＃39;port&＃39;   &＃61;> 6379,

]);

for ($i &＃61; 0; $i <1000; $i&＃43;&＃43;) {

$client->incr("name");

$client->expire("name", 10800);

usleep(10000);

}

总结

看了这么多&＃xff0c;简单的总结下&＃xff0c;其实redis本事是不会存在并发问题的&＃xff0c;因为他是单进程的&＃xff0c;再多的command都是one by one执行的。我们使用的时候&＃xff0c;可能会出现并发问题&＃xff0c;比如get和set这一对。

文档来源&＃xff1a;http://www.cnblogs.com/iforever/p/5796902.html

转载请注明来源网站:www.itxm.cn谢谢&＃xff01;

分享到&＃xff1a;