PHP写的异步高并发服务器,基于libevent

时间:2022-09-01 13:00:57

本文章于2013年11月修改。

swoole已使用C重写作为PHP扩展来运行。项目地址:https://github.com/matyhtf/swoole

swoole提供了PHP的高性能Server,异步IO,AsyncMySQL等特性。

原PHP代码框架迁移至https://github.com/matyhtf/swoole_framework。保留原有代码和web框架。

--------------------------------------------------------------------------------------------------

Swoole Socket网络开发框架,是基于php的libevent和pcntl模块的,并且只能用于Linux/Unix系统下。请先启用pcntl,安装libevent扩展。

pcntl:PHP核心模块已包含了pcntl,只需在编译时加入--enable-pcntl即可,当然也可以用extension扩展

libevent:http://pecl.php.net/package/libevent

编写的类需要继承自TCPServer类,在SwooleSocket包中。目前只提供了单进程异步事件模型,适合用于IO耗时较少的网络服务器程序,比如聊天室。多进程异步模型,多进程同步模型,会在近期提供。基类的代码,请从http://code.google.com/p/swoole/检出

  1. <?php
  2. require 'TCPServer.php';
  3. class MyServer extends TCPServer
  4. {
  5. function onRecive($client_id,$data)
  6. {
  7. $data = trim($data);
  8. if($data=="quit")
  9. {
  10. $this->close($client_id);
  11. return true;
  12. }
  13. elseif($data=='shutdown')
  14. {
  15. $this->shutdown();
  16. }
  17. else
  18. {
  19. $client_socket_name =  stream_socket_get_name($this->client_sock[$client_id],true);
  20. echo "Server send response data to client $client_socket_name\n";
  21. $send = date('Y-m-d H:i:s')."$client_socket_name said:$data\n";
  22. $this->sendAll($client_id,$send);
  23. }
  24. }
  25. /**
  26. * 发送到所有客户端
  27. * @param $data
  28. * @return unknown_type
  29. */
  30. function sendAll($client_id,$data)
  31. {
  32. foreach($this->client_sock as $k=>$sock)
  33. {
  34. if($k==$client_id) continue;
  35. fwrite($sock,$data);
  36. }
  37. }
  38. /**
  39. * 发送到某个客户端
  40. * @param $client_id
  41. * @param $data
  42. * @return unknown_type
  43. */
  44. function sendTo($client_id,$data)
  45. {
  46. fwrite($this->client_sock[$client_id],$data);
  47. }
  48. function onStart()
  49. {
  50. echo "Server in running!\n";
  51. }
  52. function onConnect($client_id)
  53. {
  54. $this->sendAll($client_id,"Client $client_id is connected!\n");
  55. }
  56. function onClose($client_id)
  57. {
  58. $this->sendAll($client_id,"Client $client_id is closed!\n");
  59. }
  60. function onShutdown()
  61. {
  62. echo "Server in stop!\n";
  63. }
  64. }
  65. $server = new MyServer('0.0.0.0',8005);
  66. $server->run();

客户端程序

  1. <?php
  2. class Stdio
  3. {
  4. static $in;
  5. static $out;
  6. static $buffer_size = 1024;
  7. static function input($h='')
  8. {
  9. if(!self::$in) self::$in = fopen('php://stdin','r');
  10. if($h) self::output($h);
  11. return trim(fread(self::$in,self::$buffer_size));
  12. }
  13. static function output($string)
  14. {
  15. if(!self::$out) self::$out = fopen('php://stdout','w');
  16. return fwrite(self::$out,$string);
  17. }
  18. }
  19. $fp = stream_socket_client('tcp://127.0.0.1:8005',$errno, $errstr);
  20. $socket = serialize($fp);
  21. if(!$fp)
  22. {
  23. echo "ERROR: $errno - $errstr<br />\n";
  24. }
  25. else
  26. {
  27. $pid = pcntl_fork();
  28. if($pid==-1)
  29. {
  30. exit("fork fail!\n");
  31. }
  32. //child
  33. elseif($pid==0)
  34. {
  35. var_dump($socket);
  36. $fp2 = unserialize($socket);
  37. while(!feof($fp2))
  38. {
  39. Stdio::output(fgets($fp2, 1024));
  40. }
  41. }
  42. //parent
  43. else
  44. {
  45. while($string!=="quit")
  46. {
  47. if(!is_writable($fp)) break;
  48. $string = Stdio::input("qq#");
  49. fwrite($fp,$string);
  50. }
  51. posix_kill($pid, 9);
  52. }
  53. fclose($fp);
  54. }

php tcpserver.php 运行服务器程序

php tcpclient.php 运行客户端程序,客户端有2个进程,主进程负责接收输入信息,发送到网络。另一个进程,接收网络信息,显示在屏幕上。

