php实现异步通知
PHP实现异步通知的方法
异步通知通常用于支付回调、第三方服务状态更新等场景，要求服务端被动接收数据并处理。以下是几种常见的实现方式：
使用cURL模拟异步请求
通过cURL设置超时时间实现伪异步，主程序不等待响应：
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $notifyUrl);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data));
curl_setopt($ch, CURLOPT_RETURNTRANSFER, false); // 不获取返回内容
curl_setopt($ch, CURLOPT_TIMEOUT, 1); // 超时1秒
curl_exec($ch);
curl_close($ch);消息队列实现
通过Redis、RabbitMQ等中间件实现真正的异步处理：
// Redis示例
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->lPush('notify_queue', json_encode($data));
// 单独的处理脚本从队列消费使用pcntl_fork创建子进程
在Linux环境下使用进程分离：
$pid = pcntl_fork();
if ($pid == -1) {
die('fork失败');
} elseif ($pid == 0) {
// 子进程处理通知
processNotify($data);
exit;
}
// 父进程继续执行定时任务+数据库标记
适用于允许延迟处理的场景：
-
收到请求后写入数据库
$db->insert('notify_logs', [ 'status' => 'pending', 'data' => json_encode($_POST) ]); -
通过crontab定时处理：
-
-
-
-
- php /path/to/process_notify.php
- php /path/to/process_notify.php
-
-
-
注意事项
- 异步通知接口需要做好签名验证防止伪造请求
- 重要操作建议实现幂等性处理
- 记录完整日志便于问题排查
- HTTP超时时间根据实际业务需求调整
根据业务场景选择合适方案，高并发场景推荐使用消息队列方案，简单业务可使用cURL伪异步方案。
