Maison >développement back-end >tutoriel php >php服务器推技术的聊天室

php服务器推技术的聊天室

WBOY
WBOYoriginal
2016-07-25 08:57:32904parcourir
  1. //chat.php
  2. header('cache-control: private');
  3. header('Content-Type: text/html; charset=utf-8');
  4. ?>
复制代码

保存用户提交的聊天内容 简易版本:

  1. $content = trim($_POST['content']);
  2. if ($content) {
  3. $fp = fopen('./chat.txt', 'a');
  4. fwrite($fp, $content . "\n");
  5. fclose($fp);
  6. clearstatcache();
  7. }
  8. ?>
复制代码

主要的HTTP长连接部分,chat_content.php文件:

  1. header('cache-control: private');

  2. header('Content-Type: text/html; charset=utf-8');
  3. //测试设置30秒超时,一般会设置比较长时间。
  4. set_time_limit(30);
  5. //这一行是为了搞定IE这个BT
  6. echo str_repeat(' ', 256);
  7. ob_flush();

  8. flush();
  9. $fp = new SplFileObject('./chat.txt', 'r+');

  10. $line = 0;
  11. $totalLine = 0;
  12. while (!$fp->eof()) {
  13. $fp->current();
  14. $totalLine++;
  15. $fp->next();
  16. }
  17. $fp->seek($totalLine);

  18. $i = $totalLine - 1;
  19. while (true) {
  20. if (!$fp->eof()) {
  21. if ($content = trim($fp->current())) {
  22. echo '
    ';
  23. echo htmlspecialchars($content);
  24. echo "
";
  • flush();
  • $fp->next();
  • $i++;
  • }
  • } else {
  • $fp->seek($i - 1);
  • $fp->next();
  • }
  • {
  • //这里可以添加心跳检测后退出循环
  • }
  • usleep(1000);
  • }
  • ?>
  • 复制代码

    代码说明:   06. 设置一个超时时间,由于要保持HTTP长连接,这个时间肯定要比较长,可能要几个小时吧,上面提到的文章里也有说明,这种HTTP长连接只能打开两个,由于浏览器的限制。另外 其实即使你设置了一个永不超时,其实上服务器部分(如Apache)的配置文件也可能对HTTP请求设置了最长等待时间,所以也可能效果会不是你想的,一般默认可能都是15分钟超时。如果 有兴趣可以自己尝试修改。

      09. 这里输出了一段空白,主要是手册上已经说明了,IE浏览器在前面256个字符是不会直接输出的,所以我们先随便输出些空白,以便让后面的内容输出来,可能其他浏览器也有其他 浏览器的设置,具体可以查看PHP手册的frush函数的说明。接下去11、12行就是强制把这些空白符丢给浏览器输出。

      13. ~ 20. 这里主要是为了计算文件行数,以便从这一行后面开始读内容。

      接下去的while循环就是一个死循环了,就是循环输出文件内容,每次判断是否到达文件末尾,如果有用户写入文件,则当前检测肯定不是文件末尾,就将该行读取出来输出,否则将指 针往前移动一行,继续循环,每次等待1000微秒,

      39. 如果一直保持长连接,那么即使客户端断开,服务端也不一定能知道客户端已经断开,所以这里可能还需要做一些心跳记录,比如每个用户保持一个心跳flag,每格几秒更新一下 最后心跳时间,当检测最后时间很久没更新后,推出这个死循环,关闭这个HTTP连接。

    演示示例2: 传统的B/S结构的应用程序,都是采用\"客户端拉\"结束来实现客户端和服务器端的数据交换。 本文将通过结合Ticks,来实现一个服务器推的PHP聊天室简单构想。

    PHPer,尤其是用过set_cookie, header的,一定见过这样的提示信息:\"Warning: Cannot modify header information - headers already sent by.....\", 这是因为通过HTTP协议通信 ,数据包会包含俩个部分,一个是Header,一个是data。 一般来说,都是先Header部分,在Heaer部分指明了Data部分的长度,然后使用\\r\\n\\r\\n来表示header部分结束,接下来是Data部分。

    当有任何输出时,Header部分就发送了,此时,再想header函数来改变一些Header部分的域信息,就会得到上面的提示信息。 一个简单的办法就是使用output_buffering。让它来缓存服务器的输出,不要太早将Header部分发给客户端。 那么,如果不使用output_buffering,是不是就可以实现,每当服务器有输出,就立即发送给客户端呢? 做个如下试验:

    1. //设置php.ini中output_buffering=0 或者使用ob_end_flush()关闭缓存
    2. set_time_limit(0);
    3. for($i=0;$i echo \"Now Index is :\". $i;
    4. sleep(1);
    5. }
    6. ?>
    复制代码

    结果发现,还是要等到脚本全部执行完以后,才能一次看到所有的结果。为什么呢? 这是因为只是解决了缓存问题,但是还有一个缓冲问题,PHP会缓冲程序的输出。 所以,此时还需要调用,flush(), 来强制使得PHP将所有的程序输出发送给客户端。

    1. //设置php.ini中output_buffering=0

    2. ob_end_flush();//关闭缓存
    3. set_time_limit(0);

    4. for($i=0;$i echo \"Now Index is :\". $i;
    5. flush();
    6. sleep(1);
    7. }
    8. ?>
    复制代码

    现在是不是看到了,不断有服务器的数据显示出来?

    有几个概念之间的关系,这里补充下: 在代码中使用ob_start(), 就相当于在php.ini中使用output_buffering=on一样,使用服务器缓存。 在代码中使用ob_end_flush() 就相当于在php.ini中使用output_buffering = false一样,关闭服务器缓存。 1 2 下一页 尾页



    Déclaration:
    Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn