Données push par lots non bloquantes PHP

Aujourd'hui, j'ai vu quelqu'un sur le forum demander comment PHP peut transmettre des données au serveur par lots et de manière non bloquante. Voici un résumé approximatif.

Recommandations associées : "Tutoriel PHP"

1. La manière la plus simple :

Exécutez un script plusieurs fois en même temps et utilisez les paramètres. pour spécifier la portée des exécutions. Si vous souhaitez pousser 10 000 utilisateurs, vous pouvez exécuter un script pour 100 utilisateurs (la logique du script consiste à parcourir 100 utilisateurs et à envoyer des données en série, le code est omis), et plusieurs (100) scripts peuvent être exécutés en même temps. temps.

Similaire à :

php task.php 1 100 &
php task.php 101 200 &
php task.php 201 300 &
........

Bien sûr, cette méthode n'est pas non bloquante, mais elle peut fonctionner par lots, accélérant considérablement le traitement.

2. Gênant : si vous souhaitez un protocole HTTP non bloquant

, vous pouvez utiliser le code suivant

<?php
// 创建一对cURL资源
$ch1 = curl_init();
$ch2 = curl_init();
 
// 设置URL和相应的选项
curl_setopt($ch1, CURLOPT_URL, "http://baidu.com/");
curl_setopt($ch1, CURLOPT_HEADER, 0);
curl_setopt($ch2, CURLOPT_URL, "http://baidu.com/");
curl_setopt($ch2, CURLOPT_HEADER, 0);
 
// 创建批处理cURL句柄
$mh = curl_multi_init();
 
// 增加2个句柄
curl_multi_add_handle($mh,$ch1);
curl_multi_add_handle($mh,$ch2);
 
$active = null;
// 执行批处理句柄
do {
    $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);
 
// 轮询Server返回的结果
while ($active && $mrc == CURLM_OK) {
    if (curl_multi_select($mh) != -1) {
        do {
            $mrc = curl_multi_exec($mh, $active);
        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    }
}
 
// 汇总结果......
 
// 关闭全部句柄
curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);
curl_multi_close($mh);

3. utilisez le socket php + stream_select

<?php
// uid数组，每个uid发送一个链接
$uids = array(1,2,3,4,5,6);
// 保存socket的数组
$sockets = array();
 
// 批量创建链接并发送数据
foreach($uids as $uid)
{
    // tcp://baidu.com 改成你要访问的ip或者域名
    if(!$socket = stream_socket_client("tcp://baidu.com:80", $errno, $errstr))
    {
        echo "$errstr\n";
        continue;
    }
 
    // 根据自己的协议向服务端写入数据，这里模拟HTTP协议
    fwrite($socket, "GET / HTTP/1.1\r\nHost: www.baidu.com\r\n\r\n");
    // 设置成非阻塞
    stream_set_blocking($socket, 0);
    // 记录数组
    $sockets[(int)$socket] = $socket;
}
 
// 批量等待数据返回
while(count($sockets)>0)
{
    $read = $sockets;
    $write = $e = array();
    // 等待数据可读
    if(stream_select($read, $write, $e, 10))
    {
        // 循环读数据
        foreach($read as $socket)
        {
           // 这里是服务端返回的数据，需要的话可以循环读
           echo fread($socket, 8192);
           // 数据读取完毕关闭链接，并删除链接
           fclose($socket);
           unset($sockets[(int)$socket]);
        }
    }
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!