[Configuration] Multi connexions ???

Version imprimable

Bonjour à toutes et à tous,

Je suis en train d'écrire un script php qui doit tourner en permanence dans le but de :

- recevoir une requête HTTP
- récupérer le flux de données (format XML)
- effectuer le traitement nécessaire
- renvoyer la réponse HTTP (format XML)

Pour l'instant mon programme fonctionne, mais ne gère qu'une seule connexion à la fois, voici son code :

Code:

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
 
<?
 
// Autorise l'exécution infinie du script, en attente de connexion.
set_time_limit(0);
 
// Active le vidage implicite des buffers de sortie, pour que nous
// puissions voir ce que nous lisons au fur et à mesure.
ob_implicit_flush();
 
$address = '192.168.1.15';
$port = 8061;
$ip = $_SERVER["REMOTE_ADDR"];
 
	// Crée la socket
	if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) {
	   echo "socket_create() a échoué : raison : " . socket_strerror($sock) . "\n";
	}
 
	// Lie un nom à la socket
	if (($ret = socket_bind($sock, $address, $port)) < 0) {
	   echo "socket_bind() a échoué : raison : " . socket_strerror ($ret) . "\n";
	}
 
	// Ouvre la socket sur le port
	if (($ret = socket_listen($sock, 5)) < 0) {
	   echo "socket_listen() a échoué : raison : " . socket_strerror ($ret) . "\n";
	}
do{	
	// Accepte la connexion
	if (($msgsock = socket_accept($sock)) < 0) {
	   echo "socket_accept() a échoué : raison : " . socket_strerror ($msgsock) . "\n";
	}
 
	// Crée la socket
	if (false === ($buf = socket_read($msgsock, 2048))) {
	   echo "socket_read() a échoué : raison : " . socket_strerror ($ret) . "\n";
	}
 
 
	/*
	.
	.
	.
	.	[TRAITEMENT => utilisation de $buf et envoi du retour dans $flux]
	.
	.
	.
	*/
 
 
	//Envoi du retour XML
	$contentLength = strlen($flux);
 
	$send = "HTTP/1.1 200 OK\n";
	$send .= "Content-Type: text/xml; charset=utf-8\r\n";
	$send .= "Content-Length: " . $contentLength . "\r\n\r\n";
	$send .= $flux;
	$send .= "\r\n";
 
	socket_write($msgsock, $send, strlen($send));
	socket_shutdown($msgsock,2);
	socket_shutdown($sock,2);
 
}while(true);
 
?>

Je voudrais maintenant que mon programme gère plusieurs connexions simultanées, mais je ne sais pas comment faire ???

Merci d'avance pour vos réponses!!

19/12/2005, 14h35
Mr N.

Re: Multi connexions ???

Citation:

Envoyé par cilv1

Je suis en train d'écrire un script php qui doit tourner en permanence dans le but de :

- recevoir une requête HTTP
- récupérer le flux de données (format XML)
- effectuer le traitement nécessaire
- renvoyer la réponse HTTP (format XML)

Je n'ai pas trop bien compris l'intéret... Pourquoi ne pas faire confiance à apache ?
19/12/2005, 14h47
cilv1

Désolé de ne pas avoir été assez clair.

Le script php tourne sur Windows Server 2003 avec IIS6, qui lui écoute les requêtes HTTP sur le port 80 et fait son travail de serveur Web.

Par contre, je suis chargé d'écouter sur le port 8061 qui lui va recevoir des données au format XML, concrètement il s'agit de commandes passées par de nombreux pharmaciens dans toute la France.

Mon programme est également chargé de récupérer ces commandes, de les intégrer dans le logiciel ERP et de transmettre les informations de retour sur ce même port 8061 (par réponse HTTP).

Mon problème est que pour l'instant un seul pharmacien peut se connecter en même temps, ce qui n'est pas souhaitable pour ce genre de projet!

Merci en tout cas pour la rapidité de ta réponse Mr. N
19/12/2005, 14h51
Mr N.

Ben tu peux configurer IIS pour écouter sur le port 80 normal, et écouter aussi sur le port 8061, pour une autre appli. Par contre je sais plus comment on fait ^^
19/12/2005, 14h58
cilv1

