[Configuration] Multi connexions ???

Version imprimable

Voir 40 message(s) de cette discussion en une page

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, 15h35
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, 15h47
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, 15h51
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, 15h58
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, 16h13
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, 16h28
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, 17h16
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, 17h23
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, 17h34
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, 17h40
cilv1

PHP5
Pourquoi difficile? Je ne m'y suis pas pris correctement?
19/12/2005, 17h45
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, 10h30
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, 10h43
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, 10h53
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, 11h04
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:

Voir 40 message(s) de cette discussion en une page