Workerman-Netzwerkprogrammierungspraxis: Erstellen Sie ein leistungsstarkes Instant-Messaging-System

Workerman Network Programming Practice: Erstellen Sie ein leistungsstarkes Instant-Messaging-System

Einführung:
Mit der rasanten Entwicklung des Internets haben Instant-Messaging-Systeme immer mehr Aufmerksamkeit bei den Benutzern auf sich gezogen. Bei herkömmlichen Instant-Messaging-Systemen wie QQ, WeChat usw. treten häufig Leistungsengpässe auf, wenn die Anzahl der Benutzer groß ist und die Nachrichten stark gleichzeitig sind. Um dieses Problem zu lösen, wurde das Open-Source-Projekt Workerman ins Leben gerufen. In diesem Artikel wird erläutert, wie Sie mit Workerman ein leistungsstarkes Instant-Messaging-System erstellen.

1. Einführung in Workerman
   Workerman ist ein leistungsstarkes Netzwerkkommunikations-Framework, das auf PHP-Basis entwickelt wurde. Im Vergleich zu herkömmlichen PHP-Betriebsmodi wie Apache, Nginx usw. verwendet Workerman einen vollständig asynchronen und nicht blockierenden Betriebsmodus, der die Effizienz der Netzwerkkommunikation erheblich verbessert. Gleichzeitig unterstützt Workerman mehrere Protokolle wie TCP, UDP usw., sodass wir je nach Bedarf flexibel wählen können. Darüber hinaus bietet Workerman eine hervorragende Unterstützung für hohe Parallelität und kann den Druck einer großen Anzahl von Benutzern problemlos bewältigen.
2. Vorbereitung
   Um mit der Entwicklung unseres Instant-Messaging-Systems zu beginnen, müssen wir zunächst Workerman installieren. Es kann über den folgenden Befehl installiert werden:

composer require workerman/workerman

Nach Abschluss der Installation können wir alle Funktionen von Workerman nutzen.

3. TCP-Server erstellen
   Wir erstellen zunächst einen einfachen TCP-Server, der den angegebenen Port überwacht. Wenn ein Benutzer eine Verbindung zum Server herstellt, gibt der Server eine Willkommensnachricht zurück und empfängt vom Benutzer gesendete Nachrichten. Das Folgende ist ein einfaches Codebeispiel:

use WorkermanWorker;

// 创建一个Worker监听端口
$tcp_worker = new Worker("tcp://0.0.0.0:1234");

