Integration von Swoole und Redis: Erstellen Sie schnell ein hochverfügbares IM-System

Mit dem Aufkommen des mobilen Internets sind Instant-Messaging-Systeme (IM) zu einem unverzichtbaren Bestandteil unseres täglichen Lebens geworden. Daher ist die Entwicklung eines praktischen und leistungsstarken IM-Systems zu einem der Ziele geworden, die viele Entwickler verfolgen. In diesem Prozess sind Swoole und Redis zwei häufig verwendete Leistungstools, die uns dabei helfen können, schnell ein hochverfügbares IM-System aufzubauen.

In diesem Artikel werden die grundlegenden Konzepte und Prinzipien von Swoole und Redis vorgestellt und ein Fallbeispiel für die IM-Systemarchitektur sowie ein Implementierungsplan basierend auf diesen beiden Tools vorgestellt. Ich hoffe, dass der Leser durch diesen Artikel verstehen kann, wie man mit diesen beiden Tools ein leistungsstarkes IM-System aufbaut.

1. Überblick über Swoole und Redis

1.1 Swoole

Swoole ist ein fortschrittliches Netzwerk-Framework auf Basis von PHP. Es handelt sich um eine vollständig asynchrone, leistungsstarke serverseitige Engine, die die Protokolle TCP, UDP, WebSocket und HTTP unterstützt. Swoole kann die Leistung und Parallelität von PHP-Prozessen erheblich verbessern, hauptsächlich aufgrund seines auf Epoll oder Kqueue basierenden Reaktionsmechanismus, der Coroutine-Technologie verwendet, um nicht blockierende asynchrone Programmierung zu implementieren.

1.2 Redis

Redis ist eine Open-Source-In-Memory-Schlüsselwertdatenbank, die eine Vielzahl von Datenstrukturen unterstützt, einschließlich Zeichenfolgen, Hashes, Listen, Mengen, geordnete Mengen usw. Redis verfügt über eine hohe Leistung und Skalierbarkeit und kann Millionen gleichzeitiger Anfragen verarbeiten. Redis wird hauptsächlich in Szenarien wie Caching, Nachrichtenwarteschlangen und verteilten Sperren verwendet. 2. Integration von Swoole und Redis Der Swoole Redis-Client ist ein traditioneller Redis-Client und muss Rückruffunktionen verwenden, um Anforderungsantworten zu verarbeiten, während der Coroutine Redis-Client Anforderungen und Antworten über Coroutinen verarbeitet, was bequemer und effizienter zu verwenden ist.

2.2 Architekturbeschreibung

Um eine Echtzeitkommunikation zu erreichen, verwenden IM-Systeme normalerweise das WebSocket-Protokoll zur Übertragung von Nachrichten. In diesem Artikel erstellen wir einen WebSocket-Server basierend auf Swoole und Redis. Die vom Client gesendeten Nachrichten werden in Redis gespeichert und dann über den Server an andere Clients weitergeleitet.

• Der Client sendet eine Nachricht an den WebSocket-Server.

Der WebSocket-Server speichert die Nachricht an Redis.

• Redis sendet die Nachricht an den Server
  1. WebSocket-Server pusht Nachrichten an andere Kunden
• 3. Implementierungsplan
  2. Als Nächstes stellen wir den Implementierungsplan für jeden Schritt im Detail vor.
3.1 Servercode
• (1) Starten Sie den WebSocket-Server
  3. Verwenden Sie die von Swoole bereitgestellte WebSocket-Server-API, um den Server zu starten:

  $server = new SwooleWebSocketServer("0.0.0.0", 9501);
  
  $server->on('open', function (SwooleWebSocketServer $server, $frame) {
      echo "connection open
  ";
  });
  
  $server->on('message', function (SwooleWebSocketServer $server, $frame) {
      $redis = new SwooleCoroutineRedis();
      $redis->connect('127.0.0.1', 6379);
      $redis->lPush('messages', $frame->data);
  });
  
  $server->on('close', function (SwooleWebSocketServer $server, $fd) {
      echo "connection close
  ";
  });
  
  $server->start();