Le problème c'est que je ne sais pas comment récupérer les données lorsque c'est IIS qui écoute ???
J'avais essayé en connectant une socket mais j'ai eu un message d'erreur comme quoi IIS écoute déjà sur le port...
19/12/2005, 15h13
Mr N.

Tu peux donner un exemple de requete reçue par ton script php ?

Oui, je te donne le script que j'ai écris et qui simule l'envoi d'une requête sur le port 8061 :

Code:

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
 
<?php
error_reporting(E_ALL);
 
/* Définit le port du service. */
$service_port = '8061';
 
/* Définit l'IP du serveur */
$address = '192.168.1.15';
 
/* Cree une socket TCP/IP. */
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 
$result = socket_connect($socket, $address, $service_port);
 
$fichier = "winpharma/tests/final/exemples/commande_test.xml";
 
$dom_=new DOMDocument();
$dom_->load($fichier);
$reqBody =$dom_->saveXML();
 
$contentLength = strlen($reqBody); 
 
$send = "POST /pharmaml.php HTTP/1.1\r\n";
$send .= "Host: localhost\r\n";
$send .= "Accept: */*\r\n";
$send .= "User-Agent: test.php test automation\r\n";
$send .= "Content-Type: application/x-www-form-urlencoded\r\n";
$send .= "Content-Length: " . $contentLength . "\r\n\r\n";
$send .= $reqBody; 
$send .= "\r\n";
 
socket_write($socket, $send, strlen($send))
or die("Write failed<br>");
 
while ($out = socket_read($socket, 2048)) {
   echo $out;
}
 
socket_close($socket);
 
?>

19/12/2005, 15h28
Mr N.

Ok et dans pharmaml.php, que donne le résultat de ceci (au début du script) :

Code:

var_dump('<pre>',$_REQUEST,'</pre>');die();

ca ne donne rien du tout, ou plutot ca fonctionne normalement :
je lance pharmaml.php, qui tourne en permanence, puis je lance le script de test d'envoi de la requete et lors de la reponse de celle-ci le script pharmaml.php continue de tourner, je peux envoyer d'autres requetes etc.

A moins que j'ai placé le code au mauvais endroit mais je ne pense pas, au cas ou je te donne le code de pharmaml.php :

Code:

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
 
<? 
var_dump('<pre>',$_REQUEST,'</pre>');die();
 
include("winpharma/tests/final/xmlrpc.inc");
 
// Autorise l'exécution infinie du script, en attente de connexion. 
set_time_limit(0); 
 
// Active le vidage implicite des buffers de sortie, pour que nous 
// puissions voir ce que nous lisons au fur et à mesure. 
ob_implicit_flush(); 
 
$address = '192.168.1.15'; 
$port = 8061; 
$ip = $_SERVER["REMOTE_ADDR"]; 
 
   // Crée la socket 
   if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) { 
      echo "socket_create() a échoué : raison : " . socket_strerror($sock) . "\n"; 
   } 
 
   // Lie un nom à la socket 
   if (($ret = socket_bind($sock, $address, $port)) < 0) { 
      echo "socket_bind() a échoué : raison : " . socket_strerror ($ret) . "\n"; 
   } 
 
   // Ouvre la socket sur le port 
   if (($ret = socket_listen($sock, 5)) < 0) { 
      echo "socket_listen() a échoué : raison : " . socket_strerror ($ret) . "\n"; 
   } 
do{    
   // Accepte la connexion 
   if (($msgsock = socket_accept($sock)) < 0) { 
      echo "socket_accept() a échoué : raison : " . socket_strerror ($msgsock) . "\n"; 
   } 
 
   // Crée la socket 
   if (false === ($buf = socket_read($msgsock, 2048))) { 
      echo "socket_read() a échoué : raison : " . socket_strerror ($ret) . "\n"; 
   } 
 
 
   /* 
   . 
   . 
   . 
   .   [TRAITEMENT => utilisation de $buf et envoi du retour dans $flux] 
   . 
   . 
   . 
   */ 
 
 
   //Envoi du retour XML 
   $contentLength = strlen($flux); 
 
   $send = "HTTP/1.1 200 OK\n"; 
   $send .= "Content-Type: text/xml; charset=utf-8\r\n"; 
   $send .= "Content-Length: " . $contentLength . "\r\n\r\n"; 
   $send .= $flux; 
   $send .= "\r\n"; 
 
   socket_write($msgsock, $send, strlen($send)); 
   socket_shutdown($msgsock,2); 
   socket_shutdown($sock,2); 
 
}while(true); 
 
