PHP multithreading_PHP tutorial

PHP 5.3 and above, using the pthreads PHP extension, can make PHP truly support multi-threading. Multi-threading can greatly shorten program execution time when processing repetitive cyclic tasks.

I said in my previous article that the performance bottleneck of most websites is not on the PHP server, because it can be easily dealt with by simply increasing the number of server or CPU cores horizontally (for each It is more convenient to add a VPS or CPU core to a cloud host. You can add a VPS directly with a backup image, and there is no need to install or configure the operating system or environment.) Instead, it depends on the MySQL database. If you use a MySQL database and a joint query SQL, you may be able to handle the business logic. However, if you encounter a large number of concurrent requests, you will stop working. If you use a NoSQL database, it may take ten queries to process the same business logic, but each query is faster than MySQL. Ten loop NoSQL queries may be faster than a MySQL joint query, which can handle tens of thousands of times/second. The query is totally fine. If you add PHP multi-threading, query NoSQL through ten threads at the same time, and return the result summary output, the speed will be faster. In our actual APP product, we call a PHP interface that recommends products in real time based on user preferences. PHP needs to initiate 500 to 1,000 queries to the BigSea NoSQL database to calculate the user's personalized preference product data in real time. The role of PHP multi-threading is very obvious.

PHP extension download: https://github.com/krakjoe/pthreads
PHP manual document: http://php.net /manual/zh/book.pthreads.php

1. Extended compilation and installation (Linux), editing parameter --enable-maintainer-zts is required:

cd /Data/tgz/php-5.5.1
./configure --prefix=/Data/apps/php --with-config-file-path=/Data/apps/php/etc --with-mysql =/Data/apps/mysql --with-mysqli=/Data/apps/mysql/bin/mysql_config --with-iconv-dir --with-freetype-dir=/Data/apps/libs --with-jpeg- dir=/Data/apps/libs --with-png-dir=/Data/apps/libs --with-zlib --with-libxml-dir=/usr --enable-xml --disable-rpath --enable -bcmath --enable-shmop --enable-sysvsem --enable-inline-optimization --with-curl --enable-mbregex --enable-fpm --enable-mbstring --with-mcrypt=/Data/apps/ libs --with-gd --enable-gd-native-ttf --with-openssl --with-mhash --enable-pcntl --enable-sockets --with-xmlrpc --enable-zip --enable-soap --enable-opcache --with-pdo-mysql --enable-maintainer-zts
make clean
make
make install   

unzip pthreads-master.zip
cd pthreads -master
/Data/apps/php/bin/phpize
./configure --with-php-config=/Data/apps/php/bin/php-config
make
make install

vi /Data/apps/php/etc/php.ini

Add:

extension = "pthreads.so"

2. Give a PHP multi-threading and For loop to capture the PHP code example of Baidu search page:

 

2.   class test_thread_run extends Thread   
3.   {  
4.       public $url;  
5.       public $data;  
6.   
7.       public function __construct($url)  
8.       {  
9.           $this->url = $url;  
10.       }  
11.   
12.       public function run()  
13.       {  
14.           if(($url = $this->url))  
15.           {  
16.               $this->data = model_http_curl_get($url);  
17.           }  
18.       }  
19.   }  
20.   
21.   function model_thread_result_get($urls_array)   
22.   {  
23.       foreach ($urls_array as $key => $value)   
24.       {  
25.           $thread_array[$key] = new test_thread_run($value["url"]);  
26.           $thread_array[$key]->start();  
27.       }  
28.   
29.       foreach ($thread_array as $thread_array_key => $thread_array_value)   
30.       {  
31.           while($thread_array[$thread_array_key]->isRunning())  
32.           {  
33.               usleep(10);  
34.           }  
35.           if($thread_array[$thread_array_key]->join())  
36.           {  
37.               $variable_data[$thread_array_key] = $thread_array[$thread_array_key]->data;  
38.           }  
39.       }  
40.       return $variable_data;  
41.   }  
42.   
43.   function model_http_curl_get($url,$userAgent="")   
44.   {  
45.       $userAgent = $userAgent ? $userAgent : 'Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.2)';   
46.       $curl = curl_init();  
47.       curl_setopt($curl, CURLOPT_URL, $url);  
48.       curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);  
49.       curl_setopt($curl, CURLOPT_TIMEOUT, 5);  
50.       curl_setopt($curl, CURLOPT_USERAGENT, $userAgent);  
51.       $result = curl_exec($curl);  
52.       curl_close($curl);  
53.       return $result;  
54.   }  
55.   
56.   for ($i=0; $i < 100; $i++)   
57.   {   
58.       $urls_array[] = array("name" => "baidu", "url" => "http://www.baidu.com/s?wd=".mt_rand(10000,20000));  
59.   }  
60.   
61.   $t = microtime(true);  
62.   $result = model_thread_result_get($urls_array);  
63.   $e = microtime(true);  
64.   echo "多线程：".($e-$t)."n";  
65.   
66.   $t = microtime(true);  
67.   foreach ($urls_array as $key => $value)   
68.   {  
69.       $result_new[$key] = model_http_curl_get($value["url"]);  
70.   }  
71.   $e = microtime(true);  
72.   echo "For循环：".($e-$t)."n";  
73. ?>