In diesem Code verwenden wir den $server-> on()-Funktion zum Festlegen der Rückruffunktionen zum Öffnen, Senden und Schließen von WebSocket-Ereignissen. Wenn der Client eine Verbindung zum Server herstellt, wird der Code in der Öffnungsfunktion ausgeführt. Wenn der Client eine Nachricht an den Server sendet, wird der Code in der Nachrichtenfunktion ausgeführt. In der Nachrichtenfunktion erstellen wir einen Coroutine Redis-Client und speichern die vom Client gesendeten Nachrichten in der Redis-Warteschlange zwischen.
• (2) Nachrichten an den Client senden
  4. Als nächstes müssen wir die Logik des Servers implementieren, der Nachrichten an den Client sendet. Dies kann mit der von Swoole bereitgestellten Funktion push() erreicht werden. Der Code lautet wie folgt:

  // 推送消息给客户端
  $server->tick(1000, function () use ($server) {
      $redis = new SwooleCoroutineRedis();
      $redis->connect('127.0.0.1', 6379);
  
      while ($message = $redis->rPop('messages')) {
          foreach ($server->connections as $fd) {
              $server->push($fd, $message);
          }
      }
  });

In diesem Code verwenden wir die von Swoole bereitgestellte Funktion tick(), um den Code regelmäßig auszuführen, und verwenden zum Abrufen den Coroutine Redis-Client die Nachricht von Redis und Push-Nachrichten an alle Clients.

3.2 Client-Code

Der Client-Code ist relativ einfach. Wir müssen nur den WebSocket-Client verwenden, um eine Verbindung zum WebSocket-Server herzustellen und Daten über JavaScript zu senden und zu empfangen. Der Code lautet wie folgt:

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>IM System</title>
</head>
<body>
    <h1>IM System</h1>
    <form>
        <label for="name">Name:</label>
        <input type="text" id="name">
        <br><br>
        <label for="message">Message:</label>
        <input type="text" id="message">
        <br><br>
        <input type="submit" value="Send Message">
    </form>
    <br><br>
    <div id="message-list"></div>
    <script>
        var socket = new WebSocket('ws://localhost:9501');

        socket.onopen = function(event) {
            console.log('WebSocket connect succeed');
        };

        socket.onmessage = function(event) {
            var message = JSON.parse(event.data);

            var messageList = document.getElementById('message-list');
            var p = document.createElement('p');
            p.innerText = message.name + ": " + message.message;
            messageList.prepend(p);
        };

        document.querySelector('form').addEventListener('submit', function(event) {
            event.preventDefault();

            var name = document.getElementById('name').value;
            var message = document.getElementById('message').value;

            socket.send(JSON.stringify({
                name: name,
                message: message
            }));

            document.getElementById('message').value = "";
        });
    </script>
</body>
</html>

In diesem Code verwenden wir zunächst den WebSocket-Client, um eine Verbindung zum WebSocket-Server herzustellen. Wenn der Client erfolgreich eine Verbindung herstellt, können wir über die send()-Methode des WebSocket-Objekts in JavaScript Nachrichten an den Server senden. Wir müssen auch die Onmessage-Rückruffunktion festlegen, um vom Server gepushte Nachrichten zu empfangen.

4. Zusammenfassung

In diesem Artikel haben wir die grundlegenden Konzepte und Prinzipien von Swoole und Redis vorgestellt und einen Fall und einen Implementierungsplan für eine WebSocket-Serverarchitektur geteilt, der auf Swoole und Redis basiert. Anhand dieses Falles können wir erfahren, wie Swoole und Redis zusammenarbeiten, um ein leistungsstarkes und hochverfügbares IM-System aufzubauen.

Natürlich ist dies nur ein einfaches Beispiel. In der Praxis müssen viele Aspekte berücksichtigt werden, wie z. B. Sicherheit, Leistungsoptimierung usw. Ich hoffe, dass die Leser durch diesen Artikel mehr über die Verwendung dieser beiden Tools erfahren können. Ich hoffe auch, dass die Leser diese beiden Tools und andere verwandte Technologien weiterhin eingehend studieren und weitere Beiträge zur Entwicklung leistungsstarker Anwendungen leisten können.

Das obige ist der detaillierte Inhalt vonIntegration von Swoole und Redis: Erstellen Sie schnell ein hochverfügbares IM-System. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!