Невозможно сделать неблокирующий ввод / вывод в React PHP - PullRequest
Новая
       9

Невозможно сделать неблокирующий ввод / вывод в React PHP

0 голосов
/ 04 мая 2018

Я пытаюсь вставить запись в базу данных, поступающую на сервер реагирующих сокетов. Я заблудился о том, как выполнять свою работу неблокирующим образом 

$loop = Factory::create();

$server = new Server('127.0.0.1:4040', $loop);
$database = new Database();

$server->on('connection', function(ConnectionInterface $conn)  use ($database) {
    $conn->write('Welcome, you can start writing your notes now...');

    $conn->on('data', function($data) use ($conn, $database) {
        $database->write($data);
        $conn->write('I am supposed to execute before database write');
    });
});

$loop->run();

Метод write в базе данных имеет sleep(10) секунд до выполнения оператора sql. Поэтому я ожидаю, что следующее сообщение I am supposed to.. должно быть напечатано немедленно.

Я ожидал, что когда будет операция ввода-вывода, операция будет перемещена в таблицу событий и не будет блокировать стек вызовов. Согласно определению цикла событий и неблокирования.

Как я могу выполнить ту же операцию неблокирующим образом.

Спасибо

1 Ответ

0 голосов
/ 04 мая 2018

Привет, член команды ReactPHP здесь. Цикл ожидает, что все будет асинхронным, поэтому поместите режим сна в вашу базу данных $ database-> write ($ data); заблокирует цикл. Ваше соединение с базой данных должно использовать цикл обработки событий, чтобы оно было неблокирующим. Мое предложение было бы посмотреть на https://github.com/friends-of-reactphp/mysql или https://github.com/voryx/PgAsync или проверить список здесь https://github.com/reactphp/react/wiki/Users#databases в зависимости от вашей базы данных. ReactPHP волшебным образом не сделает все неблокирующим, вы должны использовать пакеты, которые позаботятся об этом за вас.

...