php协程案例能否分享 - 问答

当然可以！下面是一个简单的 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 来查看服务器响应。同时，你会在命令行中看到协程发送的消息。

0 赞

0 踩