Erstellen einer Online-Abstimmungsanwendung mit Node.js und Redis: Umgang mit hoher Parallelität

Erstellen von Online-Abstimmungsanwendungen mit Node.js und Redis: Umgang mit hoher Parallelität

Mit der Entwicklung des Internets müssen immer mehr Anwendungen mit Situationen hoher Parallelität umgehen. Online-Abstimmungsanwendungen sind ein typisches Szenario mit hoher Parallelität. Benutzer senden in kurzer Zeit eine große Anzahl von Abstimmungsanfragen. Die Anwendung muss in der Lage sein, diese Anfragen schnell zu verarbeiten und die Datenkonsistenz aufrechtzuerhalten. In diesem Artikel wird erläutert, wie Sie mit Node.js und Redis eine hochgradig gleichzeitige Online-Abstimmungsanwendung erstellen.

1. Einführung in Redis

Redis ist eine speicherbasierte Schlüsselwertdatenbank, die für ihr schnelles Lesen und Schreiben und ihre umfassende Datenstrukturunterstützung beliebt ist. In diesem Artikel verwenden wir Redis zum Speichern von Abstimmungsdaten und nutzen seine atomaren Operationen, um die Datenkonsistenz sicherzustellen.

2. Architekturdesign

Um mit vielen gleichzeitigen Abstimmungsanfragen fertig zu werden, haben wir das folgende Architekturdesign übernommen:

• Frontend-Seite: Verwenden Sie HTML und CSS, um die Benutzeroberfläche zu erstellen und Abstimmungsanfragen an den Knoten zu senden .js-Server über Ajax.
• Node.js-Server: Verarbeitet jede Abstimmungsanfrage und verwendet Redis zum Lesen und Schreiben von Abstimmungsdaten.
• Redis-Datenbank: speichert Abstimmungsdaten und stellt atomare Operationen zur Parallelitätskontrolle bereit.

3. Code-Implementierung

Das Folgende ist ein Codebeispiel auf der Node.js-Serverseite:

const express = require('express');
const redis = require('redis');

// 创建Express应用
const app = express();

// 创建Redis客户端
const redisClient = redis.createClient();

// 处理投票请求
app.post('/vote', (req, res) => {
  const { option } = req.body;

  // 增加投票计数
  redisClient.incr(option, (err, result) => {
    if (err) {
      // 投票失败的处理
      res.status(500).json({ error: '投票失败' });
    } else {
      // 投票成功的处理
      res.status(200).json({ success: '投票成功' });
    }
  });
});

// 启动服务监听
app.listen(3000, () => {
  console.log('服务器已启动');
});

Der obige Code führt zunächst die Express- und Redis-Module ein und erstellt eine Express-Anwendung und einen Redis-Client. Die Funktion app.post('/vote', ...) wird zum Verarbeiten von Abstimmungsanfragen verwendet und durch Aufrufen von redisClient.incr(option, ...)</code implementiert > Die Stimmenzahl für die entsprechende Option wird erhöht. Bei erfolgreicher Abstimmung wird der Statuscode 200 zurückgegeben, bei fehlgeschlagener Abstimmung wird der Statuscode 500 zurückgegeben. <code>app.post('/vote', ...)函数用于处理投票请求，通过调用redisClient.incr(option, ...)实现对相应选项的投票计数增加。投票成功后返回200状态码，投票失败则返回500状态码。

4. 并发控制

在高并发的情况下，多个用户同时对同一个选项进行投票会导致数据不一致。为了解决该问题，我们可以使用Redis提供的原子操作来进行并发控制。

// 获取锁
redisClient.get('vote_lock', (err, result) => {
  if (result) {
    // 已经有其他用户正在投票，处理投票失败的逻辑
    res.status(500).json({ error: '投票失败' });
  } else {
    // 获取锁成功，可以进行投票
    // 设置超时时间，防止异常情况下锁没有被释放
    redisClient.setex('vote_lock', 10, 'locked');

    // 增加投票计数
    redisClient.incr(option, (err, result) => {
      if (err) {
        // 投票失败的处理
        res.status(500).json({ error: '投票失败' });
      } else {
        // 投票成功的处理
        res.status(200).json({ success: '投票成功' });
      }

      // 释放锁
      redisClient.del('vote_lock');
    });
  }
});

上述代码通过使用Redis的get和setex

Parallelitätskontrolle
5. Bei hoher Parallelität führt die gleichzeitige Abstimmung mehrerer Benutzer über dieselbe Option zu Dateninkonsistenzen. Um dieses Problem zu lösen, können wir die von Redis bereitgestellten atomaren Operationen zur Parallelitätskontrolle verwenden.
rrreee

Der obige Code implementiert einen einfachen Sperrmechanismus, indem er die Operationen get und setex von Redis verwendet, um sicherzustellen, dass nur ein Benutzer gleichzeitig abstimmen kann, und gibt ihn nach der Abstimmung frei endet.

🎜🎜Zusammenfassung🎜🎜🎜In diesem Artikel wird erläutert, wie Sie mit Node.js und Redis eine hochgradig gleichzeitige Online-Abstimmungsanwendung erstellen. Durch die Verwendung der atomaren Operationen und des einfachen Sperrmechanismus von Redis sind wir in der Lage, eine große Anzahl gleichzeitiger Abstimmungsanfragen zu bearbeiten und die Datenkonsistenz aufrechtzuerhalten. Ich hoffe, dieser Artikel kann Ihnen helfen, die Verarbeitung mit hoher Parallelität zu verstehen. 🎜

Das obige ist der detaillierte Inhalt vonErstellen einer Online-Abstimmungsanwendung mit Node.js und Redis: Umgang mit hoher Parallelität. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!