Swoole,PHP语言的高性能网络通信框架
2015-07-06 14:10
561 查看
优势
纯C编写性能极强简单易用开发效率高
事件驱动异步非阻塞
并发百万TCP连接
TCP/UDP/UnixSock
服务器端/客户端
全异步/半异步半同步
支持多进程/多线程
CPU亲和性/守护进程
支持IPv4/IPv6网络
案例
swoole目前已被多家移动互联网、物联网、网络游戏、手机游戏企业使用,替代了C++、Java等复杂编程语言来实现网络服务器程序。 使用PHP+Swoole,开发效率可以大大提升。官方提供了基于swoole扩展开发的PHP网络框架, 支持Http,FastCGI,WebSocket,FTP,SMTP,SOA等网络协议。
swoole在美国,英国,法国,印度等国家都有用户分布,在国内的腾讯、阿里、YY语音等多家知名互联网公司均有使用。
官方文档 http://wiki.swoole.com/wiki/page/1.html
Server
$serv = new swoole_server("127.0.0.1", 9501); $serv->set(array( 'worker_num' => 8, //工作进程数量 'daemonize' => true, //是否作为守护进程 )); $serv->on('connect', function ($serv, $fd){ echo "Client:Connect.\n"; }); $serv->on('receive', function ($serv, $fd, $from_id, $data) { $serv->send($fd, 'Swoole: '.$data); $serv->close($fd); }); $serv->on('close', function ($serv, $fd) { echo "Client: Close.\n"; }); $serv->start();
Client
$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC); //设置事件回调函数 $client->on("connect", function($cli) { $cli->send("hello world\n"); }); $client->on("receive", function($cli, $data){ echo "Received: ".$data."\n"; }); $client->on("error", function($cli){ echo "Connect failed\n"; }); $client->on("close", function($cli){ echo "Connection close\n"; }); //发起网络连接 $client->connect('127.0.0.1', 9501, 0.5);
Event
$fp = stream_socket_client("tcp://127.0.0.1:80", $code, $msg, 3); if (!$fp) { exit("$errstr ($errno)\n"); } $http_request = "GET /index.html HTTP/1.1\r\n"; $http_request .= "Host: localhost\r\n\r\n"; fwrite($fp, $http_request); swoole_event_add($fp, function($fp){ echo fread($fp, 8192); swoole_event_del($fp); fclose($fp); }); echo "http response:\n"; //swoole_event_wait(); //低于PHP5.4需要加swoole_event_wait
Task
$serv = new swoole_server("127.0.0.1", 9502); $serv->set(array('task_worker_num' => 4)); $serv->on('Receive', function($serv, $fd, $from_id, $data) { $task_id = $serv->task("Async"); echo "Dispath AsyncTask: id=$task_id\n"; }); $serv->on('Task', function ($serv, $task_id, $from_id, $data) { echo "New AsyncTask[id=$task_id]".PHP_EOL; $serv->finish("$data -> OK"); }); $serv->on('Finish', function ($serv, $task_id, $data) { echo "AsyncTask[$task_id] Finish: $data".PHP_EOL; }); $serv->start();
相关文章推荐
- boost http请求应用
- 网络路径查询traceroute
- https原理及tomcat配置https方法
- TCP/IP协议详解v1(第三章IP网际协议)
- TCP/IP协议详解v1(第二章数据链路层)
- TCP/IP协议详解v1(第一章概述)
- 【网络互联技术】(三) 网络互联基础。
- 【网络互联技术】(三) 网络互联基础。
- 使用netstat_-na查看网络连接_记录结果_并解释含义
- Servlet如何处理HTTP协议
- android动态注册监听网络变化异常
- ajax核心技术---XMLHttpRequset对象的使用
- 【Go】 http webserver
- Android通过tcpdump抓包
- 显示win7桌面网络.reg
- CNN卷积神经网络学习笔记3:权值更新公式推导
- keytool+tomcat配置HTTPS双向证书认证
- 常用的网络测试命令:
- 【Linux 内核网络协议栈源码剖析】数据包发送
- 一类判定性问题的网络流模型的构建