首页 / PHP / PHP读写文件高并发处理操作实例详解

PHP读写文件高并发处理操作实例详解

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP读写文件高并发处理操作实例详解，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6721字，纯文字阅读大概需要10分钟。

内容图文

本文实例讲述了PHP读写文件高并发处理操作。分享给大家供大家参考，具体如下：

背景：

最近公司游戏开发需要知道游戏加载的流失率。因为，我们做的是网页游戏。玩过网页游戏的人都知道，进入游戏前要加载一些资源。最后才能到达创建角色的游戏界面。我们有一个需求就是要统计在加载过程中还未到达角色创建界面而流失的用户数量。

我们在加载开始就进行统计人数，加载完成之后再记录人数。这样，通过用加载前的人数减去成功加载后的人数。就知道了加载的流失率。就可以知道游戏是否还要继续优化加载过程，降低用户加载游戏率。

由于，我们的量都是从*主流的合作媒体进行导量过来。所以，并发非常高，据粗略计算应该能达到每秒1000左右的并发数量。

加载前的人数本来想放到游戏内部的缓存平台。但是，游戏后端的同事担心并发太高，导致资源无故浪费。因为，内存的释放并不是实时响应的。所以，将统计的人数放到在另外一台服务器：统计服务器。

我刚开始采用的方案如下：

通过php的file_get_contents()与file_put_contents()进行读取与写入。第一次读写就向文件写入1，第二次加载就在原来的基础上加1.以此类推.这种顺序的思想完全不存在任何问题。问题就出在，我们的服务器不可能是顺序形式的。

准确的说，并发的访问不是顺序的。当A玩家加载游戏读取到文件里面的数字100(假如这时是100)，B玩家读取到的也是100，这时，处理A玩家的线程就是在100的基础上加1，得到101，就会向文件写入101。

处理B玩家的线程也得到相同的结果，将101写入文件。这时，问题就出现了？B玩家是在A玩家之后加载游戏的，理应得到102的计算结果。

这就是并发导致的问题。这个时候，我想到了采用fopen()打开文件，并用flock()加一个写入锁。大家一定会认为，这种方式有了锁定，那么就不会造成问题了。其实，也是错的。

因为，我们的问题不是出在写入上面。而是读取的时候造成数据的不同步。OK。到这里，我实在百度谷歌都搞不定了。

当希望寄托在PHP函数本身而梦碎的时候，我只能另寻它法。脱离它。于是，我想到了*语言的Map映射的机制。类似于我们的PHP数组，每加载一次就我往数组添加一个元素。这样，到最后我只需要count()一下数组就知道了有多少玩家加载了游戏。

但是，用数组的话，也存在一个问题。就是PHP的变量还是常量，在脚本执行完毕之后都会自己清掉。于是，我想到了文件保存的方式。

最终的可行方案思路如下：

用fopen打开一个文件，以只写的方式。然后写锁定。玩家每加载一次我就向文件里面写入一个数字1，最后得到的文件内容通过file_get_contents()一次性读取出来，再用strlen()计算一下长度即知道了有多少玩家加载了游戏。

听闻flock()函数会锁定会造成系统资源在很多时间升高。所以，我采用大家所使用的方式，用微秒超时的技术解决这个问题。如果，走出这个时间我就*掉它。具体的代码如下：

// loadcount.func.php 函数文件。
/**
 * 获取某来源和某服务器ID的游戏加载次数。
 *
 * @param string $fromid 来源标识。
 * @param int $serverid 服务器ID编号。
 *
 * @return int
 */
function getLoadCount($fromid, $serverid)
{
    global $g_global;
    $serverid = (int) $serverid;
    $fromid  = md5($fromid);
    $filename = $fromid . $serverid . '.txt';
    $data = file_get_contents($filename);
    return strlen($data);
}
/**
 * 获取某来源所有服务器的游戏加载次数。
 *
 * @param string $fromid 来源标识。
 *
 * @return int
 */
function getAllLoadCount($fromid)
{
    global $g_global;
    $fromid  = md5($fromid);
    $count = 0;
    foreach (glob("{$fromid}*.txt") as $filename)
    {
        $file_content = file_get_contents($filename);
        $count += strlen($file_content);
    }
    return $count;
}
/**
 * 清空所有的加载数据。
 *
 * @return void
 */
