基于Webman和Redis的
类Flarum论坛系统设计与实现

# 唯一性索引 (Set)
Key: usernames:index
Member: 用户名

Key: emails:index
Member: 邮箱

// config/session.php
return [
    'type' => 'redis',
    'handler' => \Webman\Session\RedisSessionHandler::class,
    'config' => [
        'host' => '127.0.0.1',
        'port' => 6379,
        'auth' => '',
        'database' => 1,
        'prefix' => 'webman_session_',
        'expire' => 3600 * 24,
    ],
];

验证Redis扩展

// config/redis.php
return [
    'default' => [
        'host' => '127.0.0.1',
        'password' => null,
        'port' => 6379,
        'database' => 0,
        'pool' => [
            'max_connections' => 10,
            'min_connections' => 1,
            'wait_timeout' => 3,
            'idle_timeout' => 50,
            'heartbeat_interval' => 50,
        ],
    ],
    
    // 可以配置多个Redis连接
    'cache' => [
        'host' => '127.0.0.1',
        'password' => null,
        'port' => 6379,
        'database' => 1,
    ],
];

class UserService
{
    // 用户注册
    public static function register($username, $email, $password)
    {
        $userId = self::generateUserId();
        $userKey = "user:$userId";
        
        $userData = [
            'username' => $username,
            'email' => $email,
            'password_hash' => password_hash($password, PASSWORD_DEFAULT),
            'created_at' => time(),
            'status' => 'active',
            'role' => 'member'
        ];
        
        Redis::hMset($userKey, $userData);
        
        // 更新索引
        Redis::sAdd('usernames:index', $username);
        Redis::sAdd('emails:index', $email);
        
        return $userId;
    }
}

class PostService
{
    public static function createPost($userId, $title, $content, $tagIds = [])
    {
        $postId = Redis::incr('global:post_id');
        $postKey = "post:$postId";
        $createdAt = time();
        
        $postData = [
            'id' => $postId,
            'user_id' => $userId,
            'title' => $title,
            'content' => $content,
            'created_at' => $createdAt,
            'updated_at' => $createdAt,
            'views_count' => 0,
            'likes_count' => 0,
            'comments_count' => 0,
            'tag_ids' => json_encode($tagIds)
        ];
        
        // 存储帖子详情到Hash
        Redis::hMset($postKey, $postData);
        
        // 添加到按时间排序的Sorted Set
        Redis::zAdd('posts:by_time', $createdAt, $postId);
        
        // 添加到用户发布的帖子Sorted Set
        Redis::zAdd("user_posts:$userId", $createdAt, $postId);
        
        // 处理标签关联
        foreach ($tagIds as $tagId) {
            Redis::sAdd("post_tags:$postId", $tagId);
            Redis::sAdd("tag_posts:$tagId", $postId);
            Redis::hIncrBy("tag:$tagId", 'post_count', 1);
        }
        
        return $postId;
    }
}

public static function getPostsByTime($page = 1, $perPage = 15)
{
    $start = ($page - 1) * $perPage;
    $end = $start + $perPage - 1;
    
    // 从Sorted Set获取帖子ID
    $postIds = Redis::zRevRange('posts:by_time', $start, $end);
    
    $posts = [];
    foreach ($postIds as $postId) {
        $post = self::getPost($postId);
        if ($post) {
            $posts[] = $post;
        }
    }
    
    // 获取总帖子数用于分页
    $total = Redis::zCard('posts:by_time');
    
    return [
        'posts' => $posts,
        'total' => $total,
        'last_page' => ceil($total / $perPage),
        'current_page' => $page,
        'per_page' => $perPage,
    ];
}

// config/route.php
use Webman\Route;

// WebSocket 路由
Route::websocket('/ws', \app\controller\WebSocketController::class);

// 也可以添加参数
Route::websocket('/ws/{user_id}', \app\controller\WebSocketController::class);

class WebSocketController extends Websocket
{
    protected static $userConnections = [];
    
    public function onConnect(TcpConnection $connection)
    {
        $userId = $_GET['user_id'] ?? 0;
        if ($userId) {
            self::$userConnections[$userId] = $connection;
            $connection->send(json_encode([
                'type' => 'welcome', 
                'message' => "Welcome, user {$userId}!"
            ]));
        }
    }
    
    public static function sendToUser($userId, $message)
    {
        if (isset(self::$userConnections[$userId])) {
            self::$userConnections[$userId]->send(json_encode($message));
        }
    }
}