Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1672 connectés 

  FORUM HardWare.fr
  Programmation
  PHP

  [RESOLU] socket inter-process C/PHP linux

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

[RESOLU] socket inter-process C/PHP linux

n°2158788
ti7bo7
Posté le 02-10-2012 à 00:26:20  profilanswer
 

Bonjour,
 
J'aimerai communiquer entre deux processus sous linux. J'ai un programme en C (serveur) et un autre en PHP (client).  
 
Le programme en C démarre bien et j'ai bien mon fichier server dans le dossier tmp.
 
Par contre, le fichier php je suis un peu perdu avec le client. Je ne sais pas comment faire. J'ai vu qu'il y avait aussi des client.sock ou serveur.sock qui pouvait se créer mais pourquoi mon fichier C ne me génère pas cela ??  
 
Donc là je nage un peu après plusieurs heures de recherches.. je viens à l'aide !  
 
Merci :)
 

Code :
  1. <?php
  3. $socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
  5. socket_connect($socket, "unix://tmp/server" );
  7. $msg = "\nThis is a test\r\n";
  9. socket_write($socket, $msg, strlen($msg));
  11. socket_close($socket);
  12. ?>


 

Code :
  1. /**************************************************************************/
  2. /* This sample program provides code for aserver application that uses     */
  3. /* AF_UNIX address family                                                 */
  4. /**************************************************************************/
  6. /**************************************************************************/
  7. /* Header files needed for this sample program                            */
  8. /**************************************************************************/
  9. #include <stdio.h>
  10. #include <string.h>
  11. #include <sys/types.h>
  12. #include <sys/socket.h>
  13. #include <sys/un.h>
  15. /**************************************************************************/
  16. /* Constants used by this program                                         */
  17. /**************************************************************************/
  18. #define SERVER_PATH     "/tmp/server"
  19. #define BUFFER_LENGTH    250
  20. #define FALSE              0
  22. void main()
  23. {
  24.    /***********************************************************************/
  25.    /* Variable and structure definitions.                                 */
  26.    /***********************************************************************/
  27.    int    sd=-1, sd2=-1;
  28.    int    rc, length;
  29.    char   buffer[BUFFER_LENGTH];
  30.    struct sockaddr_un serveraddr;
  32.    /***********************************************************************/
  33.    /* A do/while(FALSE) loop is used to make error cleanup easier.  The   */
  34.    /* close() of each of the socket descriptors is only done once at the  */
  35.    /* very end of the program.                                            */
  36.    /***********************************************************************/
  37.    do
  38.    {
  39.       /********************************************************************/
  40.       /* The socket() function returns a socket descriptor representing   */
  41.       /* an endpoint.  The statement also identifies that the UNIX        */
  42.       /* address family with the stream transport (SOCK_STREAM) will be   */
  43.       /* used for this socket.                                            */
  44.       /********************************************************************/
  45.       sd = socket(AF_UNIX, SOCK_STREAM, 0);
  46.       if (sd < 0)
  47.       {
  48.          perror("socket() failed" );
  49.          break;
  50.       }
  52.       /********************************************************************/
  53.       /* After the socket descriptor is created, a bind() function gets a */
  54.       /* unique name for the socket.                                      */
  55.       /********************************************************************/
  56.       memset(&serveraddr, 0, sizeof(serveraddr));
  57.       serveraddr.sun_family = AF_UNIX;
  58.       strcpy(serveraddr.sun_path, SERVER_PATH);
  60.       rc = bind(sd, (struct sockaddr *)&serveraddr, SUN_LEN(&serveraddr));
  61.       if (rc < 0)
  62.       {
  63.          perror("bind() failed" );
  64.          break;
  65.       }
  67.       /********************************************************************/
  68.       /* The listen() function allows the server to accept incoming       */
  69.       /* client connections.  In this example, the backlog is set to 10.  */
  70.       /* This means that the system will queue 10 incoming connection     */
  71.       /* requests before the system starts rejecting the incoming         */
  72.       /* requests.                                                        */
  73.       /********************************************************************/
  74.       rc = listen(sd, 10);
  75.       if (rc< 0)
  76.       {
  77.          perror("listen() failed" );
  78.          break;
  79.       }
  81.       printf("Ready for client connect().\n" );
  83.       /********************************************************************/
  84.       /* The server uses the accept() function to accept an incoming      */
  85.       /* connection request.  The accept() call will block indefinitely   */
  86.       /* waiting for the incoming connection to arrive.                   */
  87.       /********************************************************************/
  88.       sd2 = accept(sd, NULL, NULL);
  89.       if (sd2 < 0)
  90.       {
  91.          perror("accept() failed" );
  92.          break;
  93.       }
  95.       /********************************************************************/
  96.       /* In this example we know that the client will send 250 bytes of   */
  97.       /* data over.  Knowing this, we can use the SO_RCVLOWAT socket      */
  98.       /* option and specify that we don't want our recv() to wake up      */
  99.       /* until all 250 bytes of data have arrived.                        */
  100.       /********************************************************************/
  101.       length = BUFFER_LENGTH;
  102.       rc = setsockopt(sd2, SOL_SOCKET, SO_RCVLOWAT,
  103.                                           (char *)&length, sizeof(length));
  104.       if (rc < 0)
  105.       {
  106.       }
  108.       printf("%d bytes of data were received\n", rc);
  109.       if (rc == 0 ||
  110.           rc < sizeof(buffer))
  111.       {
  112.          printf("The client closed the connection before all of the\n" );
  113.          printf("data was sent\n" );
  114.          break;
  115.       }
  117.       /********************************************************************/
  118.       /* Echo the data back to the client                                 */
  119.       /********************************************************************/
  120.       rc = send(sd2, buffer, sizeof(buffer), 0);
  121.       if (rc < 0)
  122.       {
  123.          perror("send() failed" );
  124.          break;
  125.       }
  127.       /********************************************************************/
  128.       /* Program complete                                                 */
  129.       /********************************************************************/
  131.    } while (FALSE);
  133.    /***********************************************************************/
  134.    /* Close down any open socket descriptors                              */
  135.    /***********************************************************************/
  136.    if (sd != -1)
  137.       close(sd);
  139.    if (sd2 != -1)
  140.       close(sd2);
  142.     /***********************************************************************/
  143.    /* Remove the UNIX path name from the file system                      */
  144.    /***********************************************************************/
  145.    unlink(SERVER_PATH);
  146. }


