Moteur PHP5 gestion de socket.

Marsh Posté le 11-10-2007 à 16:35:41

Bonjour j utilise le moteur php pour créer un petit programme pouvant recevoir des socket exterieur,
jusqu a la tout va bien, il me renvoi bien la donnée sur le client l'envoyant;

Mon besoin étant de renvoyer toutes les informations issus de n'importe quels clients vers tout les utilisateurs connectés.

exemple 3 CX en simultanées,
un d'une des connexions envoie "1", les trois connection devront recevoir le "1" envoyé par la connection.

Merci de de votre aide

Code :

<?php
// On se replace dans le répertoire où est stocké le script
chdir(dirname(__FILE__));
// On initialise un tableau contenant la liste des sockets à surveiller
$watchSockets = array();
// On initialise un tableau contenant les sockets clients
$clients = array();
// On initlialise un tableau contenant les sockets threads
$threads = array();
// On initialise un tableau contenant les données temporaires à envoyer à un nouveau thread
$threadsTemp = array();
// -----------------------------------
// On crée la socket "externe"
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
// On la lie, ici sur le port 10000
socket_bind($socket, '0.0.0.0', 10000);
// On la fait écouter
socket_listen($socket, 5);
// On ajoute la socket du serveur dans la liste des sockets à surveiller (pour les nouvelles connexions)
$watchSockets[] = $socket;
// -----------------------------------
// On crée la socket "interne" pour la communication avec les threads
$threadSocket = socket_create(AF_UNIX, SOCK_STREAM, NULL);
// On la lie, ici sur la socket /tmp/monserveur.socket
socket_bind($threadSocket, '/tmp/monserveur.socket');
// On la fait écouter
socket_listen($threadSocket);
// On ajoute la socket du serveur interne dans la liste des sockets à surveiller (pour les nouveaux threads)
$watchSockets[] = $threadSocket;
// Boucle infinie
while (TRUE)
{
// Surveillance des sockets en attente de données à lire
// Si pas de données à lire : on relance la boucle
$toRead = $watchSockets; // Parce que socket_select() modifie le tableau passé en paramètre et que l'on veut garder notre variable $watchSockets
if (!@socket_select($toRead, $write = NULL, $except = NULL, 0)) continue;
// Il y a des données à lire
// Le socket d'écoute éxtérieur a-t-il reçu des données ?
if (in_array($socket, $toRead))
{
// Oui : il s'agit d'une nouvelle connexion
// Acceptons-la
$newConnection = socket_accept($socket);
// Ajoutons-la à la liste des clients
$clients[] = $newConnection;
// Ajoutons-la à la liste des sockets à surveiller
$watchSockets[] = $newConnection;
// Créons un thread qui s'occupera de ce client
// ATTENTION : vérifiez que le chemin vers PHP est correct
// On passe en outre l'ID du client dans le tableau de correspondance pour que l'on puisse identifier le thread lors de sa connexion plus tard
// Les caractères étranges de la fin de la commande assurent l'éxécution en arrière-plan
exec('/usr/local/bin/php thread.php '.strval(count($clients) - 1).' 2>/dev/null >&- <&- >/dev/null &');
// Supprimons la socket d'écoute de la liste des sockets à lire
// (pour éviter d'interférer avec la suite)
$key = array_search($socket, $toRead);
unset($toRead[$key]);
}
// Le socket d'écoute interne (threads) a-t-il reçu des données ?
if (in_array($threadSocket, $toRead))
{
// Oui : un thread est prêt et tente de se connecter
// Acceptons la connexion
$newConnection = socket_accept($threadSocket);
// Récupérons l'ID du thread
$data = socket_read($newConnection, 4, PHP_BINARY_READ);
var_dump($data);
$id = unpack('lid', $data); $id = $id['id'];
// NOTE : cette méthode n'est en théorie pas optimale au niveau perfs, socket_read() pouvant bloquer un court instant
// Pour éviter cela, il faut récupérer l'ID en surveillant le socket (en attendant il faut placer le socket client dans une pile temporaire)
// Cette dernière variante n'est pas utilisée ici pour ne pas compliquer le code mais ne présente pas de difficulté majeure
// Ajoutons-la à la liste des threads
$threads[$id] = $newConnection;
// Ajoutons-la à la liste des sockets à surveiller
$watchSockets[] = $newConnection;
// A-t-on des données à lui passer, qui ont été stockées temporairement ?
if (strlen($threadsTemp[$id]))
{
// Oui : passons les
for ($writed = 0; $writed < strlen($threadsTemp[$id]); $writed += socket_write($newConnection, substr($threadsTemp[$id], $writed)));
unset($threadsTemp[$id]);
}
// Supprimons la socket d'écoute de la liste des sockets à lire
// (pour éviter d'interférer avec la suite)
$key = array_search($threadSocket, $toRead);
unset($toRead[$key]);
}
// Parcourons la liste des sockets clients et threads ayant reçu des données
foreach ($toRead as $oneSocket)
{
if (in_array($oneSocket, $clients))
{
// Il s'agit d'un client externe
// Client >> SCRIPT >> thread
// Obtenons l'ID client correspondant
$key = array_search($oneSocket, $clients);
// Lisons la socket sur disons... 1024 octets
// (un choix purement arbitraire, peut néanmoins influer sur les performances, pensez à faire des tests)
$data = socket_read($oneSocket, 1024);
if (!strlen($data))
{
// La connexion avec le client s'est interrompue
// Fermons le socket client
socket_close($oneSocket);
// Fermons le socket thread
@socket_close($threads[$key]);
// On coupe tout
unset($clients[$key]);
unset($threads[$key]);
$watchKey = array_search($oneSocket, $watchSockets);
unset($watchSockets[$watchKey]);
}
else
{
// Le thread associé est-il prêt et connecté ?
if (isset($threads[$key]))
{
// Oui : passons lui les données
for ($writed = 0; $writed < strlen($data); $writed += socket_write($threads[$key], substr($data, $writed)));
}
else
{
// Non : on les stocke temporairement
$threadsTemp[$key] .= $data;
}
}
}
elseif (in_array($oneSocket, $threads))
{
// Il s'agit d'un thread
// Thread >> SCRIPT >> client
// Obtenons l'ID du thread correspondant
$key = array_search($oneSocket, $threads);
// Lisons la socket sur disons... 1024 octets
// (un choix purement arbitraire, peut néanmoins influer sur les performances, pensez à faire des tests)
$data = socket_read($oneSocket, 1024);
if (!strlen($data))
{
// La connexion avec le thread s'est interrompue (autrement dit, il veut fermer la connexion avec le client)
// Fermons le socket client
socket_close($clients[$key]);
// Fermons le socket thread
socket_close($oneSocket);
// On coupe tout
unset($clients[$key]);
unset($threads[$key]);
$watchKey = array_search($oneSocket, $watchSockets);
unset($watchSockets[$watchKey]);
}
else
{
// Passons les données au client correspondant
for ($writed = 0; $writed < strlen($data); $writed += socket_write($clients[$key], substr($data, $writed)));
}
}
}
}
?>

Reply

Marsh Posté le 11-10-2007 à 16:35:41

Reply

Marsh Posté le 11-10-2007 à 20:03:24

Quelle est la question ?

Message cité 1 fois

Reply

Marsh Posté le 15-10-2007 à 09:40:17

Olivier51 a écrit :

Quelle est la question ?

*je souhaite avoir un perroquet tout ce qui recu par un socket et renvoyé sur tout les sockets connectés

Reply

Moteur PHP5 gestion de socket.

Sujets relatifs:

Leave a Replay