swoole redis如何使用 - 问答

Swoole是一个高性能的PHP扩展，它提供了异步并发、协程、WebSocket等功能

安装Swoole和Redis扩展：

首先，确保你已经安装了Swoole扩展。如果没有，请参考Swoole官方文档进行安装。接下来，安装Redis扩展。在命令行中运行以下命令：

pecl install redis

然后，在php.ini文件中添加以下行以启用Redis扩展：

extension=redis.so

创建一个PHP文件（例如：swoole_redis_example.php），并编写以下代码：

<?php
// 创建一个Swoole协程服务器
$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);

// 监听WebSocket连接打开事件
$server->on('open', function (Swoole\WebSocket\Server $server, $request) {
    echo "客户端 {$request->fd} 成功建立连接。\n";
});

// 监听WebSocket消息事件
$server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
    $data = json_decode($frame->data, true);
    $key = $data['key'];
    $value = $data['value'];

    // 使用Redis扩展将数据存储到Redis中
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->set($key, $value);
    $redis->close();

    // 将存储结果返回给客户端
    $server->push($frame->fd, json_encode(['status' => 'success', 'message' => '数据已存储到Redis中']));
});

// 监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "客户端 {$fd} 断开连接。\n";
});

// 启动服务器
$server->start();

运行Swoole协程服务器：

在命令行中，使用以下命令运行PHP文件：

php swoole_redis_example.php

现在，你的Swoole协程服务器已经在监听9501端口。你可以使用WebSocket客户端连接到服务器，并发送包含key和value的请求。服务器将使用Redis扩展将数据存储到Redis中，并将结果返回给客户端。

注意：在实际应用中，你可能需要根据实际情况调整代码，例如使用协程版本的Redis客户端库（如Swoole\Coroutine\Redis），并处理可能的异常。

0 赞

0 踩