PHP写的异步高并发服务器,基于libevent的更多相关文章

  1. JAVA NIO non-blocking模式实现高并发服务器(转)

    原文链接:JAVA NIO non-blocking模式实现高并发服务器 Java自1.4以后,加入了新IO特性,NIO. 号称new IO. NIO带来了non-blocking特性. 这篇文章主要 ...

  2. 第15章 高并发服务器编程(2)&lowbar;I&sol;O多路复用

    3. I/O多路复用:select函数 3.1 I/O多路复用简介 (1)通信领域的时分多路复用 (2)I/O多路复用(I/O multiplexing) ①同一线程,通过“拨开关”方式,来同时处理多 ...

  3. JAVA NIO non-blocking模式实现高并发服务器

    JAVA NIO non-blocking模式实现高并发服务器 分类: JAVA NIO2014-04-14 11:12 1912人阅读 评论(0) 收藏 举报 目录(?)[+] Java自1.4以后 ...

  4. linux学习之高并发服务器篇(二)

    高并发服务器 1.线程池并发服务器 两种模型: 预先创建阻塞于accept多线程,使用互斥锁上锁保护accept(减少了每次创建线程的开销) 预先创建多线程,由主线程调用accept 线程池 3.多路 ...

  5. 第15章 高并发服务器编程(1)&lowbar;非阻塞I&sol;O模型

    1. 高性能I/O (1)通常,recv函数没有数据可用时会阻塞等待.同样,当socket发送缓冲区没有足够多空间来发送消息时,函数send会阻塞. (2)当socket在非阻塞模式下,这些函数不会阻 ...

  6. Linux &plus; C &plus; Epoll实现高并发服务器&lpar;线程池 &plus; 数据库连接池&rpar;&lpar;转&rpar;

    转自:http://blog.csdn.net/wuyuxing24/article/details/48758927 一, 背景 先说下我要实现的功能,server端一直在linux平台下面跑,当客 ...

  7. 高并发服务器建议调小 TCP 协议的 time&lowbar;wait 超时时间。

    1. [推荐]高并发服务器建议调小 TCP 协议的 time_wait 超时时间. 说明:操作系统默认 240 秒后,才会关闭处于 time_wait 状态的连接,在高并发访问下,服 务器端会因为处于 ...

  8. 为一个支持GPRS的硬件设备搭建一台高并发服务器用什么开发比较容易?

    高并发服务器开发,硬件socket发送数据至服务器,服务器对数据进行判断,需要实现心跳以保持长连接. 同时还要接收另外一台服务器的消支付成功消息,接收到消息后控制硬件执行操作. 查了一些资料,java ...

  9. linux学习之多高并发服务器篇(一)

    高并发服务器 高并发服务器 并发服务器开发 1.多进程并发服务器 使用多进程并发服务器时要考虑以下几点: 父最大文件描述个数(父进程中需要close关闭accept返回的新文件描述符) 系统内创建进程 ...

随机推荐

  1. timus&lowbar;1007&lowbar;bfs

    图像编码 题目描述: 有这样一副图,它有黑白像素,黑像素的坐标在1-10之间.有很多种方法来编码这个图.例如下面的图: 一种表示方法是只描述黑像素,并按x坐标的增序描述,如果x相同,则按y的增序描述, ...

  2. cpp异常详解

    1. 异常介绍 在函数在执行过程中如果碰到对错误的处理可以有两种方式, 1. 返回错误,2. 使用异常. 如果作为函数的调用者想要知道具体的错误信息, 就需要维护一套错误列表, 或者用string类型 ...

  3. jQuery中ajax应用

    一:Ajax介绍 1.ajax的定义:客服端js所发起的http请求的代号,无刷新的数据更新. 2.ajax原理: 运用XHTML+CSS来表达信息,运用javascript操作DOM(Documen ...

  4. K-Modes算法&lbrack;聚类算法&rsqb;

    聚类算法k-Modes的实现 <?php /* *Kmodes算法(聚类算法的实现) */ /* *获取簇的数目 */ //----------------------------------- ...

  5. php中的XML转数组

    /** * 最简单的XML转数组 * @param string $xmlstring XML字符串 * @return array XML数组 */ function simplest_xml_to ...

  6. 在Eclipse 中集成SVN

    在项目开发的过程中,我们需要用到版本控制工具,最常见的也就是SVN了,下面就来介绍最简单的一种在Elipse中集成svn工具. 第一步:下载 svn包,如site-1.6.5.zip或者site-1. ...

  7. &lbrack;转帖&rsqb;十二 个经典 Linux 进程管理命令介绍

    https://www.cnblogs.com/swordxia/p/4550825.html 接了 http referer 头 没法显示图片 可以去原始blog 里面去查看.   随笔- 109  ...

  8. 纯CSS制作图形效果

    下面所有的例子都是在demo.html的基础上添加相关样式实现的. <!DOCTYPE html> <html> <head> <meta charset=& ...

  9. pyEcharts

    例子: from pyecharts import Line line = Line("我的第一个图表", "这里是副标题",width="800px ...

  10. 终极利器!利用appium和mitmproxy登录获取cookies

    环境搭建 参考我之前写的https://www.cnblogs.com/c-x-a/p/9163221.html appium 代码start_appium.py # -*- coding: utf- ...