[RESOLU] socket inter-process C/PHP linux

socket inter-process C/PHP linux [RESOLU] - PHP - Programmation

Marsh Posté le 02-10-2012 à 00:26:20    

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
Reply

Marsh Posté le 02-10-2012 à 00:26:20   

Reply

Marsh Posté le 02-10-2012 à 08:31:26    

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 !

Reply

Marsh Posté le 02-10-2012 à 13:16:37    

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
Reply

Marsh Posté le 02-10-2012 à 21:39:03    


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. ?>


Reply

Marsh Posté le 03-10-2012 à 22:49:27    

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

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed