Основываясь на этом ответе, я переключился на библиотеку pecl-event. Теперь у меня есть:
[root]# php -v
PHP 7.1.12 (cli) (built: Nov 22 2017 08:40:02) ( NTS ) Copyright (c) 1997-2017 The PHP Group Zend Engine v3.1.0, Copyright (c) 1998-2017 Zend Technologieswith Zend OPcache v7.1.12, Copyright (c) 1999-2017, by Zend Technologies
[root]# php --info | grep event
/etc/php.d/event.ini event libevent2 headers version => 2.1.8-stable
[root]# pecl list
Installed packages, channel pecl.php.net:
=========================================
Package Version State
event 2.3.0 stable
Пример ниже ведет себя странно. Если $loop->run()
вызывается из функции runme()
, она работает и вызывается обратный вызов. Но если $loop->run()
вызывается из-за пределов runme()
, он зависает!
require_once __DIR__.'/../vendor/autoload.php';
$inner = count($argv) > 1;
$loop = new \React\EventLoop\ExtEventLoop();
//$loop = new \React\EventLoop\StreamSelectLoop();
runme($loop, $inner);
if (!$inner) {
echo "Outer start\n";
$loop->run();
}
function runme(\React\EventLoop\LoopInterface $loop, $inner)
{
$contextOpts = [];
$flags = STREAM_CLIENT_CONNECT | STREAM_CLIENT_ASYNC_CONNECT;
$context = stream_context_create($contextOpts);
$socket = stream_socket_client('tcp://127.0.0.1:3306', $errno, $errstr, 0, $flags, $context);
stream_set_blocking($socket, 0);
$loop->addWriteStream($socket, function ($socket) use ($loop) {
echo "done ".(false === stream_socket_get_name($socket, true) ? 'false' : 'true')."\n";
$loop->removeWriteStream($socket);
});
if ($inner) {
echo "Inner start\n";
$loop->run();
}
echo "Exit runme\n";
}
Результаты запуска:
[root@vultr Scraper]# php ./tests/test.php --inner
Inner start
done false
Exit runme
[root@vultr Scraper]# php ./tests/test.php
Exit runme
Outer start
...............HANGING HERE...........
Я что-то упустил или это проблема с одной из библиотек/PHP? У кого-нибудь есть опыт запуска php7.1 + react + libevent?
ОБНОВЛЕНИЕ: =============================================== =====================
Я провел тест с последней библиотекой «реагировать/сокет» «0.8.6».
require_once __DIR__.'/vendor/autoload.php';
$inner = count($argv) > 1;
$loop = new \React\EventLoop\ExtEventLoop();
$connector = new React\Socket\Connector($loop);
runme($loop, $connector, $inner);
if (!$inner) {
echo "Outer start\n";
$loop->run();
}
function runme(\React\EventLoop\LoopInterface $loop, React\Socket\Connector $connector, $inner)
{
$connector->connect('tcp://127.0.0.1:3306')->
then(function (\React\Socket\ConnectionInterface $conn) {
echo ("Hello MySQL!\n");
$conn->close();
},function ($e) {
echo ("Bye MySQL!\n");
})->done();
if ($inner) {
echo "Inner start\n";
$loop->run();
}
echo "Exit runme\n";
}
он работает правильно и возвращает:
$ php ./testMysql.php
Exit runme
Outer start
Hello MySQL!
$ php ./testMysql.php --inner
Inner start
Hello MySQL!
Exit runme
Но если вы зайдете в \React\Socket\TcpConnector::waitForStreamOnce() и удалите функцию $canceller в новом объекте Promise, как показано ниже, он снова зависнет. Похоже, это работает в последней версии реакции как бы случайно, так как сокет не хранится очевидным образом, и фактически похож на код в версии 0.4.6.
private function waitForStreamOnce($stream)
{
$loop = $this->loop;
return new Promise\Promise(function ($resolve, $reject) use ($loop, $stream) {
$loop->addWriteStream($stream, function ($stream) use ($loop, $resolve, $reject) {
$loop->removeWriteStream($stream);
// The following hack looks like the only way to
// detect connection refused errors with PHP's stream sockets.
if (false === stream_socket_get_name($stream, true)) {
fclose($stream);
$reject(new \RuntimeException('Connection refused'));
} else {
$resolve(new Connection($stream, $loop));
}
});
});
}
$ php ./testMysql.php --inner
Inner start
.....HANGING
$ php ./testMysql.php
Exit runme
Outer start
...HANGING