文档章节

PHP并发操作下的加锁

qimh
 qimh
发布于 2016/11/17 17:09
字数 670
阅读 39
收藏 0

代码如下:

文件锁类

<?php
/**
 * CacheLock 进程锁,主要用来进行cache失效时的单进程cache获取,防止过多的SQL请求穿透到数据库
 * 用于解决PHP在并发时候的锁控制,通过文件/eaccelerator进行进程间锁定
 * 如果没有使用eaccelerator则进行进行文件锁处理,会做对应目录下产生对应粒度的锁
 * 使用了eaccelerator则在内存中处理,性能相对较高
 * 不同的锁之间并行执行,类似mysql innodb的行级锁
 * 本类在sunli的phplock的基础上做了少许修改  http://code.google.com/p/phplock 
 * @author yangxinqi
 *
 */
class b2c_test_cachelock extends b2c_api_rpc_request{
    //文件锁存放路径
    private $path = null;
    //文件句柄
    private $fp = null;
    //锁粒度,设置越大粒度越小
    private $hashNum = 100;
    //cache key 
    private $name;
    //是否存在eaccelerator标志
    private  $eAccelerator = false;
    public $num = 10;
    
    /**
     * 构造函数
     * 传入锁的存放路径,及cache key的名称,这样可以进行并发
     * @param string $path 锁的存放目录,以"/"结尾
     * @param string $name cache key
     */
    public function __construct($name,$path='lock\\')
    {
        //echo "构造方法被执行......";
        //echo $name;
        //echo $path;
        $name = "key_name";
        $path = "D:\\WWW\\ecstore\\data\\lock\\";
        //判断是否存在eAccelerator,这里启用了eAccelerator之后可以进行内存锁提高效率
        $this->eAccelerator = function_exists("eaccelerator_lock");
        if(!$this->eAccelerator)
        {
            $this->path = $path.($this->_mycrc32($name) % $this->hashNum).'.txt';
            //echo "fine name:".$this->path."<br>";
        }
        $this->name = $name;
    }
    
    /**
     * crc32
     * crc32封装
     * @param int $string
     * @return int
     */
    private function _mycrc32($string)
    {
        $crc = abs (crc32($string));
        if ($crc & 0x80000000) {
            $crc ^= 0xffffffff;
            $crc += 1;
        }
        return $crc;
    }
    /**
     * 加锁
     * Enter description here ...
     */
    public function lock()
    {
        //如果无法开启ea内存锁,则开启文件锁
        if(!$this->eAccelerator)
        {
            //配置目录权限可写
            $this->fp = fopen($this->path, 'w+');
            if($this->fp === false)
            {
                return false;
            }
            return flock($this->fp, LOCK_EX);
        }else{
            return eaccelerator_lock($this->name);
        }
    }
    
    /**
     * 解锁
     * Enter description here ...
     */
    public function unlock()
    {
        if(!$this->eAccelerator)
        {
            if($this->fp !== false)
            {
                flock($this->fp, LOCK_UN);
                clearstatcache();
            }
            //进行关闭
            fclose($this->fp);
        }else{
            return eaccelerator_unlock($this->name);
        }
    }
}

?>
 

 

 

使用如下:

并发提供的接口
    //测试线程并发----测试通过解决线程并发问题
    public function fileLock(){
        $lock = kernel::single("b2c_test_cachelock");//实例化类也可以这样:$lock = new CacheLock('key_name',"D:\\WWW\\ecstore\\data\\lock\\");
        $lock->lock();//文件加锁
        //logic  如下:
        //链接数据库
        //数据库sdb_b2c_cart_objects表测试记录:obj_ident=1    member_ident=10    member=10    obj_type=goods    params=21    quantity=100    
        $conn = Mysql::mysqlConnection();//获取数据连接,这里连接你们自己的数据库
        $sql = "select quantity from sdb_b2c_cart_objects where obj_ident = 1 ";
        $result = mysql_query($sql,$conn);
        
        $quantity = 0;
        while($row = mysql_fetch_array($result,MYSQL_ASSOC)){
            $quantity= $row['quantity'];
        }
        sleep(1);//休眠一秒钟
        //logic here
        if($quantity > 0){
            //echo $lock->num;
            
            $quantity -- ;
            ToolKit::_myLogln("数量:",$quantity,LOG_DIR."fileLock");//打印日志,可以删除
            echo $quantity;
            $update_sql = 'update sdb_b2c_cart_objects set quantity = "'.$quantity.'" where obj_ident = 1';
            mysql_query($update_sql);
        }
        $lock->unlock();//文件解锁
        //使用过程中需要注意下文件锁所在路径需要有写权限.
    }

 

 

