PHP غير متزامن

Asynchrony هو قدرة النظام البرمجي على عدم منع سلسلة التنفيذ الرئيسية.
العملية غير المتزامنة هي عملية لا تمنع تدفق تنفيذ البرنامج حتى تكتمل.

عمليات الحظر

public function update(User $user)
{
    try {
        $sql = 'UPDATE users SET ...';
        return $this->connection->execute($sql, $user->data());
    } catch (\PDOException $error) {
        log($error->getMessage());
    }

    return 0;
}

• نظام الملفات : fwrite، file_get_contents.
• قواعد البيانات : PDOConnection، RedisClient. تعمل جميع ملحقات ربط قاعدة البيانات تقريبًا في وضع الحظر افتراضيًا.
• العمليات : exec، system، proc_open. هذه عمليات حظر ، حيث أن كل العمل مع العمليات يتم من خلال مكالمات النظام.
• العمل مع المدخل / المخرج المعياري : readline، echo، print.

عميل SQL غير متزامن

public function execAsync(string $query, array $params = [])
{
    $socket = stream_socket_client('127.0.0.1:3306', ...);

    stream_set_blocking($socket, false);

    $data = $this->packBinarySQL($query, $params);
    
    socket_write($socket, $data, strlen($data));
}

وعد

الوعد هو كائن مجمّع فوق نتيجة عملية غير متزامنة. علاوة على ذلك ، لا تزال نتيجة العملية غير معروفة لنا.

كيف يعمل الوعد

interface Promise
{
    const
        STATUS_PENDING = 0,
        STATUS_RESOLVED = 1,
        STATUS_REJECTED = 2
    ;

    public function onResolve(callable $callback);
    public function onReject(callable $callback);
    public function resolve($data);
    public function reject(\Throwable $error);
}

عميل SQL غير متزامن

public function execAsync(string $query, array $params = [])
{
    $deferred = new Deferred;

    $socket = stream_socket_client('127.0.0.1:3306', ...);
    stream_set_blocking($socket, false);

    $data = $this->packBinarySQL($query, $params);
    socket_write($socket, $data, strlen($data));

    return $deferred->promise();
}

• تعيين رد الاتصال والحصول على تلك affected rowsالتي تعود إلينا PDOConnection؛
• معالجة الخطأ ، إضافة إلى السجل ؛
• أعد محاولة الاستعلام إذا استجاب خادم SQL بخطأ.

$promise = $this->execAsync($sql, $user->data());

$promise->onResolve(function (int $rows) {
    echo "Affected rows: {$rows}";
});

$promise->onReject(function (\Throwable $error) {
    log($error->getMessage());
});

حلقة الحدث

• يخبر العميل Event Loop أنه مهتم بنوع من مأخذ التوصيل.
• تستقصي حلقة الحدث نظام التشغيل من خلال استدعاء النظام stream_select: هل المقبس جاهز ، هل جميع البيانات المكتوبة ، هي البيانات القادمة من الجانب الآخر.
• إذا أفاد نظام التشغيل أن المقبس ليس جاهزًا ، فقد تم حظره ، فإن تكرار حلقة الحدث يكرر الحلقة.
• عندما يخطر نظام التشغيل أن المقبس جاهز ، ترجع Event Loop التحكم إلى العميل وتمكن ( resolveأو reject) وعد.

public static function run()
{
    while (true) {
        stream_select($readSockets, $writeSockets, null, 0);
        
        foreach ($readSockets as $i => $socket) {
            call_user_func(self::readCallbacks[$i], $socket);
        }

        // Do same for write sockets
    }
}

public function execAsync(string $query, array $params = [])
{
    $deferred = new Deferred;
    ...
    Loop::onReadable($socket, function ($socket) use ($deferred) {
        $deferred->resolve(socket_read($socket));
    });

    return $deferred->promise();
}

• JavaScript setTimeout setInterval — . N . Event Loop .
• Event Loop . process control, .

Event Loop

رد PHP

$connection = (new ConnectionFactory)->createLazyConnection();

$promise = $connection->query('UPDATE users SET ...');
$promise->then(
    function (QueryResult $command) {
        echo count($command->resultRows) . ' row(s) in set.';
    },
    function (Exception $error) {
        echo 'Error: ' . $error->getMessage();
    });

    function (QueryResult $command) {
        echo count($command->resultRows) . ' row(s) in set.';
    },

    function (Exception $error) {
        echo 'Error: ' . $error->getMessage();
    });

