悲观锁，顾名思义，悲观的认为数据总是会被修改，所以在操作前都会先加上锁，操作完后，再释放锁。
<?php
function getRedis()
{
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
return $redis;
}
function lock($key, $random)
{
$redis = getRedis();
return $redis->set($key, $random, ['nx', 'ex' => 3]);
}
function unlock($key, $random)
{
$redis = getRedis();
//使用lua脚本保证原子性
$script = 'if redis.call("get",KEYS[1]) == ARGV[1] then return redis.call("del",KEYS[1]) else return 0 end';
return $redis->eval($script, [$key, $random], 1);
}
function decrGoodsStockNums()
{
$redis = getRedis();
//获取商品库存数
$ret = $redis->get('goods_stock_nums');
if ($ret === false) {
return false;
}
if ($ret <= 0) {
return false;
}
$random = mt_rand();
//先获取锁
if (lock('goods_stock_nums_lock', $random)) {
//修改库存数
$redis->decr('goods_stock_nums');
//释放锁
unlock('goods_stock_nums_lock', $random);
return true;
} else {
usleep(100);
decrGoodsStockNums();
}
}
decrGoodsStockNums();
五、使用 publish + subscribe 完成发布和订阅
发布代码：
<?php
$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);
$ix = 0;
//发布内容
while (true) {
$redis->publish('news', json_encode([
'title' => '我是新闻标题' . $ix,
'content' => '我是新闻内容' . $ix,
'time' => date('Y-m-d H:i:s'),
]));
$ix++;
sleep(1);
}
订阅代码：
<?php
$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);
//订阅内容
$redis->subscribe(['news'], function ($redis, $channel, $msg) {
$msg = json_decode($msg, true);
echo "标题: {$msg['title']} 内容: {$msg['content']} 时间: {$msg['time']} <br>";
});
更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。