Utilisez Redis comme compteur pour améliorer le système de vote

Premier aperçu des scénarios d'application : il y a quelques années, il y avait de nombreux systèmes de vote dans WeChat. De nombreuses personnes recherchent des personnes parmi leurs amis ou leur cercle d’amis pour solliciter des votes. A cette époque, un parc d'attractions relativement grand organisait également cet événement de vote. Il semblait que si vous dépassiez un certain nombre de votes, vous pouviez jouer gratuitement. Mes amis m'ont également demandé de voter pour lui. Il semblait que je pouvais voter 3 ou 5 voix par jour, je ne me souviens pas clairement des détails. Après être entré dans le système, j'ai cliqué sur le bouton de vote de mon ami et j'ai constaté que rien ne s'était passé. Je pensais que c'était un problème avec mon réseau, mais plus tard j'ai découvert que c'était un problème avec le programme. J'ai deviné à l'époque qu'il y avait trop de gens qui votaient et que le système n'a pas pu y résister pendant un moment.

Parce qu'à cette époque, j'apprenais Redis. Donc, je pense que cette fonction peut être améliorée via le compteur de Redis.

Ici, nous comptons uniquement le nombre total de votes exprimés par les utilisateurs, sans tenir compte de la situation de vote spécifique des utilisateurs. Par exemple, nous ne prenons pas en compte le moment où A a voté pour B. Si vous envisagez cette situation, vous devez utiliser d'autres solutions (vous pouvez utiliser des files d'attente de messages).

Vérification

Tout d'abord, le nombre de votes de chaque utilisateur doit être vérifié. Les utilisateurs ont trois opportunités de voter chaque jour, nous pouvons donc créer une clé et fixer sa période de validité à demain matin. Chaque fois que l'utilisateur vote, 1 sera ajouté. Lorsque l'utilisateur atteint 3 votes, il sera informé que le nombre de votes a été utilisé aujourd'hui.

// 投票次数校验
function checkVote($uid)
{
    $key = "uid:$uid:cnt";
    $tomrTime = mktime(0,0,0, date('m'), date('d')+1, date('Y'));
    
    if (!$redis->exsits($key)) {
        $redis->set($key, 0, ['ex' => $tomrTime - time()]);
        return true;
    } else if ( ($cnt = $redis->get($key)) < 3 ) {
        return true;
    } else {
        return false;
    }
}

Comptage des votes

Une fois le nombre de votes passé, il est nécessaire de compter le nombre de votes obtenus par les utilisateurs.

// 得票数计数
// uid表示投票人id
// touid表示得票人id
function vote ($uid, $toUid)
{
    $key = "uid:$toUid:vote";
    
    // 投票数校验
    if (checkVote($uid)) {
        // 统计投票数及参选人得票数
        $redis->incr($key);
        $redis->incr("uid:$uid:cnt");
        
        return true;
    } else {
        return false;
    }
}

Ma propre configuration d'hôte Alibaba Cloud n'a qu'un seul processeur principal et une configuration de mémoire de 1 Go. L'augmentation des performances peut atteindre plus de 100 000 par seconde. Les performances Redis sont vraiment terribles.

# redis-benchmark -t incr -q
INCR: 105708.25 requests per second

Mysql met à jour de manière asynchrone le nombre de votes des utilisateurs

Enfin, il nous suffit d'effectuer une tâche planifiée et de laisser MySQL y accéder chaque certain temps Synchronisez le décompte des votes de l'utilisateur.

La méthode consiste à faire une boucle infinie, et à obtenir les votes de 50 utilisateurs à chaque fois, jusqu'à ce que tous les utilisateurs soient parcourus, puis quitter la boucle et terminer le script.

$start = 0;
while (true) {
    // 每次循环取50个用户id
    $users = $DB->query("SELECT uid,votes FROM users LIMIT $start, 50");
    if (!$users) {
        exit();
    }
    $keys = [];
    foreach ($users as $userinfo) {
        $keys[] = "uid:{$userinfo['uid']}:vote";
    }
    $votes = $redis->mget($keys);
    foreach ($votes as $index => $vote) {
        if ($vote != $users[$index]['votes']) {
            $DB->query("UPDATE users SET votes = '$vote' WHERE uid='{$users[$index]['uid']}");
        }
    }
    $start += 50;
}

La commande mget de Redis consiste à obtenir les valeurs de plusieurs clés à la fois. Après avoir obtenu le nombre de votes redis stockés dans redis, vous devez d'abord le comparer avec le nombre de votes dans Mysql. Mettez à jour les données Mysql uniquement lorsqu'elles sont différentes.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!