4种PHP异步执行的常用方式

异步执行的概念

在传统的 PHP 程序中，代码是同步执行的，也就是一行一行地执行，在执行完一行代码之后，才会去执行下一行代码。这种方式通常是顺序执行的，如果这条代码很耗时，程序就会停滞在这里，不能做其他的事情。

而异步执行则是指一种非阻塞的操作，也就是在执行某个操作的时候，不会阻塞后面的代码执行。例如，在后台执行一个任务的时候，我们可以异步执行该任务，使得程序可以在执行该任务的同时，继续执行后面的代码。

4种PHP异步执行的常用方式

2.1. Callback

在 PHP 中，可以通过回调函数来实现异步执行。这种方式通常是在程序中注册一个回调函数，当某个条件满足时，就会调用这个函数。举个例子，我们可以使用 socket 编程来实现一个 HTTP 客户端，如下代码：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 
socket_connect($socket, "127.0.0.1", 80); 
$packet = "GET /index.html HTTP/1.1\r\n";
socket_send($socket, $packet, strlen($packet), MSG_EOF); 
socket_recv($socket, $data, 1024, 0); 
socket_close($socket); 
echo $data;

上面的代码时同步执行的，如果在这个 HTTP 请求是一个耗时的操作，那么程序会等待它执行完成后才会继续执行后面的代码。为了避免这种阻塞，我们可以使用回调函数。如下：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 
socket_connect($socket, "127.0.0.1", 80); 
$packet = "GET /index.html HTTP/1.1\r\n";
socket_send($socket, $packet, strlen($packet), MSG_EOF); 

socket_set_nonblock($socket);
$read = [$socket];
$result = socket_select($read, [], [], 5);
if ($result === false) {
    echo "select failed";
} elseif ($result > 0) {
    $data = "";
    while ($out = socket_read($socket, 1024)) {
        $data .= $out;
    }
    echo $data;
}
socket_close($socket);

这段代码中，我们使用了 socket_set_nonblock 将 socket 设置为非阻塞模式，使用 socket_select 实现异步读取数据，当数据读取完毕时会调用回调函数。

2.2. Coroutine

Coroutine 是一种非常强大的异步执行方式，它是通过调度器来实现的。当某个语句执行到 yield 时，执行器会将控制权交给另外一个协程，当异步操作完成后，执行器会将控制权返回给之前的协程。

function asyncFunction($name, $time) {
    echo "Async {$name} start!\n";
    yield waitFor($time);
    echo "Async {$name} end!\n";
}

function waitFor($time) {
    $time = microtime(true) + $time * 0.001;
    while (microtime(true) < $time) {
        yield;
    }
}

$coroutine = asyncFunction("task1", 3000);
$coroutine2 = asyncFunction("task2", 2000);

while (true) {
    $coroutine->current();
    $coroutine2->current();
    if ($coroutine->valid() === false && $coroutine2->valid() === false) {
        break;
    }
}

上面的代码中，我们使用了 yield 和 while 来实现一个简单的异步操作。我们先执行 asyncFunction，然后用 yield 表示等待 waitFor 函数返回，这样就可以在该操作执行的过程中，执行其他的代码。最后，我们使用一个简单的 while 循环来实现调度器，切换两个协程，使得程序可以异步执行。

2.3. Event-Driven

事件驱动是一种基于事件的异步执行方式，它是通过监听事件来实现的。当某个事件触发时，相应的回调函数就会被触发。下面是一个使用 PHP 的 Event 扩展示例代码：

$base = new EventBase();
$event = new Event($base, $fd, Event::READ | Event::PERSIST, function ($fd) {
    $buffer = "";
    while (true) {
        $data = stream_socket_recvfrom($fd, 1024, 0, $peer);
        if (empty($data)) {
            break;
        }
        $buffer .= $data;
    }
    echo $buffer;
}, $fd);
if (!$event->add()) {
    echo "error: failed to add event\n";
    return;
}
$base->dispatch();

在这个例子中，我们创建了一个 EventBase，并且添加了一个 Event 事件来监听 $fd 文件句柄，当数据读取完成时，相应的回调函数就会被触发。最后，我们调用 $base->dispatch() 函数来启动事件循环，使程序可以一直运行。

2.4. Message Queue

消息队列是一种基于消息通信的异步执行方式，它通常是通过创建一个或多个队列，来实现消息的传递和接收。下面是一个 Redis 的队列示例代码：

$redis = new Redis();
$redis->connect("127.0.0.1", 6379);
$redis->delete("queue");
for ($i = 0; $i < 10; $i++) {
    $redis->lpush("queue", $i);
}
while (true) {
    $res = $redis->blpop("queue", 5);
    if ($res === null) {
        break;
    }
    echo $res[1] . "\n";
}

在上面的代码中，我们创建了一个 Redis 的队列，然后将0~9的数字依次推入队列中。然后，我们使用 blpop 函数来执行非阻塞的读取操作，当没有数据时，程序会继续执行后面的代码。