?>

19/12/2005, 16h16
Mr N.
Laisse tomber j'ai oublié que tu n'étais pas sur un serveur web...

Alors si je comprend bien ta requête est la suivante :
Code:

1 2 3 4 5 6 7 8 POST /pharmaml.php HTTP/1.1 Host: localhost Accept: */* User-Agent: test.php test automation Content-Type: application/x-www-form-urlencoded Content-Length: 30 <toto><titi></titi></toto>
Est-ce que tu peux modifier cette requête ? car elle n'est pas très bien formée (avis personnel qui n'engage que moi, voir les rfc pour confirmation).
tu envoie un x-www-form-urlencoded or il manque le nom de la variable :

Code:

req=<toto><titi></titi></toto>

:?:

Le mieux est de donner la requête originale, la voici :
Code:

1 2 3 4 5 POST /pharmaml.php HTTP/1.1 Host: www.nepnet.net Content-Type: text/xml; charset="utf-8" Content-PharmaML: bM6fI3Rj0YfB0Hl/oY6+vQ==

19/12/2005, 16h23
Mr N.

Donc ta requete est dans le header Content-PharmaML: ?

Je ne suis pas sûr de ma réponse, mais voici la requete en entier (avec le header et le fichier xml) :

Code:

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
 
POST /pharmaml.php HTTP/1.1
Host: www.nepnet.net
Content-Type: text/xml; charset="utf-8"
Content-PharmaML: bM6fI3Rj0YfB0Hl/oY6+vQ==
 
<?xml version="1.0" encoding="UTF-8"?>
<CSRP_ENVELOPPE xmlns="urn:x-csrp:fr.csrp.protocole:enveloppe" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" Nature_Action="REQ_EMISSION" Version_Protocole="1.0.0.0" Id_Logiciel="WinPharma" Version_Logiciel="5.3.43" Usage="P">
<ENTETE>
    <EMETTEUR Nature="OF" Code="00" Id="1391002CAC" Adresse="   "/>
    <RECEPTEUR Nature="RE" Code="99" Id="123456" Adresse="HGFJHGFJH"/>
    <REF_MESSAGE>7D50A1F0D7D3202</REF_MESSAGE>
    <DATE>2005-10-31T18:20:51</DATE>
</ENTETE>
<CORPS>
    <MESSAGE_OFFICINE xmlns="urn:x-csrp:fr.csrp.protocole:message">
        <ENTETE>
            <EMETTEUR Nature_Partenaire="OF" Id_Client="1391002CAC"/>
            <DESTINATAIRE Nature_Partenaire="RE" Code_Societe="99" Id_Societe="123456"/>
        </ENTETE>
        <CORPS>
            <COMMANDE Ref_Cde_Client="6">
                <NORMALE>
                    <LIGNE_N Num_Ligne="1" Type_Codification="CIP39" Code_Produit="3341931" Quantite="1"/>
                    <LIGNE_N Num_Ligne="2" Type_Codification="CIP39" Code_Produit="3406033" Quantite="1"/>
                    <LIGNE_N Num_Ligne="3" Type_Codification="CIP39" Code_Produit="3514834" Quantite="1"/>
                </NORMALE>
            </COMMANDE>
        </CORPS>
    </MESSAGE_OFFICINE>
</CORPS>
</CSRP_ENVELOPPE>

19/12/2005, 16h34
Mr N.

Je commence à y voir un peu plus clair et surtout à voir que passer par la méthode classique risque d'être difficile...

PHP4, PHP5 ?
19/12/2005, 16h40
cilv1

PHP5
Pourquoi difficile? Je ne m'y suis pas pris correctement?
19/12/2005, 16h45
Mr N.

J'aurais tendance à dire (que les pros me confirment ou me contredisent) que le comportement que tu as est normal.
Quand apache (ou IIS) recoit une requete sur le port 80, il fait un fork afin de délivrer le contenu au client sur un autre port, afin de libérer le 80 et de pouvoir écouter d'autres clients. Si mes souvenirs sont bons.
Or avec ton script php tu ne fais pas ça. tant que tu traites une requête, tu ne peut accepter celles des autres clients, voila pourquoi un seul peut se connecter en meme temps.

Je vois donc deux solutions :
1. tu utilises un serveur web (apache, lighttpd, IIS) qui s'occupera de ce bazar (ils sont fait et étudiés pour ça)
2. tu réinventes la roue et tu le fais en php ce qui risque de ne pas être simple, d'autant plus que tu es sous windows
:|
20/12/2005, 09h30
cilv1

OK, c'est bien ce qui me semblait mais je n'ai pas réussi à trouver comment interagir avec IIS pour récupérer ces fameuses données?

J'imagine qu'il faut filtrer les requetes recues par IIS, mais vers quel port renvoyer la réponse? Faut-il que j'abandonne les sockets? Je ne connais pas de fonction php permettant ceci :cry:
20/12/2005, 09h43
Mr N.

Dans une configuration normale, c'est à dire php derrière un vrai serveur web, tu n'as pas à te soucier du port. Si le serveur écoute sur le port 8080, ca ne change rien à ton appli. Il te suffit de faire un echo et c'est apache ou autre qui s'occupe de renvoyer la réponse sur le bon port.
20/12/2005, 09h53
cilv1

ok, donc pour la réponse ça ne change rien.
Mais pour récupérer les requêtes reçues, il faut bien que je dispose d'une fonction capable de récupérer soit la ressource de la socket utilisée par le serveur web (s'il fonctionne bien ainsi), soit autre chose mais je ne vois pas quoi?
20/12/2005, 10h04
Mr N.

J'ai essayer d'envoyer ta requête à apache et il ma répondu "400 Bad Request" :(

Ta requête ressemble à du soap. Est-ce que je me trompe ? Peut-etre que ca sera une piste à explorer... :roll:
20/12/2005, 10h06
cilv1

Bon, j'ai fini par trouver une fonction qui se rapproche de ce que je veux faire : la fonction apache_request_headers()

lien :
http://fr.php.net/manual/fr/function...st-headers.php

Mais comme son nom l'indique, cette fonction n'est disponible que lorsque PHP est installé en module Apache, ce qui est loin d'être mon cas :?

Deuxieme chose, cette fonction récupère les headers HTTP, dans mon cas cela suffirait?
20/12/2005, 10h08
Mr N.

C'est ce dont je me suis servi mais relis mon post du dessus...
20/12/2005, 10h10
cilv1

Je vais voir la doc SOAP...
20/12/2005, 10h21
Mr N.

Du coté du client, c'est qui qui construit la requète ? toi ? Tu peux la modifier ?
20/12/2005, 10h27
cilv1

Non, ce n'est pas moi mais le logiciel du pharmacien qui envoie une requête HTTP.

J'ai simplement dû fournir les informations suivantes à la sociéte qui a développé ce logiciel :
- l'IP de mon serveur
- le port d'écoute de mon serveur que j'ai moi-même choisi
20/12/2005, 11h05
cilv1

Question bête : la variable pré-définie $_SERVER ne permet-elle pas de récupérer les headers http?

Alors je viens de réussir à passer ta requete via apache avec un header supplémentaire : content-length.
Voici la requête :

Code:

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
POST /xxxx.php HTTP/1.1
Host: localhost
Accept: */*
User-Agent: test.php test automation
Content-Type: text/xml; charset="utf-8"
Content-PharmaML: bM6fI3Rj0YfB0Hl/oY6+vQ==
Content-Length: 1309
 
