Swoole 教程

swoole是什么？

Swoole是一個(gè)PHP的C擴(kuò)展，可用來(lái)開發(fā)PHP的高性能高并發(fā)TCP/UDP Server。Swoole的網(wǎng)絡(luò)IO部分基于epoll/kqueue事件循環(huán)，是全異步非阻塞的。 業(yè)務(wù)邏輯部分使用多進(jìn)程同步阻塞方式來(lái)運(yùn)行。這樣既保證了Server能夠應(yīng)對(duì)高并發(fā)和大量TCP連接。又保證業(yè)務(wù)代碼仍然可以簡(jiǎn)單的編寫。

Swoole1.6.2之后增加了異步支持，應(yīng)用程序也可以像node.js一樣寫異步回調(diào)。

Swoole與Node.js相比更強(qiáng)大，支持同步/異步、多進(jìn)程并行，Swoole提供了進(jìn)程生命周期管理、內(nèi)存保護(hù)機(jī)制，開發(fā)者無(wú)需考慮底層細(xì)節(jié)，專注于業(yè)務(wù)邏輯和功能的開發(fā)。

Swoole底層內(nèi)置了異步非阻塞、多線程的網(wǎng)絡(luò)IO服務(wù)器。PHP程序員僅需處理事件回調(diào)即可，無(wú)需關(guān)心底層。與Nginx/Tornado/Node.js等全異步的框架不同，Swoole既支持全異步，也支持同步。

Swoole從2.0版本開始支持了內(nèi)置協(xié)程，可以使用完全同步的代碼實(shí)現(xiàn)異步程序。PHP代碼無(wú)需額外增加任何關(guān)鍵詞，底層自動(dòng)進(jìn)行協(xié)程調(diào)度，實(shí)現(xiàn)異步。

Swoole是開源免費(fèi)的自由軟件，授權(quán)協(xié)議是Apache2.0。企業(yè)和開發(fā)者均可免費(fèi)使用Swoole的代碼，并且在Swoole之上所作的修改無(wú)需開源。

Swoole官網(wǎng)地址：http://www.swoole.com/

優(yōu)勢(shì)

• 純C編寫性能極強(qiáng)
• 簡(jiǎn)單易用開發(fā)效率高
• 事件驅(qū)動(dòng)異步非阻塞
• 并發(fā)百萬(wàn)TCP連接
• TCP/UDP/UnixSock
• 服務(wù)器端/客戶端
• 全異步/半異步半同步
• 支持多進(jìn)程/多線程
• CPU親和性/守護(hù)進(jìn)程
• 支持IPv4/IPv6網(wǎng)絡(luò)

Swoole HttpServer實(shí)現(xiàn)示例：

$serv = new Swoole\Http\Server("127.0.0.1", 9502);

$serv->on('Request', function($request, $response) {
    var_dump($request->get);
    var_dump($request->post);
    var_dump($request->cookie);
    var_dump($request->files);
    var_dump($request->header);
    var_dump($request->server);

    $response->cookie("User", "Swoole");
    $response->header("X-Server", "Swoole");
    $response->end("<h1>Hello Swoole!</h1>");
});

$serv->start();

Swoole WebSocket Server實(shí)現(xiàn)示例：

$serv = new Swoole\Websocket\Server("127.0.0.1", 9502);

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

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

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

$serv->start();

Swoole TCP Server實(shí)現(xiàn)示例：

$serv = new Swoole\Server("127.0.0.1", 9501);
$serv->set(array(
    'worker_num' => 8,   //工作進(jìn)程數(shù)量
    'daemonize' => true, //是否作為守護(hù)進(jìn)程
));
$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();

Swoole TCP Client實(shí)現(xiàn)示例：

$client = new Swoole\Client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
//設(shè)置事件回調(diào)函數(shù)
$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";
});
//發(fā)起網(wǎng)絡(luò)連接
$client->connect('127.0.0.1', 9501, 0.5);

Swoole 異步MySQL實(shí)現(xiàn)示例

$db = new Swoole\MySQL;
$server = array(
    'host' => '127.0.0.1',
    'user' => 'test',
    'password' => 'test',
    'database' => 'test',
);

$db->connect($server, function ($db, $result) {
    $db->query("show tables", function (Swoole\MySQL $db, $result) {
        if ($result === false) {
            var_dump($db->error, $db->errno);
        } elseif ($result === true) {
            var_dump($db->affected_rows, $db->insert_id);
        } else {
            var_dump($result);
            $db->close();
        }
    });
});

Swoole 異步Redis/異步Http客戶端實(shí)現(xiàn)示例

$redis = new Swoole\Redis;
$redis->connect('127.0.0.1', 6379, function ($redis, $result) {
    $redis->set('test_key', 'value', function ($redis, $result) {
        $redis->get('test_key', function ($redis, $result) {
            var_dump($result);
        });
    });
});

$cli = new Swoole\Http\Client('127.0.0.1', 80);
$cli->setHeaders(array('User-Agent' => 'swoole-http-client'));
$cli->setCookies(array('test' => 'value'));

$cli->post('/dump.php', array("test" => 'abc'), function ($cli) {
    var_dump($cli->body);
    $cli->get('/index.php', function ($cli) {
        var_dump($cli->cookies);
        var_dump($cli->headers);
    });
});

Swoole Async-IO實(shí)現(xiàn)示例

$fp = stream_socket_client("tcp://127.0.0.1:80", $code, $msg, 3);
$http_request = "GET /index.html HTTP/1.1\r\n\r\n";
fwrite($fp, $http_request);
Swoole\Event::add($fp, function($fp){
    echo fread($fp, 8192);
    swoole_event_del($fp);
    fclose($fp);
});
Swoole\Timer::after(2000, function() {
    echo "2000ms timeout\n";
});
Swoole\Timer::tick(1000, function() {
    echo "1000ms interval\n";
});

Swoole 異步任務(wù)實(shí)現(xiàn)示例：

$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();

案例

swoole目前已被多家移動(dòng)互聯(lián)網(wǎng)、物聯(lián)網(wǎng)、網(wǎng)絡(luò)游戲、手機(jī)游戲企業(yè)使用，替代了C++、Java等復(fù)雜編程語(yǔ)言來(lái)實(shí)現(xiàn)網(wǎng)絡(luò)服務(wù)器程序。 使用PHP+Swoole，開發(fā)效率可以大大提升。官方提供了基于swoole擴(kuò)展開發(fā)的PHP網(wǎng)絡(luò)框架， 支持Http，F(xiàn)astCGI，WebSocket，F(xiàn)TP，SMTP，RPC等網(wǎng)絡(luò)協(xié)議 swoole在美國(guó)，英國(guó)，法國(guó)，印度等國(guó)家都有用戶分布，在國(guó)內(nèi)的 騰訊、百度、阿里巴巴、YY語(yǔ)音等多家知名互聯(lián)網(wǎng)公司均有使用。

 版權(quán)說(shuō)明：本教程內(nèi)容來(lái)源：Swoole開源社區(qū)