[PHP] Socket server in loop infinito errori

giogua

Nuovo Utente
12 Lug 2017
2
0
1
58
Saluti a tutti e grazie per l'aiuto

Ho creato un socket_ server in loop, inizialmente senza un termine di chiusura,
Questo si collega ad una porta e si mette in ascolto per ricevere dei dati da alcuni dispositivi.
Il problema nasce dal fatto che vorrei poter sospendere il socket attraverso il cambiamento di un flag su un database.
Questo purtroppo non avviene il socket continua il suo loop, non fa lo shutdown e la chiusura, tutti i comandi, non vengono eseguiti, cosa sbaglio?


PHP:
<?php

$sql ="SELECT socketalive from semaphores";
include 'database-select.php';
var_dump($v);
if ($v==0) {
/********Socket Server*********************/
set_time_limit (0);

// Set the ip and port we will listen on
$address = '127.0.0.1';
$port = 6789;

// Create a TCP Stream socket
//$sock = socket_create(AF_INET, SOCK_STREAM, 0); // 0 for  SQL_TCP oppure IPPROTO_IP questo è il protocollo IP
if (!($sock = socket_create(AF_INET, SOCK_STREAM, 0))) {
    $errorcode = socket_last_error();
    $errormsg = socket_strerror($errorcode);
    die("Creazione del socket non riuscita: [$errorcode] $errormsg \n");
    }
    echo "{$v}";
  
// Bind the socket to an address/port
socket_bind($sock, 0, $port) or die('Could not bind to address');  //0 for localhost

// Start listening for connections
socket_listen($sock);
//loop and listen

while ($v==0):

          
                var_dump($v); // QUESTO COMANDO NON PRODUCE ALCUN RISULTATO
                //Si connette al database per controllare il valore di socketalive
                $servername = "localhost";
                $username = "root";
                $password = "Gionewday63";
                $dbname = "wandw";
                $sql ="SELECT socketalive from semaphores";
              
          
                $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
                $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
                $stmt = $conn->prepare($sql);
                $stmt->execute();
                $result = $stmt->setFetchMode(PDO::FETCH_ASSOC);
                    foreach(new Rows(new RecursiveArrayIterator($stmt->fetchAll())) as $k=>$v) {}
                  
                        if ($v==0) {
              
                        /* Accept incoming  requests and handle them as child processes */
                        $client =  socket_accept($sock);
                      
                        // Read the input  from the client – 1024000 bytes
                        $input =  socket_read($client, 1290);
                      
                        $output = trim($input);
                        $myfile = fopen("testfile.txt", "a+");
                        fwrite($myfile, $v);
                        fclose($myfile);  
                        /*
                         Strip all white  spaces from input
                      
                        $output .= \n\r;
                        $output =  ereg_replace("[ \t\n\r]","",$input)."\0";
                        $message=explode(',',$output);
                      
                        $file = 'gps.txt';
                        Open the file to get existing content
                        $current = file_get_contents($file);
                      
                        //Append new data to the file
                        $current .= $output;
                      
                        // Write the contents back to the file
                        file_put_contents($file, $current);
                      
                       
                      
                            //socket_shutdown($sock, 2);
                            //($sock);
                        */
                            }
              
                            else {
                            echo "sono passato da qui";
                            socket_shutdown($sock, 2);
                            socket_close($sock);
                            //break;
                            }
          
                       
                        $i++;
                        endwhile;
}
else {

echo ("Questo script finisce qui");
}
?>




include iniziale (fa una semplice select e presenta la variabile nell'array:

PHP:
<?php
class Rows extends RecursiveIteratorIterator {
  
}
//Si connette al database per controllare il valore di socketalive
$servername = "localhost";
$username = "root";
$password = "Gionewday63";
$dbname = "wandw";



try {
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $stmt = $conn->prepare($sql);
    $stmt->execute();
  
    // set the resulting array to associative
    $result = $stmt->setFetchMode(PDO::FETCH_ASSOC);
  
    foreach(new Rows(new RecursiveArrayIterator($stmt->fetchAll())) as $k=>$v) {
            }
  
  
}

catch(PDOException $e) {
    echo "Error: " . $e->getMessage();
}
$conn = null;

?>
 
Ultima modifica di un moderatore:

linoma

Utente Attivo
1 Mar 2017
84
4
8
Nn puoi identare un po il codice? Già il codice è illeggibile di per se poi nn identato lo diventa di più. Cmq credo che tu debba attendere prima la connessione da parte del client e poi testare il db, nn si riesce a capire bene cosa vuoi fare. Cmq questo è il flusso di una socket server

YQ5ES.png
 
Ultima modifica:
Discussioni simili
Autore Titolo Forum Risposte Data
L php e socket PHP 3
T fatture con voci fattura in php PHP 0
T ALTRO PROBLEMA CON ARRAY PHP PHP 1
M Collegamento tra form html e script php PHP 4
M Problemi con la stampa dei valori in php PHP 1
W [Cerco collaborazioni] Sviluppatore Web (PHP) Offerte e Richieste di Lavoro e/o Collaborazione 0
D passare valori da database sql a php PHP 1
L Ricezione dei dati su file php da modulo html PHP 6
E Inviare variabile a PHP da ciclo in JS Javascript 0
A form PHP prenotazione tramite query PHP 2
A Form php prenotazione di un azienda sanitaria locale presso studio medico PHP 1
F menù select dinamico da db in php PHP 3
L Problemi form Pagina php HTML e CSS 3
L php mysql non salva solo id PHP 21
L php mysql cerca e visualizza pagina PHP 0
F Il codice php è giusto? PHP 2
R Aggiornare record mysql con Ajax, jQuery e php Ajax 2
A invio massivo dati a file php Javascript 4
Z MySql injection PHP PHP 1
V PHP form intersecate PHP 0
I [Offro][Retribuito] Programmatore Php Offerte e Richieste di Lavoro e/o Collaborazione 0
P Funzione jQuery Ajax invio file a php jQuery 1
C Dopo chiusura del tag php la stringa html va a capo PHP 1
E Transaction php PHP 11
B ciclare file xml con PHP PHP 1
L Estrazione dati php Database 6
A Aiuto per pagina php PHP 0
E Php select option e ajax PHP 23
I Aiuto php Dependent Lookup PHP 0
T arretramento versione PHP... PHP 3
D problema php mysql PHP 1
D problema php mysql PHP 1
E Barra di avanzamento codice PHP PHP 4
G creazione menu a tendina e invio a pagina php PHP 1
A inserire variabile php colore in div html PHP 2
Z Video protetto con PHP PHP 0
Z Problema di sincronizzazione PAYPAL con PHP PHP 1
I Eecuzione di javascript in ciclo foreach php. PHP 7
S Libreria PHP per creare file dwg o dxf PHP 0
A [cerco - retribuito] Sviluppatore Php freelance per progetti vari Offerte e Richieste di Lavoro e/o Collaborazione 2
L Google chart php mysql PHP 2
R Download file multipli da directory php PHP 0
F pagina dinamica PHP PHP 3
P Rimozione automatica url da sitemap.xml con PHP PHP 1
L php tinymce mi duplica la classe label PHP 3
S Errore PHP - Notice: Undefined index ... PHP 14
N file manager da php 5 a 7 PHP 15
M Utilizzare la funzione mysql_num_rows() in PHP 5 PHP 3
elpirata Update dinamico informazioni scritte in una pagina php jQuery 11
N Mysql_result per PHP 7 PHP 2

Discussioni simili