ArtusPendragon
Grünschnabel
Hallo
ich suche ein script beispiel für einen Funktionierenden Socket server in PHP.
Dieser solte mehere verbindungen gleichzeitig verarbeiten können.
Er soll befehle entgegen nehmen, die anahme bestätigen und dann die verbindung zum client trennen.
Dieser hier macht schon fast das was ich will. Er nimmt mehrere verbindungen an aber bestätigt den erhalt nicht und schliest die verbindung nicht automatisch.
ich will so ne art aplication server erstellen der über ein Webinterface aufgaben in gegen nimmt und diese dann abarbeitet. Die aufgaben sollen mittels XML übergeben werden.
leider komm ich da gerade ned weiter, hab zwar schon einige anleitungen gelesen aber ihrgendwie ist mir das gerade zu hoch.
ich suche ein script beispiel für einen Funktionierenden Socket server in PHP.
Dieser solte mehere verbindungen gleichzeitig verarbeiten können.
Er soll befehle entgegen nehmen, die anahme bestätigen und dann die verbindung zum client trennen.
Dieser hier macht schon fast das was ich will. Er nimmt mehrere verbindungen an aber bestätigt den erhalt nicht und schliest die verbindung nicht automatisch.
PHP:
#!/usr/local/bin/php -q
<?php
$ipaddress = '192.168.1.1';
$port = 31339;
// Ressourcen-arrays definieren
$readSocks = array();
// write und exception sockets werden in diesem script nicht benötigt
$writeSocks = null;
$exceptSocks = null;
// hier kommen alle neuen socket-verbindungen mit den clients hinein
$clients = array();
// erzeugen des sockets mittels socket_create()
$socket = socket_create(AF_INET, SOCK_STREAM, 0);
if ($socket === false) {
die('Fehler beim erzeugen des Sockets! Grund: ' . socket_strerror($socket) . "\n");
}
// socket an gegebene IP-Addresse und port binden.
if (($ret = socket_bind($socket, $ipaddress, $port)) === false) {
die('Fehler beim Binden des Sockets! Grund: ' . socket_strerror($ret) . "\n");
}
// auf dem socket auf einkommende verbindungen warten
if (($ret = socket_listen($socket, 5)) === false) {
die('Fehler beim lauschen auf dem Socket! Grund: ' . socket_strerror($ret) . "\n");
}
// einkommende Verbindung annehmen.
while (true) {
// der hauptsocket gehört ebenfalls zu den lesesockets
$readSocks = array();
$readSocks[] = $socket;
foreach($clients as $clientSock) {
$readSocks[] = $clientSock;
}
if (false === ($num_changed = socket_select($readSocks, $writeSocks, $exceptSocks, 0))) {
die('Fehler bei socket_select! Grund:' . socket_strerror(socket_last_error()) . "\n");
} elseif ($num_changed > 0) {
if (in_array($socket, $readSocks)) {
// Wenn unser socket immer noch in den lesesockets ist, hat
// ein neuer connect stattgefunden
if (($newsocket = socket_accept($socket)) === false) {
die('Fehler beim akzeptieren der Verbindung! Grund:' . socket_strerror($newsocket) . "\n");
} else {
// neuen client in die liste aller clienten aufnehmen
$clients[] = $newsocket;
}
}
foreach ($clients as $clientSock) {
if (in_array($clientSock, $readSocks)) {
// Ein Client hat uns daten geschickt.
$buffer = socket_read($clientSock, 2048);
if (!$buffer = trim($buffer)) {
// Verbindung wurde von der gegenpartei beendet.
socket_shutdown($clientSock);
socket_close($clientSock);
$key_index = array_keys(array_keys($clients), $clientSock);
array_splice($clients,$key_index[0]);
break;
}
if ($buffer == 'quit') {
// Verbindung möchte von der gegenstelle beendet werden.
socket_shutdown($clientSock);
socket_close($clientSock);
$key_index = array_keys(array_keys($clients), $clientSock);
array_splice($clients,$key_index[0]);
break;
} else {
// Normale nachricht
echo 'Nachricht von ' . $clientSock . ': ' . $buffer . "\n";
}
}
}
}
}
// Socket vor dem beenden schliessen
socket_shutdown($socket);
socket_close($socket);
?>ich will so ne art aplication server erstellen der über ein Webinterface aufgaben in gegen nimmt und diese dann abarbeitet. Die aufgaben sollen mittels XML übergeben werden.
leider komm ich da gerade ned weiter, hab zwar schon einige anleitungen gelesen aber ihrgendwie ist mir das gerade zu hoch.
Obwohl der Code caotisch und schlimm ist, ist er relativ schnell. Vllt. kannst du was damit anfangen:
