1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
<?php
class Serveur
{
//contiendra la socket du serveur
private $socket=NULL;
//contiendra l'id du client
private $client=NULL;
//contiendra les données de l'en-tête
private $input=NULL;
//contiendra la chaine retournée par la fonction socket_read()
private $chaine=NULL;
private $tabClient=Array();
private $donnees='';
private $longueur='1500';
private $message='';
private $message_complet='';
private $i='0';
private $etat='1';
// Function qui démarre le serveur. Elle reçoit en paramètre l'adresse du serveur ainsi que son port, généralement, il s'agit du port 80.
public function DemarrerServeur($adress, $port)
{
if (($this->socket=socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === FALSE)
{
echo "socket_create () a échoué : raison : " . socket_strerror(socket_last_error($this->socket)) . "\n";
}
//on lie la ressource sur laquelle le serveur va écouter si il y a une erreur, on ferme la socket.
if ((socket_bind($this->socket, $adress, $port)) === FALSE)
{
echo "socket_bind () a échoué : raison : " . socket_strerror(socket_last_error($this->socket)) . "\n";
}
//on écoute les nouvelles ressources
socket_listen($this->socket) OR DIE ("ERREUR:".socket_strerror(socket_last_error($this->socket)));
echo "Le socket est en ecoute\r\n";
//Premiere boucle infinie qui ne stoppe pas le serveur.
while(true)
{
//accepte toutes les connexions.
$this->client=socket_accept($this->socket) OR DIE("ERREUR Socket_accept". socket_strerror(socket_last_error($this->client))); //il est arrêté tant qu'un client n'est pas connecté...
//Lis l'en-tête du fichier html de l'utilisateur qui vient de se connecter
$this->message=socket_read($this->client, 5);//lis le messagé que le client vient d'envoyer en le récupérant dans la variable message
if(substr_count($this->message, 'GET') > 0)
{
$this->i++;
echo "le".$this->i."client est connecte\r\n";
//mets l'id dans le tableau
$nick=urldecode(socket_read($this->client,23));
$nick=trim(substr($nick,(strpos($nick,'=')+1),15));//On isole le pseudo
echo "le pseudo".$nick;
$this->tabClient[$nick]= $this->client;
$this->Ecrire_aux_clients();
/*if((socket_write($this->client, $this->html, strlen($this->html)))!==FALSE)
{
echo "l'en-tete a ete envoye \n\r".$this->message;
}*/
socket_getpeername($this->client,&$adress,&$port);
echo "nouveau client ". $adress .":". $port;
//socket_close($this->client);
}
else
{
echo "post envoye";
//$this->message=socket_read($this->client, 1024);//lis le messagé que le client vient d'envoyer en le récupérant dans la variable message
$paquet=socket_read($this->client,intval(substr($this->message,0,2))+intval(substr($this->message,2,3)));
$pseudo=substr($paquet,0,intval(substr($this->message,0,2)));
$message_final=substr($paquet,intval(substr($this->message,0,2)),intval(substr($this->message,2,3)));
$full_client_msg="<font color='#FF0000'> [$pseudo a ecrit:]</font><font color='#AF00AF'>$message_final</font><br>";
//$full_client_msg="<font>$this->message</font><br>";
$this->message_complet="<script language=\"javascript\">document.getElementById('content').innerHTML+=\"".$full_client_msg."\"</script>";
reset($this->tabClient);
while ($value = current($this->tabClient))
{
if(is_resource($value))
{
if(($retourEcriture=socket_write($value,$this->message_complet,strlen($this->message_complet))!==false))
{
echo "\r\n longueur du texte \r\n ".$retourEcriture;
echo "message envoye \r\n".$this->message_complet;
}
}
next($this->tabClient);
}
}
//socket_close($this->client);
}
socket_close($this->socket);
}
//methode qui envoie aux clients tous ceux qui sont connectés
public function Ecrire_aux_clients()
{
reset($this->tabClient);
while ($value = current($this->tabClient))
{
if(is_resource($value))
{
$msg.="<script language=javascript>add_opt(\"".key($this->tabClient)."\",\"".key($this->tabClient)."\")</script>";
}
next($this->tabClient);
}
$full_msg=$this->html.$msg;
@socket_write($this->client,$full_msg,strlen($full_msg));
}
}
?> |