<?xml version="1.0" encoding="UTF-8"?>
<CSRP_ENVELOPPE xmlns="urn:x-csrp:fr.csrp.protocole:enveloppe" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" Nature_Action="REQ_EMISSION" Version_Protocole="1.0.0.0" Id_Logiciel="WinPharma" Version_Logiciel="5.3.43" Usage="P">
<ENTETE>
    <EMETTEUR Nature="OF" Code="00" Id="1391002CAC" Adresse="   "/>
    <RECEPTEUR Nature="RE" Code="99" Id="123456" Adresse="HGFJHGFJH"/>
    <REF_MESSAGE>7D50A1F0D7D3202</REF_MESSAGE>
    <DATE>2005-10-31T18:20:51</DATE>
</ENTETE>
<CORPS>
    <MESSAGE_OFFICINE xmlns="urn:x-csrp:fr.csrp.protocole:message">
 
        <ENTETE>
            <EMETTEUR Nature_Partenaire="OF" Id_Client="1391002CAC"/>
            <DESTINATAIRE Nature_Partenaire="RE" Code_Societe="99" Id_Societe="123456"/>
        </ENTETE>
        <CORPS>
            <COMMANDE Ref_Cde_Client="6">
                <NORMALE>
                    <LIGNE_N Num_Ligne="1" Type_Codification="CIP39" Code_Produit="3341931" Quantite="1"/>
                    <LIGNE_N Num_Ligne="2" Type_Codification="CIP39" Code_Produit="3406033" Quantite="1"/>
 
                    <LIGNE_N Num_Ligne="3" Type_Codification="CIP39" Code_Produit="3514834" Quantite="1"/>
                </NORMALE>
            </COMMANDE>
        </CORPS>
    </MESSAGE_OFFICINE>
