使用Workerman构建高性能的游戏排行榜服务

composer require workerman/workerman

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;
use WorkermanConnectionAsyncTcpConnection;

$rankingServer = new Worker('tcp://0.0.0.0:2345');

$rankingServer->onWorkerStart = function ($rankingServer) {
    // 连接Redis
    $redis = new AsyncRedis();
    $redis->connect('127.0.0.1', 6379, function ($redis) use ($rankingServer) {
        // 监听游戏服务器事件
        $gameServer = new Worker();
        $gameServer->onWorkerStart = function ($gameServer) use ($redis) {
            // 监听游戏开始事件
            $gameServer->on('game_start', function ($connection, $data) use ($redis) {
                $playerId = $data['player_id'];
                $score = $data['score'];
                // 更新排行榜数据
                $redis->zincrby('game_ranking', $score, $playerId);
            });
            // 监听游戏结束事件
            $gameServer->on('game_end', function ($connection, $data) use ($redis) {
                $playerId = $data['player_id'];
                $score = $data['score'];
                // 更新排行榜数据
                $redis->zincrby('game_ranking', $score, $playerId);
            });
        };
        $gameServer->listen('tcp://0.0.0.0:1234');
    });
};

$rankingServer->runAll();