當然可以!下面是一個簡單的 PHP 協程示例,使用了 Swoole 擴展。Swoole 是一個高性能的 PHP 異步編程框架,可以用于構建高并發的 Web 服務器和客戶端應用。
首先,確保已經安裝了 Swoole 擴展。在命令行中運行以下命令來安裝:
pecl install swoole
然后,在你的 PHP 項目中創建一個名為 coroutine_example.php
的文件,并添加以下代碼:
<?php
// 引入 Swoole 自動加載文件
require_once __DIR__ . '/vendor/autoload.php';
use Swoole\Coroutine;
use Swoole\Http\Server;
use Swoole\WebSocket\Server as WebSocketServer;
// 啟動一個簡單的 HTTP 服務器
$http = new Server('127.0.0.1:9501', 9501);
$http->on('Start', function (Server $server) {
echo "HTTP server is started at http://127.0.0.1:9501\n";
});
$http->on('Request', function (Server $server, $fd, $reactor_id, $data) {
$response = "Hello, this is a coroutine example.\n";
$server->send($fd, $response);
});
$http->start();
// 啟動一個簡單的 WebSocket 服務器
$websocket = new WebSocketServer('127.0.0.1:9502', 9502);
$websocket->on('Open', function (WebSocketServer $server, $request) {
echo "WebSocket server is started at ws://127.0.0.1:9502\n";
});
$websocket->on('Message', function (WebSocketServer $server, $frame) {
$response = "You sent: {$frame->data}\n";
$server->push($frame->fd, $response);
});
$websocket->start();
// 協程示例:并發執行任務
Coroutine::create(function () use ($http) {
while (true) {
$http->send('127.0.0.1:9501', 'Hello from coroutine!');
Coroutine::sleep(1);
}
});
Coroutine::create(function () use ($websocket) {
while (true) {
$websocket->push('127.0.0.1:9502', 'Hello from coroutine!');
Coroutine::sleep(1);
}
});
// 運行協程
Coroutine::run();
在這個示例中,我們創建了一個簡單的 HTTP 服務器和一個 WebSocket 服務器。然后,我們使用 Coroutine::create()
方法創建了兩個協程,它們分別向 HTTP 服務器和 WebSocket 服務器發送消息。最后,我們使用 Coroutine::run()
方法啟動協程。
要運行此示例,請確保已經安裝了 Swoole 擴展,然后在命令行中運行以下命令:
php coroutine_example.php
現在,你可以訪問 http://127.0.0.1:9501
和 ws://127.0.0.1:9502
來查看服務器響應。同時,你會在命令行中看到協程發送的消息。