PHP如何对接消息推送

wen PHP项目 2026-08-11 7

本文目录导读：

PHP如何对接消息推送

📚 目录导读
什么是消息推送？为什么PHP项目需要它？
消息推送的主流协议与渠道选型
PHP对接消息推送的三种核心方式
实战演练：用PHP + cURL对接FCM
踩坑避雷：Token过期、重试机制、并发与性能优化
PHP推送服务的架构升级：从同步脚本到消息队列
高频问答（FAQ）

PHP如何对接消息推送？从入门到生产级应用的完整实战指南**

📚 目录导读

什么是消息推送？为什么PHP项目需要它？
消息推送的主流协议与渠道选型（APNs / FCM / 极光 / 钉钉 / WebSocket）
PHP对接消息推送的三种核心方式（HTTP API / 长连接 / 异步队列）
实战演练：用PHP + cURL对接FCM（Firebase Cloud Messaging）
踩坑避雷：Token过期、重试机制、并发与性能优化
PHP推送服务的架构升级：从同步脚本到消息队列（Redis + Supervisor）
高频问答（FAQ）

什么是消息推送？为什么PHP项目需要它？

消息推送（Push Notification）是指服务器主动向客户端（App、Web、小程序）发送数据，而非客户端轮询请求，对于PHP开发者而言，最常见场景是：用户下单后通知配送员、系统告警发到钉钉群、或者运营活动触达App用户。

关键认知：PHP本身不擅长维持长连接，但这并不妨碍它成为推送的“指挥中枢”——使用HTTP/2协议调用苹果或谷歌的推送网关，或者通过WebSocket与客户端保持心跳,都是成熟方案。

消息推送的主流协议与渠道选型

渠道	适用对象	协议
FCM	Android / iOS	HTTP v1 API
APNs	iOS	HTTP/2 + JWT
极光推送	国内双端	REST API
钉钉群机器人	企业IM	Webhook
WebSocket	网页实时通知	长连接（需Workerman）

选型建议：国内ToC应用优先选极光、阿里云移动推送（封装了APNs和厂商通道）；ToB内部告警或工单通知用钉钉/飞书机器人；若您是纯PHP团队且不想引入SDK，FCM的REST API是最纯粹的练手靶场。

PHP对接消息推送的三种核心方式

（1）HTTP API 同步调用（最常用）

// 以FCM为例，POST JSON到https://fcm.googleapis.com/v1/projects/{project_id}/messages:send

（2）长连接（适合聊天类）

使用Swoole或Workerman常驻内存，维护WebSocket连接表，PHP-FPM生命周期太短，不适合直接用stream_socket_client保持长连。

（3）异步任务队列（生产必备）

推送是IO密集操作，必须解耦，将推送任务放入Redis List，由常驻Worker消费,防止请求阻塞。

实战演练：用PHP + cURL对接FCM

前置条件：在Firebase控制台创建项目，下载服务账号JSON文件，获取project_id。

Step1：生成Access Token（使用Google Auth库）

composer require google/auth

use Google\Auth\Credentials\ServiceAccountCredentials;
use Google\Auth\HttpHandler\HttpHandlerFactory;
$cred = new ServiceAccountCredentials(
    ['https://www.googleapis.com/auth/firebase.messaging'],
    'path/to/service-account.json'
);
$token = $cred->fetchAuthToken(HttpHandlerFactory::build());
$accessToken = $token['access_token'];

Step2：构建并发送推送消息

$projectId = 'your-project-id';
$url = "https://fcm.googleapis.com/v1/projects/{$projectId}/messages:send";
$payload = [
    'message' => [
        'token' => '客户端设备的FCM Token',
        'notification' => [
            'title' => 'PHP推送测试',
            'body'  => '这是一条来自Laravel的问候'
        ]
    ]
];
$ch = curl_init($url);
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer ' . $accessToken,
        'Content-Type: application/json'
    ],
    CURLOPT_POSTFIELDS => json_encode($payload),
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 10
]);
$response = curl_exec($ch);
curl_close($ch);
echo $response; // {"name":"projects/.../messages/..."}

踩坑避雷：Token过期、重试机制、并发与性能优化

Token生命周期：FCM Token会因App重装、卸载而失效，建议数据库记录last_sent_at，每次推送后检测返回的UNREGISTERED错误码,并异步清理无效Token。
重试策略：封装中间件，对超时或5xx错误做指数退避重试（1s、2s、4s，最多3次），但注意：Notification类消息有重复推送风险，业务侧需要幂等键（如订单号）。
并发优化：批量推送时，不要for循环同步cURL，用curl_multi_init()或Guzzle的Pool实现并发请求,提升10倍吞吐。

PHP推送服务的架构升级：从同步脚本到消息队列

核心痛点：一个订单完成需要推送3个人（商家、骑手、用户），若同步处理，PHP-FPM进程会挂起等待外部响应,高并发下直接打爆。

解决方案：

// 1. 生产者：Controller中仅入队
Redis::lpush('push_queue', json_encode(['user_id'=>1, 'payload'=>$payload]));
// 2. 消费者：独立的CLI脚本（配合Supervisor守护）
while ($task = Redis::brpop('push_queue', 5)) {
    $data = json_decode($task[1], true);
    try {
        $result = pushToFcm($data);
    } catch (\Exception $e) {
        Redis::lpush('push_retry_queue', $task[1]); // 二次重试队列
    }
}

架构收益：API响应时间从300ms降至5ms；推送失败不影响主流程；可水平扩展Worker数量。

高频问答（FAQ）

Q1：PHP对接苹果APNs必须用JWT吗？ 是的，新版APNs要求提供基于ES256算法的JWT token（由.p8密钥生成），直接用cURL发送HTTP/2请求即可,无需引入复杂SDK。

Q2：WebSocket推送和HTTP推送有什么区别？ WebSocket适合服务端主动下发的实时双向通信（如聊天），而HTTP推送是“一次请求一次回应”，PHP做WebSocket可使用Swoole或Workerman来常驻内存，传统PHP-FPM无法实现。

Q3：推送消息丢了怎么办？ 必须建立最终一致性机制：例如将“待推送记录”写入MySQL，Worker消费成功后修改状态，若发现超时未推送,则通过定时任务扫表重发。

Q4：国内不用FCM，PHP怎么接华为/小米推送？ 各家均有REST接口，逻辑类似，仅需要注册各自开发者平台，获取app_id和app_secret，签名方式可能用到MD5或HMAC-SHA256。

Q5：既然有第三方推送平台，PHP还需要自己写对接吗？ 视情况而定，使用极光等平台，你只需处理其SDK返回码，这能帮你规避直连APNs的复杂性和设备碎片化问题，但如果追求成本和可控性,自己对接核心推送网关是值得投资的技术储备。

延伸建议：若项目跑在腾讯云/阿里云，可优先考虑其自带的移动推送服务（封装了厂商通道，且提供PHP SDK），能显著降低失效Token的占比，但无论如何，理解上述HTTP通信与队列解耦原理,才是PHP工程师进阶架构师的必经之路。