curl - How to implement asynchronous operation in php without installing extensions

After I received the request processing, there was a very time-consuming operation that required requesting the WeChat interface. It required processing many orders and calling the WeChat interface. I want to perform these operations after echo. Message queue needs to install extensions such as memcacheq on the server. I do not have the right to operate the server and want to solve it with code. Is it possible to implement a message queue? Can anyone give me an example? I know nothing about queue operations. I saw that it can also be implemented using fsockopen. What is the difference between this and the message queue mechanism?

Reply content:

After I received the request processing, there was a very time-consuming operation that required requesting the WeChat interface. It required processing many orders and calling the WeChat interface. I want to perform these operations after echo. Message queue needs to install extensions such as memcacheq on the server. I do not have the right to operate the server and want to solve it with code. Is it possible to implement a message queue? Can anyone give me an example? I know nothing about queue operations. I saw that it can also be implemented using fsockopen. What is the difference between this and the message queue mechanism?

<code>//程序被阻塞10秒
shell_exec('timeout 10 vmstat 1 >/dev/null 2>&1 &');
//程序不会被阻塞
pclose(popen('timeout 10 vmstat 1 >/dev/null 2>&1 &', 'r'));
//因此可以异步执行任务
pclose(popen("timeout 60 php /path/to/task.php '$arg' >/dev/null 2>&1 &", 'r'));
</code>

The variable $arg is the parameter passed to the script task.php. This parameter is obtained through $argv[1] in task.php.
timeout 60 means the maximum execution time of the task.php script is 60 seconds. It can be removed if not needed. .
The essence of asynchronous implementation by pclose(popen()) is to open a process to execute blocking code.
It is suitable for asynchronous scenarios that do not require automatic return of results (callbacks) after execution is completed.

The string parameter $arg can be enclosed in single quotes, which can avoid the impact of some spaces, but it still has flaws.
In order to avoid Shell injection (compared to SQL injection), it is best to serialize the string parameter to a file,
Then Pass the file path parameter to the script task.php, and let task.php read the file, unserialize, deserialize and get the data.
The file name should be unique, for example, it can be user ID + process PID + time random number:

<code>$filename = md5(uniqid($uid.'_'.getmypid().'_'.mt_rand().'_', true));
</code>

The function fastcgi_finish_request provided by PHP-FPM can flush all response data to the client and end the request. This allows the client to continue executing code that does not need to be output to the user after ending the connection, such as generating cache, but Will still block the current FPM worker process.
http://php.net/manual/zh/func...

fsockopen means making a request (similar to curl), but not waiting for the result to be returned.

So you can also use fsockopen. After you echo, fsockopen requests the local operation of the WeChat interface and it will be fine