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

Question

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

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

感觉就像它发送数据到一个旧的连接，只是在第二次尝试时才意识到，这可能吗？

socket_select() 可以解决这个问题吗？我很难理解它的作用。

澄清：如果客户端重新启动并再次连接，则向其发送数据返回int，然后返回false、false、false（除非我取消设置$accept 并再次执行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) 并发送回$data['payload'] 的strlen。客户端也可以验证它是否已收到所有这样的数据。为此，只需将$data['payload'] 中的strlen 与$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 milliseconds
socket_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 loop
if($reply != "ok"){
    unset($accept);
}

// if reply was "ok", then clear this message as it was successfuly sent
if($reply == "ok"){
    unset($message_to_send);
}