转自这篇博客:http://www.nowamagic.net/php/php_LockInConcurrent.php

 

© 著作权归作者所有

共有 人打赏支持
qimh
粉丝 8
博文 364
码字总数 66097
作品 0
滁州
程序员
inhere/php-queue

php 的队列实现 php的队列使用包装, 默认自带支持 三个级别的队列操作。 基于数据库(mysql/sqlite)的队列实现 基于 php 实现 基于 redis 实现 - 操作具有原子性,并发操作不会有问题 基于共享...

inhere
2017/06/13
0
0
Go实例讲解,并发编程-slice并发读写的线程安全性问题

先上实例代码,后面再来详细讲解。 /** * 并发编程,切片的线程安全性问题 */package main import ( "fmt" "sync" "time") var list []int = []int{}var wgList sync.WaitGroup = sync.Wait...

一凡Sir
08/14
0
0
多线程——探索 ConcurrentHashMap 高并发性的实现机制

ConcurrentHashMap 的结构分析 为了更好的理解 ConcurrentHashMap 高并发的具体实现,让我们先探索它的结构模型。 ConcurrentHashMap 类中包含两个静态内部类 HashEntry 和 Segment。HashEnt...

亚特兰缇斯
2015/09/08
231
0
php redis实现秒杀功能

主要针对并发情况下,通过redis的分布式锁和队列的方式进行处理的代码 Queue:{商品ID}: 数据类型是有序集合(zset),成员是用户ID,score是用户入队的时间戳 Lock:Queue:{商品ID}: 数据类型...

RitaChen
2016/11/17
77
0
并发编程(三):同步容器和并发容器

前言 Java 中有些集合和非线程安全,而有些集合是线程安全,后者又被称为是Java中的同步容器,因为它能满足操作的原子性,保持数据同步。有些容器时Java自带的,而有些是通过Collections提供...

mengdonghui123456
2017/08/15
0
0

没有更多内容

加载失败,请刷新页面

加载更多

20180920 rzsz传输文件、用户和用户组相关配置文件与管理

利用rz、sz实现Linux与Windows互传文件 [root@centos01 ~]# yum install -y lrzsz # 安装工具sz test.txt # 弹出对话框,传递到选择的路径下rz # 回车后,会从对话框中选择对应的文件传递...

野雪球
今天
2
0
OSChina 周四乱弹 —— 毒蛇当辣条

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @ 达尔文:分享花澤香菜/前野智昭/小野大輔/井上喜久子的单曲《ミッション! 健?康?第?イチ》 《ミッション! 健?康?第?イチ》- 花澤香菜/前野智...

小小编辑
今天
9
3
java -jar运行内存设置

java -Xms64m #JVM启动时的初始堆大小 -Xmx128m #最大堆大小 -Xmn64m #年轻代的大小,其余的空间是老年代 -XX:MaxMetaspaceSize=128m # -XX:CompressedClassSpaceSize=6...

李玉长
今天
4
0
Spring | 手把手教你SSM最优雅的整合方式

HEY 本节主要内容为:基于Spring从0到1搭建一个web工程,适合初学者,Java初级开发者。欢迎与我交流。 MODULE 新建一个Maven工程。 不论你是什么工具,选这个就可以了,然后next,直至finis...

冯文议
今天
2
0
RxJS的另外四种实现方式(四)——性能最高的库(续)

接上一篇RxJS的另外四种实现方式(三)——性能最高的库 上一篇文章我展示了这个最高性能库的实现方法。下面我介绍一下这个性能提升的秘密。 首先,为了弄清楚Most库究竟为何如此快,我必须借...

一个灰
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部