PHP implements asynchronous operations_PHP tutorial

1. Why does PHP need asynchronous operations?

Generally speaking, PHP is suitable for short-term tasks such as web page display. If you perform time-consuming operations such as resizing images, importing big data, sending EDM, SMS, etc. in batches, it is easy for operation timeouts to occur. You can say that I can set an infinite timeout, etc. You also need to know that PHP has a working mode which is fastcgi. PHP does not timeout indefinitely, which does not mean that fastcgi will not timeout... If you still want fastcgi to never timeout, I It is recommended that you discuss it with your operation and maintenance personnel...

At this time, the asynchronous operation comes into play. Since it is a non-blocking operation, the operation will return immediately, and then work slowly in the background. It doesn’t matter whether it times out or not, I’m not working under the current process/thread. Look, isn’t it beautiful, but actually it’s also a trap...

2.Can PHP implement asynchronous operations?

The answer is yes, but the various pure PHP implementations on the Internet are a bit awkward. Socket mode, suspended process mode, and some even directly fork the process. Very good, all kinds of gods show their magical powers. If the operation and maintenance personnel see it, they will definitely ××××× you. It would be strange if they don’t kill the web server...

Are there any other better ways to implement this asynchronous operation? Yes, now we only have to think about how to enable plug-ins. Check the mainstream plug-in solutions of PECL. There are a bunch of ××MQ (message queue). Among them, there is a plug-in for task distribution that comes into our sight. Gearman (actually this guy is the corner, I won’t introduce it in detail, click to connect See introduction).

3. Why choose Gearman?

If nothing else, let’s just say that it has many clients and supports clients in many languages. You can use most of the languages ​​you like to write workers. Personally, I am very annoyed by the language debate. You can use Shenma to write workers as you like. There is data persistence support (that is, the queue is saved to the database medium, so failure recovery is easy), and there is cluster support (in fact, many ××MQ have these functions). There are extensions on PECL, and there are also extensions implemented in pure PHP. Anyway, this Gearman has lived for a long time, and all the miscellaneous problems have been basically solved.

4.Basic idea

With Gearman, this plug-in is much simpler. It means sending a task to gearman, sending out the executed task, and then waiting for the worker to call the PHP cli to run our php code.

I just wrote a python worker (don’t ask me why I use python, 1. I know python, 2. I don’t need to install runtime under Linux). You can write a PHP worker based on your own ideas, but I don’t know. I really trust the worker running PHP. For other languages, you can try implementing a worker using java, node.js or other languages. Friends who are interested in writing workers in Golang can contact me.

phpasync_worker_py

Sorry, there are no comments in it. A configuration file and a py script. The basic function is to analyze the calling parameters and then call the PHP Cli, that's it. To make the py script run, please install the python gearman module yourself.

Then go to the PHP part and upload the test code first:

1. 		<?php  

   Copy after login
2. require_once 'PHPAsyncClient.php';  
3. date_default_timezone_set('Asia/Shanghai');  
4.  
5. class AsyncTest {  
6.  
7.     const 
8.         LOG_FILE = '/debug.log';  
9.  
10.     static public function run() {  
11.         if (PHPAsyncClient::in_callback(__FILE__)) {  
12.             self::log('php Async callback');  
13.             PHPAsyncClient::parse();  
14.             return;  
15.         }  
16.         if (PHPAsyncClient::is_main(__FILE__)) {  
17.             self::log('main run');  
18.             $async_call = PHPAsyncClient::getInstance();  
19.             $async_call->AsyncCall('AsyncTest', 'callback', array(  
20.                 'content' => 'Hello World!!!',  
21.             ), array(  
22.                 'class' => 'AsyncTest',  
23.                 'method' => 'callback',  
24.                 'params' => array(  
25.                     'content' => 'Hello Callback!',  
26.                 ),  
27.             ), __FILE__);  
28.             return;  
29.         }  
30.     }  
31.  
32.     static public function callback($args) {  
33.         self::log('AsyncTest callback run');  
34.         self::log('AsyncTest callback args:'.print_r($args, true));  
35.     }  
36.  
37.     static public function log($content) {  
38.         $fullname = dirname(__FILE__).self::LOG_FILE;  
39.         $content = date('[Y-m-d H:i:s]').$content."n";  
40.         file_put_contents($fullname, $content, FILE_APPEND);  
41.     }  
42. }  
43.  
44. AsyncTest::run(); 

就3个静态方法，一个是用于调试的log方法，其他都是字面意思。这个例子是对这种调用方式有个初步印象。然后直接上PHP的所有源码：

php_async.zip

然后应该会有很多人会说，win下安装不了gearman……所以我把java版的gearman server也放上去吧。

java-gearman-service-0.6.6.zip

5.结论

After configuring something as big as a rhinoceros (a Gearman needs to be installed and a Py script needs to be run), we have basically given PHP an asynchronous calling function. Of course, there is also a state maintenance feature that needs to be implemented by ourselves. So I found that this solution is actually not good and too complicated. It would be better to use some web service methods to make web callbacks (the problem is that web callbacks will also time out...), please pay attention to the follow-up.

http://www.bkjia.com/PHPjc/735076.htmlwww.bkjia.comtruehttp: //www.bkjia.com/PHPjc/735076.htmlTechArticle1. Why does PHP need asynchronous operations? Generally speaking, PHP is suitable for short-term tasks such as web page display. If it is time-consuming operations such as resizing images, importing big data,...