Swoole，PHP语言的高性能网络通信框架

优势

• 纯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.
";
});
$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.
";
});
$serv->start();

Client

$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
//设置事件回调函数
$client->on("connect", function($cli) {
    $cli->send("hello world
");
});
$client->on("receive", function($cli, $data){
    echo "Received: ".$data."
";
});
$client->on("error", function($cli){
    echo "Connect failed
";
});
$client->on("close", function($cli){
    echo "Connection close
";
});
//发起网络连接
$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)
");
}
$http_request = "GET /index.html HTTP/1.1
";
$http_request .= "Host: localhost

";
fwrite($fp, $http_request);
swoole_event_add($fp, function($fp){
    echo fread($fp, 8192);
    swoole_event_del($fp);
    fclose($fp);
});
echo "http response:
";
//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
";
});
$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();