Перехват ошибок fwrite () / socket

Question

Я создаю библиотеку , которая устанавливает соединение через сокет:

public function __construct(Options $options)
{
    $this->responseBuffer = new Response();
    $this->connection = stream_socket_client($options->fullSocketAddress());

    if (!$this->isAlive($this->connection)) {
        throw new DeadSocket();
    }

    stream_set_timeout($this->connection, $this->timeout);
    $this->options = $options;
}

Отправка данных на сервер осуществляется методом send(), который выглядит следующим образом:

public function send(string $xml)
{
    try {
        fwrite($this->connection, $xml);
    } catch (Exception $e) {
        $this->options->getLogger()->error(__METHOD__ . '::' . __LINE__ . " fwrite() failed " . $e->getMessage());
        return;
    }
}

Проблема в том, что catch не фиксирует ошибки уведомления PHP, которые в моем случае являются показателем того, что само соединение разорвано.

В случае, если произошла ошибка сервера, я получаю <stream:error> (стандарт XMPP), однако, если сломался сокет или произошел какой-то тайм-аут, как этот, я не могу его перехватить:

[22 мая 2019 12:35:07 UTC] Примечание PHP: fwrite (): сбой отправки 94 байтов с ошибкой = 110 Время ожидания соединения в ... / Socket.php в строке 52

В настоящее время я хотел бы знать, произошла ли ошибка, чтобы я мог инициировать переподключение, однако выполнение любого из этих действий не показалось полезным:

if (!is_resource($this->connection)) $this->reconnect();

if (!$this->connection) $this->reconnect();

Помимо проверки любого из свойств socket_get_status(), поскольку socket_get_status($this->connection)['timed_out'] может иметь значение true даже при активном соединении.

Есть ли способ поймать это уведомление?

Также есть ли способ имитировать поведение, чтобы я мог воспроизвести его, даже если время соединения не истекло?

Answer 1

Вы можете установить только уровень, вызвав error_reporting , например:

error_reporting(E_ERROR | E_WARNING | E_PARSE | E_NOTICE);

Или вы можете установить свой собственный обработчик ошибок, используя set_error_handler . Вы также можете найти пример на странице:

<?php
// error handler function
function myErrorHandler($errno, $errstr, $errfile, $errline)
{
    if (!(error_reporting() & $errno)) {
        // This error code is not included in error_reporting, so let it fall
        // through to the standard PHP error handler
        return false;
    }

    switch ($errno) {
    case E_USER_ERROR:
        echo "<b>My ERROR</b> [$errno] $errstr<br />\n";
        echo "  Fatal error on line $errline in file $errfile";
        echo ", PHP " . PHP_VERSION . " (" . PHP_OS . ")<br />\n";
        echo "Aborting...<br />\n";
        exit(1);
        break;

    case E_USER_WARNING:
        echo "<b>My WARNING</b> [$errno] $errstr<br />\n";
        break;

    case E_USER_NOTICE:
        echo "<b>My NOTICE</b> [$errno] $errstr<br />\n";
        break;

    default:
        echo "Unknown error type: [$errno] $errstr<br />\n";
        break;
    }

    /* Don't execute PHP internal error handler */
    return true;
}

// function to test the error handling
function scale_by_log($vect, $scale)
{
    if (!is_numeric($scale) || $scale <= 0) {
        trigger_error("log(x) for x <= 0 is undefined, you used: scale = $scale", E_USER_ERROR);
    }

    if (!is_array($vect)) {
        trigger_error("Incorrect input vector, array of values expected", E_USER_WARNING);
        return null;
    }

    $temp = array();
    foreach($vect as $pos => $value) {
        if (!is_numeric($value)) {
            trigger_error("Value at position $pos is not a number, using 0 (zero)", E_USER_NOTICE);
            $value = 0;
        }
        $temp[$pos] = log($scale) * $value;
    }

    return $temp;
}

// set to the user defined error handler
$old_error_handler = set_error_handler("myErrorHandler");

// trigger some errors, first define a mixed array with a non-numeric item
echo "vector a\n";
$a = array(2, 3, "foo", 5.5, 43.3, 21.11);
print_r($a);

// now generate second array
echo "----\nvector b - a notice (b = log(PI) * a)\n";
/* Value at position $pos is not a number, using 0 (zero) */
$b = scale_by_log($a, M_PI);
print_r($b);

// this is trouble, we pass a string instead of an array
echo "----\nvector c - a warning\n";
/* Incorrect input vector, array of values expected */
$c = scale_by_log("not array", 2.3);
var_dump($c); // NULL

// this is a critical error, log of zero or negative number is undefined
echo "----\nvector d - fatal error\n";
/* log(x) for x <= 0 is undefined, you used: scale = $scale" */
$d = scale_by_log($a, -2.5);
var_dump($d); // Never reached
?>