// 当客户端连接时的回调函数
$tcp_worker->onConnect = function ($connection) {
    $connection->send("Welcome to the chat room!
");
};

// 当接收到客户端消息时的回调函数
$tcp_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    echo "Received message: " . $data . "
";
    $connection->send("You said: " . $data . "
");
};

// 启动Worker
Worker::runAll();

Mit dem obigen Code haben wir einen TCP-Worker erstellt, der Port 1234 überwacht. Wenn ein Client eine Verbindung zum Server herstellt, sendet der Server eine Willkommensnachricht. Wenn der Client eine Nachricht sendet, gibt der Server die Nachricht unverändert zurück. Sie können Tools wie Telnet verwenden, um zu Testzwecken eine Verbindung zum Server herzustellen.

4. WebSocket-Server erstellen
   WebSocket ist ein Vollduplex-Kommunikationsprotokoll, das eine dauerhafte Verbindung zwischen dem Client und dem Server herstellen kann. Workerman unterstützt das WebSocket-Protokoll und wir können Workerman zum Erstellen eines WebSocket-Servers verwenden. Das Folgende ist ein einfaches Codebeispiel:

use WorkermanWorker;
use WorkermanProtocolsWebsocket;

// 创建一个WebSocket Worker监听端口
$websocket_worker = new Worker("websocket://0.0.0.0:1234");

// 设置协议处理类
$websocket_worker->onWebSocketConnect = function ($connection, $http_header) {
    // 处理握手请求
    Websocket::dealHandshake($connection, $http_header);
    // 发送欢迎消息
    $connection->send("Welcome to the chat room!
");
};

// 当接收到客户端消息时的回调函数
$websocket_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    echo "Received message: " . $data . "
";
    $connection->send("You said: " . $data . "
");
};

// 启动Worker
Worker::runAll();

Mit dem obigen Code erstellen wir einen WebSocket-Worker, der Port 1234 überwacht. Wenn ein Client eine Verbindung zum Server herstellt, sendet der Server eine Willkommensnachricht. Wenn der Client eine Nachricht sendet, gibt der Server die Nachricht unverändert zurück.

5. Implementierung eines Instant-Messaging-Systems
   Mit der oben genannten Grundlage können wir weiterhin ein umfassenderes Instant-Messaging-System implementieren. Für die Entwicklung verwenden wir hier das WebSocket-Protokoll.

Erstellen Sie zunächst einen WebSocket-Server, der den angegebenen Port überwacht. Wenn ein Benutzer eine Verbindung zum Server herstellt, fügt der Server die Verbindung zur Benutzerliste hinzu und sendet die Nachricht, dass der Benutzer den Chatraum betreten hat. Wenn der Benutzer eine Nachricht sendet, sendet der Server die Nachricht an alle Online-Benutzer Der Benutzer trennt die Verbindung, der Server entfernt ihn aus der Benutzerliste und sendet eine Nachricht, dass der Benutzer den Chatroom verlassen hat.

Das Folgende ist ein einfaches Codebeispiel:

use WorkermanWorker;
use WorkermanProtocolsWebsocket;

// 创建一个WebSocket Worker监听端口
$websocket_worker = new Worker("websocket://0.0.0.0:1234");

// 设置协议处理类
$websocket_worker->onWebSocketConnect = function ($connection, $http_header) {
    // 处理握手请求
    Websocket::dealHandshake($connection, $http_header);

    // 将连接添加到用户列表中
    global $user_list;
    $user_list[$connection->id] = $connection;

    // 广播用户进入聊天室的消息
    broadcastMessage("User #$connection->id entered the chat room.
");
};

// 当接收到客户端消息时的回调函数
$websocket_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    broadcastMessage("User #$connection->id: $data");
};

// 当用户断开连接时的回调函数
$websocket_worker->onClose = function ($connection) {
    // 将连接从用户列表中移除
    global $user_list;
    unset($user_list[$connection->id]);

    // 广播用户离开聊天室的消息
    broadcastMessage("User #$connection->id left the chat room.");
};

// 启动Worker
Worker::runAll();

// 广播消息给所有在线用户
function broadcastMessage($message)
{
    global $user_list;
    foreach ($user_list as $connection) {
        $connection->send($message);
    }
}

Mit dem obigen Code haben wir ein einfaches Instant-Messaging-System implementiert. Immer wenn ein neuer Benutzer den Chatroom betritt, eine Nachricht sendet oder den Chatroom verlässt, sendet der Server die entsprechende Nachricht an alle Online-Benutzer.

Fazit:
In diesem Artikel verwenden wir das Workerman-Framework, um zu demonstrieren, wie man durch einfachen Beispielcode ein leistungsstarkes Instant-Messaging-System aufbaut. Mit dem asynchronen, nicht blockierenden Betriebsmodus von Workerman und der Unterstützung hoher Parallelität können wir den Druck einer großen Anzahl von Benutzern problemlos bewältigen. Ich hoffe, dass die Leser durch die Einleitung dieses Artikels ein tieferes Verständnis von Workerman erlangen und es in tatsächlichen Projekten anwenden können.

Das obige ist der detaillierte Inhalt vonWorkerman-Netzwerkprogrammierungspraxis: Erstellen Sie ein leistungsstarkes Instant-Messaging-System. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!