</CORPS>
</CSRP_ENVELOPPE>

voici apache_request_headers :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
array(6) {
  ["Host"]=>
  string(9) "localhost"
  ["Accept"]=>
  string(3) "*/*"
  ["User-Agent"]=>
  string(24) "test.php test automation"
  ["Content-Type"]=>
  string(26) "text/xml; charset="utf-8""
  ["Content-PharmaML"]=>
  string(24) "bM6fI3Rj0YfB0Hl/oY6+vQ=="
  ["Content-Length"]=>
  string(4) "1309"
}

Voici les infos de $_SERVER :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
array(29) {
...
  ["HTTP_HOST"]=>
  string(9) "localhost"
  ["HTTP_ACCEPT"]=>
  string(3) "*/*"
  ["HTTP_USER_AGENT"]=>
  string(24) "test.php test automation"
  ["CONTENT_TYPE"]=>
  string(28) "text/xml; charset=\"utf-8\""
  ["HTTP_CONTENT_PHARMAML"]=>
  string(24) "bM6fI3Rj0YfB0Hl/oY6+vQ=="
  ["CONTENT_LENGTH"]=>
  string(4) "1309"
...
  ["REQUEST_METHOD"]=>
  string(4) "POST"
  ["QUERY_STRING"]=>
  string(0) ""
...
}

$_POST :

Code:

1
2
array(0) {
}

C'est assez maigre comme résultat :|

20/12/2005, 11h56
cilv1

En effet il manque justement les données XML :(

Sinon j'ai épluché la doc SOAP et la fonction SoapClient->__getLastRequest() ressemble à ce que je cherche mais pour être honnête je n'ai pas bien compris la puissance de cette extension et s'il faut que le client envoie une requete "normale" ou spéciale dûe à SOAP ??
20/12/2005, 12h41
Mr N.

Alors ce que je comprend de ton application, c'est que tu es en train de développer un web service. Il faudrait demander à celui qui développe le client, sur quel standard il se base pour envoyer cette requette. Car pour du soap, je crois savoir, que le hader devrait contenir "Content-Type: application/soap+xml;..." au lieu de text/xml...

/!\ Ne pas prendre mes supputations au pied de la lettre, je suis assez loin de mon domaine de compétences /!\
20/12/2005, 14h51
cilv1

Je suis tombé sur cette page qui a l'air de confirmer ce que tu dis à propos des web services, et qui préconise l'utilisation de la librairie PEAR::SOAP:
http://www.esup-portail.org/consorti...b_services.htm

Je me penche dessus mais si quelqu'un s'y connaît je suis preneur!

Merci en tous cas de tes réponses Mr. N
21/12/2005, 10h45
cilv1

Bon j'ai décidé de réinventer la roue, ce qui n'a pas l'air si difficile que ça :roll:

Je reviendrais dans tous les cas pour ceux que ça intéresserait pour indiquer quelle piste j'ai suivie.
19/01/2006, 09h03
crevecoeurj

la solution mise en place m'interresse fortement.
Peux-tu expliquer la solution adoptée?
14/11/2010, 14h01
psirac

infos sur la solution adoptée

Je suis aussi interessé, pourrais-tu fournir la solution que tu as adopté s'il te plait ?