function clearLoadCount()
{
    foreach (glob("*.txt") as $filename) {
      unlink($filename);
    }
    return true;
}
/**
 * 延迟更新游戏加载次数中间件。
 *
 * 使用此函数来延迟更新数据，原理：当不足1000次的时候，不更新数据库，超过1000就更新到数据库里面去。
 *
 * @param string $fromid 来源标识。
 * @param int $serverid 服务器ID编号。
 */
function delayAddLoadCount($fromid, $serverid)
{
    // 使用MD5生成文件名记录缓存次数。
    $fromid  = md5($fromid);
    $filename = $fromid . $serverid . '.txt';
    if($fp = fopen($filename, 'a'))
    {
        $startTime = microtime();
        do {
            $canWrite = flock($fp, LOCK_EX);
            if(!$canWrite)
            {
                usleep(round(mt_rand(0, 100)*1000));
            }
        }
        while ( ( !$canWrite ) && ( ( microtime()- $startTime ) < 1000 ) );
        if ($canWrite)
        {
            fwrite($fp, "1");
        }
        fclose($fp);
    }
    return true;
}

以下是我调用以上方法的文件：

< ?php
/**
 * @describe 平台用户加载游戏次数统计接口入口。
 * @date 2012.12.17
 */
include_once './loadcount.func.php';
// 测试用。
// $_GET['fromid']  = '4399';
// $_GET['serverid'] = mt_rand(0, 5);
// 添加加载次数。
if ( $_GET['action'] == 'addcount' )
{
    $fromid  = $_GET['fromid'];  // 来源标识。
    $serverid = $_GET['serverid']; // 服务器ID编号。
    $return = delayAddLoadCount($fromid, $serverid);
    $return = $return ? 1 : 0;
    ob_clean();
    echo json_encode($return);
    exit;
}
// 取加载次数。
elseif ( $_GET['action'] == 'getcount' )
{
    $fromid = $_GET['fromid'];  // 来源标识。
    if ( !isset( $_GET['serverid'] ) ) // 有服务器编号 ID则取来源对应的服务器加载次数。
    {
        $count = getAllLoadCount($fromid);
    }
    else // 加载对应来源的次数。
    {
        $serverid = $_GET['serverid']; // 服务器ID编号。
        $count = getLoadCount($fromid, $serverid);
    }
    ob_clean();
    header('Content-Type:text/html;charset=UTF-8');
    $serverid = strlen($serverid) ? $serverid : '无';
    echo "来源:{$fromid},服务器ID:{$serverid},游戏加载次数：" . $count;
    exit;
}
// 清除加载次数。
elseif ( $_GET['action'] == 'clearcount' )
{
    header('Content-Type:text/html;charset=UTF-8');
    $return = clearLoadCount();
    if ($return)
    {
        echo "清除成功！";
    }
    else
    {
        echo "清除失败！";
    }
}

这是血的教训，所以，我不得不将它记录下来。以备以后让他人借鉴。

本文是作者寒冰一年前在4399游戏工作室负责做数据分析的时候写的代码。希望对大家有所帮助。

PHP数据库操作之高并发实例

高并发下PHP写文件日志丢失

<?php
/**
 * Created by PhpStorm.
 * User: andyfeng
 * Date: 2015/6/24
 * Time: 13:31
 */
