Swoole的HTTP服务怎么用？HTTP请求如何处理？-Swoole-PHP中文网

Swoole的HTTP服务怎么用？HTTP请求如何处理？

畫卷琴夢

发布： 2025-08-14 23:44:01

原创

635人浏览过

Swoole的HTTP服务通过异步非阻塞模式提升PHP性能，需先安装Swoole扩展，再创建Server实例并监听端口；通过$request和$response对象处理请求与响应，支持GET/POST参数及JSON解析；静态资源可通过文件读取或反向代理实现；使用kill -USR1平滑重启；Session可借助Redis管理；错误通过onError事件和try-catch捕获处理。

swoole的http服务怎么用？http请求如何处理？

Swoole的HTTP服务，说白了，就是让你用PHP写出高性能的Web应用。它接管了底层的网络通信，你只需要关注业务逻辑，HTTP请求的处理也变得相当简单。

直接上解决方案，别绕弯子。

首先，你需要安装Swoole扩展，这个是前提。然后，就可以开始写代码了。

<?php
$http = new Swoole\Http\Server("0.0.0.0", 9501);

$http->on("request", function ($request, $response) {
    // 处理HTTP请求
    $response->header("Content-Type", "text/plain");
    $response->end("Hello World\n");
});

$http->start();

登录后复制

这段代码创建了一个HTTP服务器，监听9501端口。当有HTTP请求过来时，

request

登录后复制

事件会被触发。你可以在这个事件的回调函数里处理请求，并发送响应。

$request

登录后复制

对象包含了请求的所有信息，比如GET、POST参数，Header等等。

$response

登录后复制

对象用于发送响应，你可以设置Header，Body，Status Code等等。

Swoole的HTTP服务器是异步非阻塞的，这意味着它可以同时处理多个请求，而不会被阻塞。这使得它比传统的PHP-FPM模式更加高效。

如何获取HTTP请求的参数？

Swoole的

$request

登录后复制

对象提供了访问HTTP请求参数的方法。GET参数可以通过

$request->get

登录后复制

访问，POST参数可以通过

$request->post

登录后复制

访问。如果请求体是JSON格式，你可以通过

$request->rawContent()

登录后复制

获取原始数据，然后使用

json_decode()

登录后复制

解析。

$http->on("request", function ($request, $response) {
    $name = $request->get['name'] ?? 'Guest'; // 获取GET参数
    $data = $request->post['data'] ?? null;   // 获取POST参数

    $raw = $request->rawContent(); // 获取原始请求体
    $json = json_decode($raw, true); // 解析JSON

    $response->header("Content-Type", "text/plain");
    $response->end("Hello, " . $name . "!\n" . "Data: " . ($data ?? 'No data') . "\n" . "JSON: " . print_r($json, true));
});

登录后复制

注意，如果你的请求头里包含了

Content-Type: application/json

登录后复制

，Swoole并不会自动解析JSON数据，你需要手动解析。

Swoole HTTP服务如何处理静态资源？

Swoole本身并不擅长处理静态资源，因为它更适合处理动态请求。但是，你可以通过一些技巧来让它处理静态资源。一个简单的方法是，判断请求的URL是否指向静态资源，如果是，就读取文件内容并返回。

$documentRoot = '/path/to/your/static/files';

$http->on("request", function ($request, $response) use ($documentRoot) {
    $path = $request->server['request_uri'];
    $filePath = $documentRoot . $path;

    if (file_exists($filePath) && is_file($filePath)) {
        $ext = pathinfo($filePath, PATHINFO_EXTENSION);
        $mimeType = getMimeType($ext); // 自己实现一个getMimeType函数
        $response->header("Content-Type", $mimeType);
        $response->sendfile($filePath);
        return;
    }

    // 处理动态请求
    $response->header("Content-Type", "text/plain");
    $response->end("Hello World\n");
});

登录后复制

这个方法很简单，但是效率不高。更好的方法是使用Nginx或Apache等Web服务器来处理静态资源，然后将动态请求转发给Swoole处理。这种方式可以充分利用Nginx和Apache的静态资源处理能力，同时发挥Swoole的动态请求处理优势。

如何优雅地重启Swoole HTTP服务？

直接kill掉进程不是一个好的选择，因为它可能会导致正在处理的请求中断。Swoole提供了

reload

登录后复制

命令，可以平滑地重启服务。

在Linux系统中，你可以使用

kill -USR1 <pid>

登录后复制

命令来发送

USR1

登录后复制

信号给Swoole进程。Swoole收到这个信号后，会平滑地重启worker进程，而不会中断正在处理的请求。

kill -USR1 <pid>

登录后复制

其中

<pid>

登录后复制

是Swoole主进程的PID。你可以在Swoole的配置文件中设置

pid_file

登录后复制

选项，将PID写入到一个文件中，方便你获取PID。

AppMall应用商店

AI应用商店，提供即时交付、按需付费的人工智能应用服务

查看详情

需要注意的是，

reload

登录后复制

命令只会重启worker进程，不会重启manager进程。如果你修改了监听端口等配置，需要先停止服务，然后再启动。

另外，如果你使用了Task worker，你需要使用

kill -USR2 <pid>

登录后复制

命令来重启Task worker进程。

Swoole HTTP服务如何处理Session？

Swoole本身并没有内置Session管理功能。你需要自己实现Session管理。一个简单的方法是将Session数据存储在Redis或Memcached等缓存系统中。

use Swoole\Http\Request;
use Swoole\Http\Response;

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$http->on("request", function (Request $request, Response $response) use ($redis) {
    $sessionId = $request->cookie['session_id'] ?? uniqid();
    $sessionData = $redis->get('session:' . $sessionId);

    if ($sessionData) {
        $session = unserialize($sessionData);
    } else {
        $session = [];
    }

    // 处理Session数据
    $session['views'] = ($session['views'] ?? 0) + 1;

    $redis->set('session:' . $sessionId, serialize($session), 3600); // Session过期时间为1小时
    $response->cookie('session_id', $sessionId, time() + 3600);

    $response->header("Content-Type", "text/plain");
    $response->end("Views: " . $session['views'] . "\n");
});

登录后复制

这个例子中，我们使用Redis来存储Session数据。每次请求时，我们都会从Redis中读取Session数据，更新Session数据，然后将Session数据写回Redis。同时，我们使用Cookie来存储Session ID。

这种方法简单有效，但是需要你自己处理Session的过期时间、垃圾回收等问题。

如何处理Swoole HTTP服务的错误？

Swoole提供了

onError

登录后复制

事件，可以用来处理服务器的错误。

$http->on("error", function ($serv, $fd, $reactorId, $errorCode, $errorMessage) {
    echo "Error: " . $errorCode . " - " . $errorMessage . "\n";
});

登录后复制

这个事件会在服务器发生错误时被触发。你可以记录错误日志，或者发送报警邮件。

除了

onError

登录后复制

事件，你还可以在

request

登录后复制

事件中捕获异常。

$http->on("request", function ($request, $response) {
    try {
        // 处理请求
        $response->header("Content-Type", "text/plain");
        $response->end("Hello World\n");
    } catch (\Exception $e) {
        // 处理异常
        $response->status(500);
        $response->header("Content-Type", "text/plain");
        $response->end("Error: " . $e->getMessage() . "\n");
    }
});

登录后复制

使用