Message édité par ti7bo7 le 03-10-2012 à 22:50:01
mood
Publicité
Posté le 02-10-2012 à 00:26:20  profilanswer
 

n°2158803
Farian
Posté le 02-10-2012 à 08:31:26  profilanswer
 

Bonjour !
 
Votre code C est étrange ...
 
 * Vous configurez la socket pour que chaque appel à "recv" ne rende la main qu'une fois 250 octets reçus, or, votre programme en PHP en envoie beaucoup moins que ça (17 si j'ai bien compté)
 
 * Vous ne faites pas de "recv" ! Vous n'allez donc rien recevoir !  
 
Le programme va donc tranquillement afficher "0 octets recus", puis envoyer un buffer non initialisé vers le client ... jusqu'à ce que le client ferme la socket (ce qu'il fait juste après avoir envoyé son message, donc cela devrait arriver très vite) et donc, que le "send" sorte en erreur.
 
Je pense que vous devez repenser vos programmes de tests, afin qu'ils soient cohérents :)
 
Bon courage !

n°2158844
ti7bo7
Posté le 02-10-2012 à 13:16:37  profilanswer
 

Bonjour,
 
Merci de votre réponse.
 
J'ai avancé depuis hier soir.
 
J'ai réussi à avoir une connexion et discussion mais entre deux programme C.
 
Il me reste le php qui est problématique: je ne sais pas comment écrire l'adresse du socket, certains site disent: "unix://tmp/server" mais ça ne marche pas non plus... des idées ??
 
Sachant qu'évidemment le socket est bien à cette adresse ..
 

Code :
  1. <?php
  3. $socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
  5. socket_connect($socket, "/tmp/server" );
  7. echo 'ok';
  9. $msg = "\nThis is a test\r\n";
  11. socket_write($socket, $msg, strlen($msg));
  13. socket_close($socket);
  14. ?>


 
 
Merci !


Message édité par ti7bo7 le 02-10-2012 à 16:59:01
n°2158892
czh
Posté le 02-10-2012 à 21:39:03  profilanswer
 


Code :
  1. <?php
  3. $socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
  4. var_dump($socket);
  6. $ret = socket_connect($socket, "/tmp/server" );
  7. var_dump($ret);
  8. var_dump(socket_last_error());
  10. echo 'ok';
  12. $msg = "\nThis is a test\r\n";
  14. $ret = socket_write($socket, $msg, strlen($msg));
  15. var_dump($ret);
  16. var_dump(socket_last_error());
  18. socket_close($socket);
  19. ?>


n°2159057
ti7bo7
Posté le 03-10-2012 à 22:49:27  profilanswer
 

C'est bon j'ai réussi ! merci


Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  PHP

  [RESOLU] socket inter-process C/PHP linux

 

Sujets relatifs
Petit problème - langage C[PHP] FPDF error: Some data has already been output, can't send PDF fi
PHP-HTMLbesoin d'aide-language C svp
[C#] Comment faire une méthode avec un paramètre générique[Codage PHP] Affichage résumé d'une ligne
fstream / Modifier une valeur spécifique dans un fichier C++[Microsoft][C] convertir un char* en PCWSTR
Erreur de Link (Visual C++ 2005)[C#] Expression régulières
Plus de sujets relatifs à : [RESOLU] socket inter-process C/PHP linux

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.124 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR