PHP socket_write 失败仅在下次调用时返回错误

Question

我正在尝试通过 PHP 套接字发送数据，客户端是 Arduino 设备，当我多次发送时它接收数据正常，但是如果我重置客户端（Arduino 设备），它会在几秒钟内重新启动，它说连接到 PHP 套接字，然后当我想再次发送数据时，它会socket_send()默默地失败，PHP在第一个实际错误时不会返回错误，只有在我第二次尝试（并失败）时，才会返回错误（“零”socket_send()发送的字节数”）。收到此错误时，我创建另一个错误socket_accept()并成功发送消息。

什么可能导致这种情况？我希望它能够正确检测丢失的连接，以便我可以在需要时重新发送数据。

感觉就像它向旧连接发送数据，并且只有在第二次尝试时才意识到，这可能吗？

这可以通过 解决吗socket_select()？我很难理解它的作用。

澄清：如果客户端重新启动并再次连接，则向其发送数据将返回int，然后返回false, false, false（除非我取消设置$accept并再次执行 a socket_accept()）。如果客户端保持离线状态，则发送始终返回int, int, int。 int是发送的字符串的大小。

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("Could not create socket\n");

// reuse any existing open port to avoid error

socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);

$result = socket_bind($socket, $host, $port) or die("Could not bind to socket\n");

$result = socket_listen($socket) or die("Could not set up socket listener\n");

    

do{

    if(!isset($accept)){

        echo "\nwaiting for clients";

        $accept = @socket_accept($socket) or die("Could not accept incoming connection");

        echo "\nclient connected";

    }

    

    // memcached will return a message here like: "my message\r\n"

    $message_to_send = $memcached->get('my_socket_message');

    

    if($message_to_send!=''){

        echo "\nsending: ".$message_to_send;

    

        $total_data_sent = @socket_send($accept, $message_to_send, strlen($message_to_send), MSG_EOR);

    

        // if data was not send (sent to an old connection ?!)...

        // then clear $accept, so a new connection is accepted

        // and keep the my_socket_message variable, so message is sent again

        if($total_data_sent === false){

            echo "\nSEND FAILED, will retry message: ".$message_to_send;

            unset($accept);

        } else {

            $memcached->delete('my_socket_message');

        }

    

    }

    

} while (true);

Answer 1

我进行了一些实验并能够重现该问题。这是我的解决方案（也许不是最好的方法，但有效）：@socket_send($accept, $message_to_send, strlen($message_to_send), MSG_EOR);$dataSent = @socket_write($accept, '', 0);    if ($dataSent === false) {        unset($accept);        // ...编辑我想出了一个更简洁的解决方案。我们只是做函数socket_send应该做的事情。返回false或int接收到的字节数。在接收端，您只需解码消息 ( $data) 并发strlen回$data['payload']。客户端也可以验证它是否已收到这样的所有数据。为此，只需与strlen进行比较即可。如果你真的很偏执，你也可以实现一些校验和。$data['payload']$data['length']服务器使用的代码send而不是socket_send：function send($client, $message) {    $messageLength = strlen($message);    $data = [        'length' => $messageLength,        'payload' => $message    ];    $jsonData = json_encode($data);    try {        @socket_send($client, $jsonData, strlen($jsonData), MSG_EOR);        $response = @socket_read($client, 1024);        if (intval($response) !== $messageLength) {            return false;        }    } catch (Exception $e) {        return false;    }        return $response;}尽管这可行，但我认为 TCP 正是这样做的——确保数据已被接收。也许我们仍然缺少一些东西。

Answer 2

这就是我最终使用的，看起来效果很好。它等待来自客户端的回复/确认，如果没有收到确认，则message_to_send保留，连接被清除，在下一个循环中它重新连接并重试发送现有的message_to_send.$total_data_sent = @socket_send($accept, $message_to_send, strlen($message_to_send), MSG_EOR);// set a timeout for waiting a reply, in this case 500 millisecondssocket_set_option($accept, SOL_SOCKET, SO_RCVTIMEO, array("sec"=>0, "usec"=>500000));// read a reply, which should be "ok" (text sent by client)$reply = socket_read($accept, 1024);// if reply was not "ok", then unset the connection and will reconnect on next loopif($reply != "ok"){    unset($accept);}// if reply was "ok", then clear this message as it was successfuly sentif($reply == "ok"){    unset($message_to_send);}