Websocket While

  • PHP

    Websocket While

    Hallo Zusammen :)

    ich arbeite an einer Seite die sich mit einem Websocket in meinem Localen Netzwerk befindet verbindet. Ein kleiner ausschnitt vom dem Script sieht so aus:

    Quellcode

    1. ​
    2. while (true) {
    3. $changed = $clients;
    4. socket_select($changed, $null, $null, 0, 10);
    5. if (in_array($socket, $changed)) {
    6. $socket_new = socket_accept($socket);
    7. $clients[] = $socket_new;
    8. $header = socket_read($socket_new, 1024);
    9. perform_handshaking($header, $socket_new, $host, $port);
    10. socket_getpeername($socket_new, $ip);
    11. $response = mask(json_encode(array('type'=>'system', 'message'=>$ip.' connected')));
    12. send_message($response);
    13. $found_socket = array_search($socket, $changed);
    14. unset($changed[$found_socket]);
    15. }
    16. foreach ($changed as $changed_socket) {
    17. while(socket_recv($changed_socket, $buf, 1024, 0) >= 1)
    18. {
    19. $received_text = unmask($buf);
    20. $tst_msg = json_decode($received_text);
    21. $user_name = $tst_msg->name;
    22. $user_message = $tst_msg->message;
    23. $user_color = $tst_msg->color;
    24. $response_text = mask(json_encode(array('type'=>'usermsg', 'name'=>$user_name, 'message'=>$user_message, 'color'=>$user_color)));
    25. send_message($response_text);
    26. break 2;
    27. }
    29. $buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ);
    30. if ($buf === false) {
    31. $found_socket = array_search($changed_socket, $clients);
    32. socket_getpeername($changed_socket, $ip);
    33. unset($clients[$found_socket]);
    34. $response = mask(json_encode(array('type'=>'system', 'message'=>$ip.' disconnected')));
    35. send_message($response);
    36. }
    37. }
    38. }


    Es funktioniert auch alles super, bekomme auch die Message (wie z.B Connected siehe Zeile 11). Aber nun möchte ich, dass der Socket nicht nur Verbindungen aufnehmen soll sondern, auch Nachrichten Verschicken soll in einem 5 Sekunden Takt. Ich habe überlegt gehabt über eine While den befehl send_message auszuführen, aber dann hängt sich die Seite auf bzw. die Verbindung zum Socket wird unterbrochen.


    Wäre Nett wenn ihr mir dabei weiter helfen könntet, weil ich schon keine Ahnung habe, was ich nun da machen soll. ?(


    Lg. Georg

Facebook
Telefonspende