$promise
    ->then(function ($data) {
        return new Promise(...);
    })
    ->then(function ($data) {
        ...
    }, function ($error) {
        log($error);
    })
    ...

أمفب

$pool = Mysql\pool("host=127.0.0.1 port=3306 db=test");

try {
    $result = yield $pool->query("UPDATE users SET ...");

    echo $result->affectedRows . ' row(s) in set.';
} catch (\Throwable $error) {
    echo 'Error: ' . $error->getMessage();
}

مولدات كهرباء

function generator($counter = 1)
{
    yield $counter++;

    echo "A";

    yield $counter;

    echo "B";

    yield ++$counter;
}

$generator = generator(1);

foreach ($generator as $value) {
    echo $value;
}

while ($generator->valid()) {
    echo $generator->current();

    $generator->next();
}

Coroutines

function printer() {  
    while (true) {     
        echo yield;       
    }                             
}                                

$print = printer();
$print->send('Hello');
$print->send(' PHPRussia');
$print->send(' 2019');
$print->send('!');

function printer() {
    try {
        echo yield;
    } catch (\Throwable $e) {
        echo $e->getMessage();
    }
}

printer()->throw(new \Exception('Ooops...'));

المولدات والوعد

class Generator
{
    public function send($data);
    public function throw(\Throwable $error);
}

class Promise
{
    public function resolve($data);
    public function reject(\Throwable $error);
}

function recoil(\Generator $generator)
{
    $promise = $generator->current();

    $promise->onResolve(function($data) use ($generator) {
        $generator->send($data);
        recoil($generator);
    };

    $promise->onReject(function ($error) use ($generator) {
        $generator->throw($error);
        recoil($generator);
    });
}

    $promise->onResolve(function($data) use ($generator) {
        $generator->send($data);
        recoil($generator);
    };

تعدد المهام التعاونية

معالجة الطلب في PHP

• معالجة الأخطاء البسيطة . إذا حدث خطأ ما وسقط أحد الطلبات ، فنحن لسنا بحاجة إلى القيام بأي شيء - سيأتي الطلب التالي ، وهذا لن يؤثر على عمله.
• لا نفكر في الذاكرة . لسنا بحاجة لتنظيف أو مراقبة الذاكرة. في الطلب التالي ، سيتم مسح كل الذاكرة.

• الحد من عدد العمليات . إذا كان لدينا 50 سلسلة رسائل في الدقيقة على الخادم ، فبمجرد وصول الطلب 51 ، سينتظر حتى يصبح أحد سلاسل المحادثات مجانيًا.
• تكاليف تبديل السياق . يقوم نظام التشغيل بتبديل الطلبات بين تدفقات FPM. هذه العملية على مستوى المعالج تسمى تبديل السياق. إنها مكلفة وتدير عددًا كبيرًا من الإجراءات. من الضروري حفظ جميع التسجيلات ، مكدس الاتصال ، كل شيء موجود في المعالج ، ثم التبديل إلى عملية أخرى ، وتحميل تسجيلاته ومكدس المكالمات الخاص به ، وتنفيذ شيء هناك مرة أخرى ، والتبديل مرة أخرى ، والحفظ مرة أخرى ... لفترة طويلة.

خادم HTTP غير متزامن

Loop::run(function () {
    $app = new Application();
    $app->bootstrap();

    $sockets = [Socket\listen('0.0.0.0:80')];

    $server = new Server($sockets, new CallableRequestHandler(
        function (Request $request) use ($app) {
            $response = yield $app->dispatch($request);

            return new Response(Status::OK, [], $response);
        })
    );

    yield $server->start();
});

مشاكل

class UserRepository
{
    public function find(int $id): \Generator
    {
        $data = yield $this->db->query('SELECT ...', $id);

        return User::fill($data);
    }
}

PHP 8

class UserRepository
{
    public function find(int $id): Promise<User>
    {
        $data = await $this->db->query('SELECT ...', $id);

        return User::fill($data);
    }
}

class UserRepository
{
    public function find(int $id): Promise<User>
    {
        $data = yield $this->db->query('SELECT ...', $id);

        return User::fill($data);
    }
}

لماذا كل هذا؟

للسرعة والأداء.

13 مايو 2020 ، سوف نجتمع للمرة الثانية في PHP روسيا لمناقشة اللغة والمكتبات والأطر وطرق زيادة الإنتاجية ومزالق حلول الضجيج. لقد قبلنا التقارير الأربعة الأولى ، ولكن لا تزال دعوة للأوراق قادمة. قدم طلبك إذا كنت ترغب في مشاركة تجربتك مع المجتمع.