锁机制之所以存在是因为并发导致的资源竞争，为了确保操作的有效性和完整性，可以通过锁机制将并发状态转换成串行状态。作为锁机制中的一种，PHP的文件锁也是为了应对资源竞争。假设一个应用场景，在存在较大并发的情况下，通过fwrite向文件尾部多次有序的写入数据，不加锁的情况下会发生什么？多次有序的写入操作相当于一个事务，我们此时需要保证这个事务的完整性。
如果我们有两个程序同时向某个文件中写入数据，为了保证数据的完整性，可以加一个文件锁，先让程序1执行，程序1执行完后，解锁，再让程序2执行。实现代码如下：
| 代码如下 | 复制代码 |
$fp=fopen('test.txt',"a"); $count= 10; if(flock($fp, LOCK_EX)) { for($i=1;$i<$count;$i++){ fwrite($fp,'text2_'.$i."rn"); echo"test2".date('h:i:s') . " "; sleep(1); echo"test2".date('h:i:s'); } flock($fp, LOCK_UN); }else{ echo"Couldn't lock the file !"; } fclose($fp); | |
小编给大家推荐的这篇文章介绍了PHP连接MySQL进行增、删、改、查操作，非常实用，有兴趣的同学可以看看
| 代码如下 | 复制代码 |
<tablewidth="100%"border="1"cellpadding="0"cellspacing="0"> <tr> <td>代号</td> <td>姓名</td> <td>性别</td> <td>民族</td> <td>生日</td> </tr> <?php 1.造一个mysqli对象,造连接对象 $db=newMySQLi("localhost","用户名","密码","数据库名"); 2.准备一条SQL语句 $sql="select * from info"; 3.执行SQL语句,如果是查询语句，成功返回结果集对象 $reslut = $db->query($sql); 4.判断返回是否执行成功 if($reslut) { while($attr = $reslut->fetch_row()) { echo "<tr> <td>{$attr[0]}</td> <td>{$attr[1]}</td> <td>{$attr[2]}</td> <td>{$attr[3]}</td> <td>{$attr[4]}</td> </tr>"; } } ?> </table> | |
fetch_all() 返回全部数组
fetch_row() 返回索引数组
fetch_assoc() 返回关联数组
fetch_object() 返回对象
fetch_array() 返回的数组既有索引的，又有关联的
数据库的删除，增加，修改操作
| 代码如下 | 复制代码 |
<?php //造连接对象 $db=newMySQLi("localhost","用户名","密码","数据库名"); //准备SQL语句 $sql="delete from info where code='p004'"; 删 //$sql = "insert course values" 增 //$sql = "update 表名 set 字段=信息 where 字段=信息" 改 //执行SQL语句 $r=$db->query($sql); if($r) { echo"执行成功"; } else { echo"执行失败"; } ?> | |
本文介绍了thinkphp标签实现bootsrtap轮播carousel实例代码，非常实用，有兴趣的同学可以参考一下。
由于轮播carousel第一个div需要设置active样式才能正常显示，上面的圆点也同样需要数字，
使用volist标签在循环的同时可以取得下标（foreach，for标签实现不了）
| 代码如下 | 复制代码 |
<div class="Container"> <!-- carousel --> <div id="carousel-example-generic"class="carousel slide"data-ride="carousel"> <ol class="carousel-indicators"> <volist name="bopic"id="xt"> <li data-target="#carousel-example-generic"data-slide-to="{$i-1}"class="<if condition="$i eq 1">active</if>"></li> </volist> </ol> <div class="carousel-inner"> <volist name="bopic"id="xt"> <div class='item <if condition="$i eq 1 ">active</if>'> <img" width=100% src="{$xt.page_bopic_image}"alt="{$xt.page_bopic_seo}"/> </div> </volist> </div> <a class="left carousel-control"href="#carousel-example-generic"data-slide="prev"> <span class="glyphicon glyphicon-chevron-left"></span> </a> <a class="right carousel-control"href="#carousel-example-generic"data-slide="next"> <span class="glyphicon glyphicon-chevron-right"></span> </a> </div> <!-- /.carousel --> </div> | |
本文介绍了PHP进程通信基础之信号量与共享内存通信，非常实用，大家可以参考一下。
由于进程之间谁先执行并不确定，这取决于内核的进程调度算法，其中比较复杂。由此有可能多进程在相同的时间内同时访问共享内存，从而造成不可预料的错误。信号量这个名字起的令人莫名其妙，但是看其英文原意，就十分容易理解。
semaphore 英[ˈseməfɔ:(r)] vt. 发出信号，打旗语;
类似于指挥官的作用。
下面我们看下一个伪代码信号量的使用。
1、创建信号量唯一标识符
$ftok = ftok(__FILE__, 'a');
2、创建信号量资源ID
$sem_resouce_id = sem_get($ftok);
3、接受信号量
sem_acqure($sem_resource_id);
4、释放信号量
sem_release($sem_resource_id);
5、销毁信号量
sem_remove($sem_resource_id);
举个不文雅的例子，使我们容易理解这个信号量在生活中的用法。理解之后可以套用到我们编程领域。
一家公司只有一个卫生间。那么当有人上厕所的时候，都要获取一把锁（信号量），表示卫生间正在使用。代码如下：
sem_acqure($sem_resource_id);
那么员工上完厕所之后，就需要将锁打开，释放锁（信号量），表示现在可以允许别人使用。代码如下：
sem_release($sem_resource_id);
通过一个简单的锁，我们就能够知道当前的厕所（共享内存）是否可以使用。这个例子不雅观，但说明了问题。这篇博客也是有味道的博客，真是不容易。。。。以下是示例代码：
| 代码如下 | 复制代码 |
<?php //创建共享内存区域 $shm_key = ftok(__FILE__,'a'); $shm_id = shm_attach($shm_key, 1024, 0755);
//var_dump($shm_id);die(); resource(4) oftype(sysvshm) const SHARE_KEY = 1; $child_list = [];
//加入信号量 $sem_id = ftok(__FILE__,'b'); $signal = sem_get($sem_id);
//$signal resource(5) oftype(sysvsem)
for($i = 0; $i < 3; $i++) { $pid = pcntl_fork(); if($pid == -1) { exit("Fork fail!".PHP_EOL); } elseif ($pid == 0) { //获取信号量 sem_acquire($signal); if(shm_has_var($shm_id,SHARE_KEY)) { $count = shm_get_var($shm_id, SHARE_KEY); $count++; //模拟业务处理 $sec = rand(1, 3); sleep($sec); shm_put_var($shm_id, SHARE_KEY, $count); }else{ $count = 0; $sec = rand(1, 3); sleep($sec); shm_put_var($shm_id, SHARE_KEY, $count); }
echo"child process: ".getmypid()." is writing! now count is: $count ".PHP_EOL;
//释放信号量 sem_release($signal); exit("child process".getmypid()."end".PHP_EOL); }else{ $child_list[] = $pid; } }
while(count($child_list) > 0) { foreach ($child_list as $key => $pid) { $status = pcntl_waitpid($pid, $status); if($status > 0 || $status == -1) { unset($child_list[$key]); } } sleep(1); }
$count = shm_get_var($shm_id, SHARE_KEY); echo" $count ".PHP_EOL;
//销毁信号量 sem_remove($signal);
shm_remove($shm_id); shm_detach($shm_id); | |