PHP写的异步高并发服务器,基于libevent
2023-09-14 08:59:33 时间
本文章于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/检出
- <?php
- require 'TCPServer.php';
- class MyServer extends TCPServer
- {
- function onRecive($client_id,$data)
- {
- $data = trim($data);
- if($data=="quit")
- {
- $this->close($client_id);
- return true;
- }
- elseif($data=='shutdown')
- {
- $this->shutdown();
- }
- else
- {
- $client_socket_name = stream_socket_get_name($this->client_sock[$client_id],true);
- echo "Server send response data to client $client_socket_name\n";
- $send = date('Y-m-d H:i:s')."$client_socket_name said:$data\n";
- $this->sendAll($client_id,$send);
- }
- }
- /**
- * 发送到所有客户端
- * @param $data
- * @return unknown_type
- */
- function sendAll($client_id,$data)
- {
- foreach($this->client_sock as $k=>$sock)
- {
- if($k==$client_id) continue;
- fwrite($sock,$data);
- }
- }
- /**
- * 发送到某个客户端
- * @param $client_id
- * @param $data
- * @return unknown_type
- */
- function sendTo($client_id,$data)
- {
- fwrite($this->client_sock[$client_id],$data);
- }
- function onStart()
- {
- echo "Server in running!\n";
- }
- function onConnect($client_id)
- {
- $this->sendAll($client_id,"Client $client_id is connected!\n");
- }
- function onClose($client_id)
- {
- $this->sendAll($client_id,"Client $client_id is closed!\n");
- }
- function onShutdown()
- {
- echo "Server in stop!\n";
- }
- }
- $server = new MyServer('0.0.0.0',8005);
- $server->run();
客户端程序
- <?php
- class Stdio
- {
- static $in;
- static $out;
- static $buffer_size = 1024;
- static function input($h='')
- {
- if(!self::$in) self::$in = fopen('php://stdin','r');
- if($h) self::output($h);
- return trim(fread(self::$in,self::$buffer_size));
- }
- static function output($string)
- {
- if(!self::$out) self::$out = fopen('php://stdout','w');
- return fwrite(self::$out,$string);
- }
- }
- $fp = stream_socket_client('tcp://127.0.0.1:8005',$errno, $errstr);
- $socket = serialize($fp);
- if(!$fp)
- {
- echo "ERROR: $errno - $errstr<br />\n";
- }
- else
- {
- $pid = pcntl_fork();
- if($pid==-1)
- {
- exit("fork fail!\n");
- }
- //child
- elseif($pid==0)
- {
- var_dump($socket);
- $fp2 = unserialize($socket);
- while(!feof($fp2))
- {
- Stdio::output(fgets($fp2, 1024));
- }
- }
- //parent
- else
- {
- while($string!=="quit")
- {
- if(!is_writable($fp)) break;
- $string = Stdio::input("qq#");
- fwrite($fp,$string);
- }
- posix_kill($pid, 9);
- }
- fclose($fp);
- }
php tcpserver.php 运行服务器程序
php tcpclient.php 运行客户端程序,客户端有2个进程,主进程负责接收输入信息,发送到网络。另一个进程,接收网络信息,显示在屏幕上。
相关文章
- php 版本号 整数化 mysql存储入库 比较大小【版本处理类,提供版本与数字互相转换】
- php进程导致服务器cpu 100问题追查过程
- PHP Socket服务器搭建和测试
- PHP-FPM 与 Nginx 的通信机制总结
- PHP读取大文件的几种方法介绍
- PHP简单的图片上传
- PHP读取配置文件类(php,ini,yaml,xml)
- 比较全面的php session验证码与防识别
- php 数据库导入导出类
- 安装memcached服务器和PHP中添加memcache拓展模块
- 使用PHP类库PHPqrCode生成二维码
- php:用数组实现多语言(PHP 7.4.2)
- Nginx 0.8.x + PHP 5.2.13(FastCGI)搭建胜过Apache十倍的Web服务器(第6版)[原创]
- [转]PHP 真正多线程的使用
- Atitit 前端测试最简化内嵌web服务器 php 与node.js 目录 1.1. php内置Web Server1 1.2. Node的2 Node的比较麻烦些。。Php更加简单
- PHP面试题:php读取文件内容的几种方法和函数?
- PHP:echo,print,print_r,var_dump区别
- PHP上传文件(学习)
- 5. 通过PHP反序列化进行远程代码执行
- 安装PHP sphinx扩展 sphinx-1.1.0/sphinx.c:105:2: error: too few arguments 错误
- 统计php程序运行时间及设置PHP最长运行时间
- 高考后能学习——阿里云-winserver服务器购买以及使用(包含【.Net】、【PHP】、【MySQL】、【Navicat】、【Java】、安装)
- JS工具方法 3 js客户端与php服务器通信加密之AES