Swoole可以让PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务。Swoole 可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网(IOT)、车联网、智能家居等领域。

Swoole简介

Swoole 使用纯 C 语言编写,提供了 PHP 语言的异步多线程服务器,异步 TCP/UDP 网络客户端,异步 MySQL,异步 Redis,数据库连接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,异步DNS查询。 Swoole内置了Http/WebSocket服务器端/客户端、Http2.0服务器端。

除了异步 IO 的支持之外,Swoole 为 PHP 多进程的模式设计了多个并发数据结构和IPC通信机制,可以大大简化多进程并发编程的工作。其中包括了并发原子计数器,并发 HashTable,Channel,Lock,进程间通信IPC等丰富的功能特性。

Swoole2.0 支持了类似 Go 语言的协程,可以使用完全同步的代码实现异步程序。PHP 代码无需额外增加任何关键词,底层自动进行协程调度,实现异步。

简单的说,Swoole增强了PHP的应用能力,以前PHP做不到的或者很难做到的,现在借助SWoole就能轻松实现。

Swoole是开源免费的,企业和个人开发者均可免费使用Swoole的代码。

源码编译安装

所需环境
  • CentOS7.4
  • PHP7.2
下载源码包

源码下载地址:https://github.com/swoole/swoole-src/releases。截至目前swoole已经发布了4.0版本了,我们给大家演示的是2.1版本的。

编译

接下来就是解压编译。注意PHP的安装路径请参照本站文章:CentOS7 源码编译安装PHP7.2。

tar -zxvf swoole-src-2.1.2.tar.gz
cd swoole-src-2.1.2
phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make 
make install
将Swoole加入到PHP中
echo 'extension=swoole.so' >> /usr/local/php/etc/php.ini
重启php-fpm
/etc/init.d/php-fpm restart
验证

输入命令:

php -m | grep swoole

如果返回swoole字样则安装成功。

或者使用phpinfo()函数,查看swoole是否安装成功。

应用示例

HTTP Server
<?php
$http = new swoole_http_server("127.0.0.1", 9501);

$http->on("start", function ($server) {
    echo "Swoole http server is started at http://127.0.0.1:9501n";
});

$http->on("request", function ($request, $response) {
    $response->header("Content-Type", "text/plain");
    $response->end("Hello Worldn");
});

$http->start();

WebSocket Server
<?php
$server = new swoole_websocket_server("127.0.0.1", 9502);

$server->on('open', function($server, $req) {
    echo "connection open: {$req->fd}n";
});

$server->on('message', function($server, $frame) {
    echo "received message: {$frame->data}n";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

$server->on('close', function($server, $fd) {
    echo "connection close: {$fd}n";
});

$server->start();

异步任务Task
<?php
$server = new swoole_server("127.0.0.1", 9502);
$server->set(array('task_worker_num' => 4));
$server->on('receive', function($server, $fd, $reactor_id, $data) {
    $task_id = $server->task("Async");
    echo "Dispath AsyncTask: [id=$task_id]n";
});
$server->on('task', function ($server, $task_id, $reactor_id, $data) {
    echo "New AsyncTask[id=$task_id]n";
    $server->finish("$data -> OK");
});
$server->on('finish', function ($server, $task_id, $data) {
    echo "AsyncTask[$task_id] finished: {$data}n";
});
$server->start();

更多有关Swoole的使用和手册请参考官网:https://www.swoole.com/

接下来我们会推出很多有关Swoole的使用实例,敬请关注。