Research on the implementation of asynchronous operations in PHP Ancient poems about spring Quotes about reading Handwritten notes about reading

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 in batches, etc., 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 wonderful, but actually it's also a pitfall...

2. Can PHP implement asynchronous operations?

The answer is yes, but 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 the web server is not killed...

Is there any other better way to achieve 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, just say that it has many clients and supports clients in many languages. You can use most of your favorite languages ​​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 the Gearman plug-in, it 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 well, I I don’t really trust workers 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 start the test code:

<ol>
<li><span><span><?php  </span></span></span></li>
<li>
<span>require_once</span><span> </span><span>'PHPAsyncClient.php'</span><span>;  </span>
</li>
<li>
<span>date_default_timezone_set(</span><span>'Asia/Shanghai'</span><span>);  </span>
</li>
<li><span> </span></li>
<li>
<span>class</span><span> AsyncTest {  </span>
</li>
<li><span> </span></li>
<li>
<span>    </span><span>const</span><span> </span>
</li>
<li>
<span>        LOG_FILE = </span><span>'/debug.log'</span><span>;  </span>
</li>
<li><span> </span></li>
<li>
<span>    </span><span>static</span><span> </span><span>public</span><span> </span><span>function</span><span> run() {  </span>
</li>
<li>
<span>        </span><span>if</span><span> (PHPAsyncClient::in_callback(</span><span>__FILE__</span><span>)) {  </span>
</li>
<li>
<span>            self::log(</span><span>'php Async callback'</span><span>);  </span>
</li>
<li><span>            PHPAsyncClient::parse();  </span></li>
<li>
<span>            </span><span>return</span><span>;  </span>
</li>
<li><span>        }  </span></li>
<li>
<span>        </span><span>if</span><span> (PHPAsyncClient::is_main(</span><span>__FILE__</span><span>)) {  </span>
</li>
<li>
<span>            self::log(</span><span>'main run'</span><span>);  </span>
</li>
<li>
<span>            </span><span>$async_call</span><span> = PHPAsyncClient::getInstance();  </span>
</li>
<li>
<span>            </span><span>$async_call</span><span>->AsyncCall(</span><span>'AsyncTest'</span><span>, </span><span>'callback'</span><span>, </span><span>array</span><span>(  </span>
</li>
<li>
<span>                </span><span>'content'</span><span> => </span><span>'Hello World!!!'</span><span>,  </span>
</li>
<li>
<span>            ), </span><span>array</span><span>(  </span>
</li>
<li>
<span>                </span><span>'class'</span><span> => </span><span>'AsyncTest'</span><span>,  </span>
</li>
<li>
<span>                </span><span>'method'</span><span> => </span><span>'callback'</span><span>,  </span>
</li>
<li>
<span>                </span><span>'params'</span><span> => </span><span>array</span><span>(  </span>
</li>
<li>
<span>                    </span><span>'content'</span><span> => </span><span>'Hello Callback!'</span><span>,  </span>
</li>
<li><span>                ),  </span></li>
<li>
<span>            ), </span><span>__FILE__</span><span>);  </span>
</li>
<li>
<span>            </span><span>return</span><span>;  </span>
</li>
<li><span>        }  </span></li>
<li><span>    }  </span></li>
<li><span> </span></li>
<li>
<span>    </span><span>static</span><span> </span><span>public</span><span> </span><span>function</span><span> callback(</span><span>$args</span><span>) {  </span>
</li>
<li>
<span>        self::log(</span><span>'AsyncTest callback run'</span><span>);  </span>
</li>
<li>
<span>        self::log(</span><span>'AsyncTest callback args:'</span><span>.print_r(</span><span>$args</span><span>, true));  </span>
</li>
<li><span>    }  </span></li>
<li><span> </span></li>
<li>
<span>    </span><span>static</span><span> </span><span>public</span><span> </span><span>function</span><span> log(</span><span>$content</span><span>) {  </span>
</li>
<li>
<span>        </span><span>$fullname</span><span> = dirname(</span><span>__FILE__</span><span>).self::LOG_FILE;  </span>
</li>
<li>
<span>        </span><span>$content</span><span> = </span><span>date</span><span>(</span><span>'[Y-m-d H:i:s]'</span><span>).</span><span>$content</span><span>.</span><span>"\n"</span><span>;  </span>
</li>
<li>
<span>        </span><span>file_put_contents</span><span>(</span><span>$fullname</span><span>, </span><span>$content</span><span>, FILE_APPEND);  </span>
</li>
<li><span>    }  </span></li>
<li><span>}  </span></li>
<li><span> </span></li>
<li><span>AsyncTest::run(); </span></li>
</ol>

There are only 3 static methods, one is the log method for debugging, and the others are literal. This example is a preliminary impression of this calling method. Then directly upload all the source code of PHP:

php_async.zip

Then there should be many people saying that gearman cannot be installed under win... So I will also put the java version of gearman server.

java-gearman-service-0.6.6.zip

5. Conclusion

After configuring a thing as big as a rhinoceros (to install a Gearman and run a Py script), we basically made PHP own In addition to the asynchronous calling function, of course there is also a state maintenance function that needs to be implemented by yourself. 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.

Original link: http://my.oschina.net/wakanoc/blog/101789

The above introduces the research on the implementation of asynchronous operations in PHP, including PHP, and related aspects. I hope it will be helpful to friends who are interested in PHP tutorials.