别再手动发通知了！用ThinkPHP 6.2 + uni-push 2.0 实现APP消息自动推送（附完整代码）

别再手动发通知了用ThinkPHP 6.2 uni-push 2.0 实现APP消息自动推送附完整代码每次用户下单后还要手动点击发送通知系统公告需要运营人员逐个页面操作这种低效方式早该淘汰了。本文将带你用ThinkPHP 6.2和uni-push 2.0构建一个全自动消息推送系统让重要通知像流水一样自然触达用户终端。1. 环境准备与基础配置在开始编码前我们需要完成几个关键配置。uni-push 2.0作为DCloud推出的全端推送服务相比1.0版本在送达率和功能完整性上都有显著提升。以下是必须完成的准备工作Android证书生成步骤登录DCloud开发者中心找到对应应用进入Android云端证书页面点击创建证书并记录SHA1、MD5等关键信息配置推送模块时特别注意以下参数// manifest.json配置示例 { push: { unipush: { enable: true, android: { packageName: com.yourcompany.app } } } }提示包名(PackageName)必须与证书完全一致否则会导致推送失败2. 客户端初始化与权限处理用户首次启动APP时我们需要完成两件关键事初始化推送服务和检查通知权限。以下是经过实战检验的最佳实践方案// unipush.js export function initPush() { checkNotificationPermission() setupPushListener() } function checkNotificationPermission() { // Android权限检查 if (plus.os.name Android) { const context plus.android.importClass(android.content.Context) const notificationManager plus.android.importClass( android.app.NotificationManager ) const areEnabled notificationManager.from(context).areNotificationsEnabled() if (!areEnabled) { showPermissionDialog() } } // iOS权限检查省略... } function setupPushListener() { uni.onPushMessage(res { switch(res.type) { case receive: handleReceivedMessage(res.data) break case click: handleMessageClick(res.data) break } }) }常见问题处理权限被拒绝建议在设置页面增加引导图示推送不显示检查手机系统通知设置和APP图标华为/小米等国产机型需要单独配置厂商通道3. 服务端集成方案设计ThinkPHP 6.2的事件系统与uni-push简直是天作之合。我们可以将推送逻辑封装成服务类通过事件监听实现完全解耦。下面是我在电商项目中验证过的架构方案app ├── event │ └── OrderCreated.php ├── listener │ └── PushNotification.php └── service └── UniPushService.phpUniPushService核心代码namespace app\service; class UniPushService { private $appId; private $apiUrl; private $secretToken; public function __construct() { $this-appId env(UNI_PUSH_APPID); $this-apiUrl env(UNI_PUSH_URL); $this-secretToken env(UNI_PUSH_TOKEN); } public function sendToUser($userId, $title, $content, $payload []) { $clientId $this-getClientId($userId); $data [ token $this-secretToken, client_id $clientId, title $title, content $content, data json_encode($payload, JSON_UNESCAPED_UNICODE) ]; return $this-httpPost($this-apiUrl, $data); } private function httpPost($url, $data) { $ch curl_init(); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_POST, 1); curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data)); $output curl_exec($ch); curl_close($ch); return json_decode($output, true); } }4. 用户设备绑定与消息追踪可靠的推送系统必须解决设备标识绑定问题。我们采用登录绑定心跳维护的双保险机制登录绑定流程// 用户登录成功后 public function loginSuccess($user) { $clientId request()-post(client_id); if ($clientId) { UserDevice::updateOrCreate( [user_id $user-id], [client_id $clientId, last_active time()] ); } }心跳维护机制// 前端定时发送心跳 setInterval(() { uni.getPushClientId({ success: (res) { if (userLoggedIn) { api.updateDeviceId(res.cid) } } }) }, 3600000) // 每小时一次设备状态监控表设计字段类型说明user_idbigint用户IDclient_idvarchar设备标识platformvarchar设备平台last_activedatetime最后活跃时间is_validtinyint是否有效5. 实战电商订单通知系统让我们看一个完整的电商场景实现。当订单状态变化时系统自动触发相关推送// 事件定义 class OrderCreated { public $order; public function __construct(Order $order) { $this-order $order; } } // 监听器实现 class PushNotification { public function handle(OrderCreated $event) { $pushService app(unipush); $order $event-order; $pushService-sendToUser( $order-user_id, 订单创建成功, 您的订单{$order-no}已提交请及时支付, [ type order, id $order-id, jump_page /pages/order/detail?id.$order-id ] ); } }消息模板设计建议支付提醒您的订单{no}待支付还剩{time}分钟发货通知订单{no}已发货快递{express}售后处理您的售后申请#{id}已处理6. 性能优化与异常处理高并发场景下推送系统需要特别注意以下几点队列化处理// 使用ThinkPHP队列 $job new SendPushNotification($userId, $title, $content); Queue::push($job);失败重试机制public function retryFailedPush($maxAttempts 3) { FailedPush::where(attempts, , $maxAttempts) -where(next_attempt, , time()) -chunk(100, function ($items) { foreach ($items as $item) { $this-send($item-toArray()); $item-increment(attempts); $item-update([next_attempt time() 600]); } }); }监控指标送达率实际收到/应发送打开率消息点击/消息到达延迟时间触发到接收的时间差7. 高级功能扩展uni-push 2.0还支持更多实用功能可以根据业务需求逐步引入定时推送实现// 定时任务命令 class PushReminder extends Command { public function handle() { $users User::whereHas(cartItems)-get(); foreach ($users as $user) { PushJob::dispatch( $user-id, 购物车提醒, 您的购物车还有商品未结算, [type cart] )-delay(now()-addHours(24)); } } }多语言支持方案// 前端根据语言显示不同内容 uni.onPushMessage(res { const messages { order_paid: { zh: 订单已支付, en: Order paid } } const locale getAppLocale() showNotification(messages[res.data.type][locale]) })在最近的一个跨境电商项目中这套系统每天稳定处理超过50万条推送平均送达时间在300毫秒以内。最关键的收获是把client_id存储从数据库迁移到Redis后查询性能提升了8倍。