class LogFileUtil {
  public static $fileHandlerCache;
  private static $initFlag = false;
  private static $MAX_LOOP_COUNT = 3;
  private static function init() {
    self::$initFlag = true;
    register_shutdown_function(array("LogFileUtil", "shutdown_func"));
  }
  /**
   *

输出到文件日志 * @param $filePath 文件路径 * @param $msg 日志信息 * @return int */ public static function out($filePath, $msg) { if (!self::$initFlag) { self::init(); } return self::internalOut($filePath, $msg); } /** * @param $filePath * @param $msg * @param $loop * @return int */ private static function internalOut($filePath, $msg, $loop = 0) { //以防一直添加失败造成死循环 if ($loop > self::$MAX_LOOP_COUNT) { $result = 0; } else { $loop++; $fp = self::$fileHandlerCache["$filePath"]; if (empty($fp)) { $fp = fopen($filePath, "a+"); self::$fileHandlerCache[$filePath] = $fp; } if (flock($fp, LOCK_EX)) { $result = fwrite($fp, $msg); flock($fp, LOCK_UN); } else { $result = self::internalOut($filePath, $msg, $loop); } } return $result; } function shutdown_func() { if (!empty(LogFileUtil::$fileHandlerCache)) { if (is_array(LogFileUtil::$fileHandlerCache)) { foreach (LogFileUtil::$fileHandlerCache as $k => $v) { if (is_resource($v)) //file_put_contents("close.txt",$k); fclose($v); } } } } }

更多关于PHP相关内容感兴趣的读者可查看本站专题：《php文件操作总结》、《php缓存技术总结》、《PHP运算与运算符用法总结》、《PHP基本语法入门教程》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。

内容总结

以上是互联网集市为您收集整理的PHP读写文件高并发处理操作实例详解全部内容，希望文章能够帮你解决PHP读写文件高并发处理操作实例详解所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/273557.html

来源：【匿名】

【上一篇】PHP使用文件锁解决高并发问题示例【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【PHP读写文件高并发处理操作实例详解】教程文章相关的互联网学习教程文章

PHP中读写文件实现代码

在PHP中读写文件，可以用到一下内置函数： 1.fopen（创建文件和打开文件）语法：复制代码代码如下:fopen(filename,mode) filename，规定要打开的文件。mode，打开文件的模式，可能的值见下表。 mode 说明 "r" 只读方式打开，将文件指针指向文件开头。 "r+" 读写方式打开，将文件指针指向文件开头。 "w" 写入方式打开，将文件指针指向文件开头并将文件大小截为零。如果文件不存在则尝试创建。 "w+" 读写方式打开，将文件指针指向...

日志-php读写文件多大比较合适？

在使用workman 一个php方面的定时计划任务框架。通过定时写入日志来记录定时任务成功还是失败，当日志文件大小为70M的时候级计划任务断掉了，后台读取日志也不能读取了。请教一下，php 写入日志文件或者读取日志文件，一般日志文件为多大比较合适？看往上有文章说1G的日志文件也能读取，但是普通网站如何来控制日志文件的大小？回复内容：在使用workman 一个php方面的定时计划任务框架。通过定时写入日志来记录定时任务成功...

PHP读写文件的方法(生成HTML)

<?php //生成HTML $countfile="template.html"; $num=file_get_contents($countfile); echo $num; $num=str_replace("|*|*|PAGE_TITLE|*|*|","myhome",$num); $path="template.html"; $handle=fopen($path,"w"); //写入方式打开新闻路径 fwrite($handle,$num); //把刚才替换的内容写进生成的HTML文件 fclose($handle); ?> file_get_contents -- 将整个文件读入一个字符串file -- 把整个文件读入一个数组中

php如何创建和读写文件?【图】

首先创建一个名称为file的php文件并添加标记。创建一个txt文件的文件命名为myfile，用touch函数创建文件。运行后会在php所在的同级目录生成一个myfile文档文件。相关推荐：《php入门教程》用fopen() 函数来打开myfile文档，并赋值。然后往myfile文档中写入内容。如果想要写入多条就执行多次就可以。重新来打开myfile文件这是用来读取文件。读取到myfile文件后利用循环将文件的内容都读取出来并输出出来。最后执行filephp文件，会发...

生成.ShtmlPHP读写文件的方法生成HTML

//生成HTML $countfile="template.html"; $num=file_get_contents($countfile); echo $num; $num=str_replace("|*|*|PAGE_TITLE|*|*|","myhome",$num); $path="template.html"; $handle=fopen($path,"w"); //写入方式打开新闻路径 fwrite($handle,$num); //把刚才替换的内容写进生成的HTML文件 fclose($handle); ?> file_get_contents -- 将整个文件读入一个字符串file -- 把整个文件读入一个数组中以上就介绍了生成.Sht...

PHP读写文件高并发处理操作步骤分析

这次给大家带来PHP读写文件高并发处理操作步骤分析，PHP读写文件高并发处理的注意事项有哪些，下面就是实战案例，一起来看一下。最近公司游戏开发需要知道游戏加载的流失率。因为，我们做的是网页游戏。玩过网页游戏的人都知道，进入游戏前要加载一些资源。最后才能到达创建角色的游戏界面。我们有一个需求就是要统计在加载过程中还未到达角色创建界面而流失的用户数量。我们在加载开始就进行统计人数，加载完成之后再记录人数。这...

PHP并发读写文件如何解决

在并发高的情况下，操作同一个文件会导致数据错乱，所以需要在操作文件时进行一些特殊处理，下面总结一下几种解决方案。希望能帮助到大家。方案一：使用flock函数对文件加锁/* * flock(file,lock,block) * file 必需，规定要锁定或释放的已打开的文件 * lock 必需。规定要使用哪种锁定类型。 * block 可选。若设置为 1 或 true，则当进行锁定时阻挡其他进程。 * lock * LOCK_SH 要取得共享锁定（读取的程序） * LOCK_EX 要取...

php读写文件冲突出现高并发解决方案汇总

在PHP中，flock似乎工作的不是那么好！在多并发情况下，似乎是经常独占资源，不即时释放，或者是根本不释放，造成死锁，从而使服务器的cpu占用很高，甚至有时候会让服务器彻底死掉。好像在很多linux/unix系统中，都会有这样的情况发生。所以使用flock之前，一定要慎重考虑。如果flock()我们使用得当，完全可能解决死锁的问题。当然如果不考虑使用flock()函数，也同样会有很好的解决方案来解决我们的问题。大致归纳了解决方案有如下...

php读写文件的方法

PHP读写文件的方法<?php //生成HTML $countfile="template.html"; $num=file_get_contents($countfile); echo $num; $num=str_replace("|*|*|PAGE_TITLE|*|*|","myhome",$num); $path="template.html"; $handle=fopen($path,"w"); //写入方式打开新闻路径 fwrite($handle,$num); //把刚才替换的内容写进生成的HTML文件 fclose($handle); ?> file_get_contents -- 将整个文件读入一个字符串 file -- 把整个文...

php多用户读写文件冲突的解决办法实例详解

解决多调用同时写一个文件时我们会使用flock来解决些问题，这样同一时间只有一个用户可以写文件，同时其它用户进行等待队列了，下面我来介绍一下flock解决多用户读写文件冲空问题一般的方案会是：代码如下:$fp = fopen("/tmp/lock.txt", "w+"); if (flock($fp, LOCK_EX)) {fwrite($fp, "Write something heren");flock($fp, LOCK_UN); } else {echo "Couldnt lock the file !"; } fclose($fp);但在PHP中，flock似乎工作的不是那么好...

php怎么读写文件？

PHP中读写文件实现代码，整理的还不错，需要的朋友可以参考下。在PHP中读写文件，可以用到一下内置函数： 1.fopen（创建文件和打开文件）语法：代码如下:fopen(filename,mode)filename，规定要打开的文件。mode，打开文件的模式，可能的值见下表。 mode 说明 "r" 只读方式打开，将文件指针指向文件开头。 "r+" 读写方式打开，将文件指针指向文件开头。 "w" 写入方式打开，将文件指针指向文件开头并将文件大小截为零。如果文件不...

PHP读写文件生成HTML的方法

<?php //生成HTML $countfile="template.html"; $num=file_get_contents($countfile); echo $num; $num=str_replace("|*|*|PAGE_TITLE|*|*|","myhome",$num); $path="template.html"; $handle=fopen($path,"w"); //写入方式打开新闻路径 fwrite($handle,$num); //把刚才替换的内容写进生成的HTML文件 fclose($handle); ?>file_get_contents -- 将整个文件读入一个字符串file -- 把整个文件读入一个数组中以上就...

如何解决php多用户读写文件冲突

解决多调用同时写一个文件时我们会使用flock来解决些问题，这样同一时间只有一个用户可以写文件，同时其它用户进行等待队列了，下面介绍一下flock解决多用户读写文件冲空问题一般的方案会是：$fp = fopen("/tmp/lock.txt", "w+"); if (flock($fp, LOCK_EX)) {fwrite($fp, "Write something heren");flock($fp, LOCK_UN); } else {echo "Couldnt lock the file !"; } fclose($fp);但在PHP中，flock似乎工作的不是那么好！在多并发情...

PHP读写文件代码

<?php$str1 = "write something into file. ";$str2 = "this is a text file. ";$filename = "C:/data/01.txt";// 写文件$file = fopen($filename, "w");$w1 = fwrite($file, $str1);$w1 = fwrite($file, "\r\n");$w1 = fwrite($file, $str2);fclose($file);// 读文件$file = fopen($filename, "r");while (!feof ($file)) { echo fgets($file) ."<br>" ;}fclose($file); ?>