php异步通知怎么实现

120次阅读

共计 1372 个字符，预计需要花费 4 分钟才能阅读完成。

在 PHP 中实现异步通知可以通过以下两种方式：

使用 curl 发送异步请求：在接收到请求后，使用 curl 函数发送一个异步请求到指定的处理程序，然后立即返回响应。这样可以让请求的处理和响应的返回同时进行，从而实现异步通知。

示例代码：

// 接收到请求后立即返回响应 
header("HTTP/1.1 200 OK");
header("Content-Type: text/html; charset=utf-8");
echo "OK";

// 异步请求处理 
$url = "http://example.com/notify.php";  // 异步处理程序的 URL
$data = array("param1" => "value1", "param2" => "value2");  // 请求参数 
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_TIMEOUT, 1);  // 设置超时时间，避免请求阻塞 
curl_exec($ch);
curl_close($ch);

使用队列或消息队列系统：将接收到的请求信息存储到队列或消息队列系统中，然后由后台进程或消费者来处理。这样可以实现请求的处理和响应的返回的解耦，从而实现异步通知。

示例代码：

// 接收到请求后将请求信息存入消息队列 
$queue = new \AMQPQueue($channel);
$queue->setName('notify_queue');
$message = json_encode($_POST);
$queue->publish($message);

// 后台进程或消费者处理请求 
$connection = new \AMQPConnection(array('host' => 'localhost', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest'));
$connection->connect();
$channel = new \AMQPChannel($connection);
$queue = new \AMQPQueue($channel);
$queue->setName('notify_queue');
$queue->consume(function($envelope, $queue) {$message = $envelope->getBody();
    // 处理请求 
    // ...
    $queue->ack($envelope->getDeliveryTag());  // 确认消息已被处理 
});