So implementieren Sie einen Socket-Server mit PHP

Dieser Artikel wurde ursprünglich von MaNong.com übersetzt – Wang Guofeng. Bitte lesen Sie die Nachdruckanforderungen am Ende des Artikels. Willkommen beim technischen Übersetzungsteam!

Möchten Sie eine Chat-App oder sogar ein Spiel erstellen? Dann ist der Socket-Server Ihr erster Schritt. Sobald Sie die Grundfunktionen beim Erstellen eines Servers verstanden haben, werden nachfolgende Optimierungsschritte ebenso einfach.

Der Socket-Server funktioniert so: Er läuft kontinuierlich, um auf Client-Verbindungen zu warten. Sobald der Client verbunden ist, fügt der Server ihn der Clientliste hinzu und wartet auf Nachrichten vom Client.

Geh nicht weg, hier ist der vollständige Quellcode:

// Set time limit to indefinite execution
set_time_limit (0);

// Set the ip and port we will listen on
$address = 'localhost';
$port = 10000;
$max_clients = 10;

// Array that will hold client information
$client = Array();

// Create a TCP Stream socket
$sock = socket_create(AF_INET, SOCK_STREAM, 0);
// Bind the socket to an address/port
socket_bind($sock, $address, $port) or die('Could not bind to address');
// Start listening for connections
socket_listen($sock);

echo "Waiting for connections...\r\n";

// Loop continuously
while (true) {
	// Setup clients listen socket for reading
	$read[0] = $sock;
	for ($i = 0; $i < $max_clients; $i++) {
		if (isset($client[$i]['sock']))
			$read[$i + 1] = $client[$i]['sock'];
	}
	// Set up a blocking call to socket_select()
	if (socket_select($read, $write = NULL, $except = NULL, $tv_sec = 5) < 1)
		continue;
	/* if a new connection is being made add it to the client array */
	if (in_array($sock, $read)) {
		for ($i = 0; $i < $max_clients; $i++) {
			if (empty($client[$i]['sock'])) {
				$client[$i]['sock'] = socket_accept($sock);
				echo "New client connected $i\r\n";
				break;
			}
			elseif ($i == $max_clients - 1)
				echo "Too many clients...\r\n";
		}
	} // end if in_array

	// If a client is trying to write - handle it now
	for ($i = 0; $i < $max_clients; $i++) { // for each client
		if (isset($client[$i]['sock'])) {
			if (in_array($client[$i]['sock'], $read)) {
				$input = socket_read($client[$i]['sock'], 1024);
				if ($input == null) {
					echo "Client disconnecting $i\r\n";
					// Zero length string meaning disconnected
					unset($client[$i]);
				} else {
					echo "New input received $i\r\n";
					// send it to the other clients
					for ($j = 0; $j < $max_clients; $j++) {
						if (isset($client[$j]['sock']) && $j != $i) {
							echo "Writing '$input' to client $j\r\n";
							socket_write($client[$j]['sock'], $input, strlen($input));
						}
					}
					if ($input == 'exit') {
						// requested disconnect
						socket_close($client[$i]['sock']);
					}
				}
			} else {
				echo "Client disconnected $i\r\n";
				// Close the socket
				socket_close($client[$i]['sock']);
				unset($client[$i]);
			}
		}
	}
} // end while
// Close the master sockets
socket_close($sock);

Ja, das scheint auf den ersten Blick ein großes Projekt zu sein, aber wir Sie können damit beginnen, es in kleinere Teile zu zerlegen. Der erste Teil besteht darin, den Server zu erstellen. Zeilen: 2 bis 20.

Dieser Teil des Codes legt die Variablen, die Adresse, den Port, den maximalen Client und das Client-Array fest. Erstellen Sie als Nächstes den Socket und binden Sie ihn an die von uns angegebene Adresse und den angegebenen Port.

Als nächstes müssen wir eine Endlosschleife ausführen (eigentlich haben wir das mit Absicht gemacht!). Zeilen: 22 bis 32. Der erste Schritt, den wir in diesem Teil des Codes ausführen, besteht darin, das Array $read einzurichten. Dieses Array enthält die Sockets aller Clients und die Sockets unseres Hauptservers. Diese Variable wird später in der Select-Anweisung verwendet, um PHP anzuweisen, auf jede Nachricht von diesen Clients zu warten.

Der letzte Parameter von socket_select() weist unseren Server an, bis zu 5 Sekunden zu warten, bevor er einen Wert zurückgibt. Wenn der Rückgabewert kleiner als 1 ist, bedeutet dies, dass keine Daten empfangen wurden. Sie müssen also nur zum Anfang der Schleife zurückkehren und weiter warten.

Der nächste Teil des Skripts besteht darin, den neuen Client zum Array hinzuzufügen. Zeilen: 33 bis 44.

Platzieren Sie den neuen Kunden am Ende der Liste. Stellen Sie sicher, dass wir nicht mehr Clients haben, als der Server verarbeiten soll.

Der unten vorgestellte Codeblock ist ziemlich groß und stellt den Hauptteil des Servers dar. Wenn der Client eine Nachricht an den Server sendet, muss dieser Codeabschnitt weitergeleitet werden, um ihn zu verarbeiten. Die Nachricht kann alles sein, eine Trennungsnachricht, eine tatsächliche Trennung – was auch immer der Server verarbeiten muss. Zeilen: 46 bis zum Ende.

Der Code durchläuft jeden Client und prüft, ob eine Nachricht von ihm empfangen wurde. Wenn ja, rufen Sie den Eingabeinhalt ab. Überprüfen Sie anhand der Eingabe, ob es sich um eine Trennungsnachricht handelt. Wenn ja, löschen Sie sie aus dem Array. Andernfalls handelt es sich um eine normale Nachricht. Anschließend geht unser Server alle Clients erneut durch und schreibt die Nachricht einzeln an sie. Überspringen Absender.

Okay, lass uns versuchen, deinen eigenen Chat-Server zu erstellen!

Das Obige stellt vor, wie man PHP zum Implementieren eines Socket-Servers verwendet, einschließlich der relevanten Aspekte. Ich hoffe, dass es für Freunde hilfreich ist, die sich für PHP-Tutorials interessieren.