打造高并发个人微信消息发送网关
PHP结合Redis队列削峰填谷打造高并发个人微信消息发送网关在许多传统的PHP业务系统中由于PHP本身多进程/同步阻塞的特性当遇到需要同时向数千个微信用户推送通知的场景时直接发送极易导致Web服务器进程被迅速占满进而引发网关超时。本文将分享如何利用PHP结合Redis队列实现异步、削峰填谷的微信消息发送网关。一、 架构改造思路请求解耦业务代码不再直接调用外部发送接口而是将待发送的消息结构化后压入Redis队列中并瞬间返回响应。守护进程消费编写一个常驻内存的PHP CLI脚本持续从Redis队列中Pop数据并按照预设的限流规则进行发送。异常重试当某条消息因网络原因发送失败时可进行二次重试。二、 核心代码实现以下是基于PHP实现的Redis队列消费者核心逻辑。?php class WeChatQueueWorker { private $redis; private $queueName wechat_send_queue; private $apiUrl http://127.0.0.1:8080/v1/message/send; private $apiToken your_api_token_here; public function __construct() { $this-redis new Redis(); $this-redis-connect(127.0.0.1, 6379); } public function run() { echo 微信消息队列消费者已启动...\n; while (true) { try { $taskData $this-redis-brPop($this-queueName, 5); if (!empty($taskData)) { $payload json_decode($taskData[1], true); if ($payload) { $this-handleSend($payload); } } } catch (\Exception $e) { echo 捕获到异常: . $e-getMessage() . \n; sleep(2); } } } private function handleSend(array $payload) { $wxid $payload[wxid] ?? ; $message $payload[message] ?? ; echo 正在发送给 [{$wxid}] ...\n; $postData json_encode([ to $wxid, content $message ]); $ch curl_init($this-apiUrl); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_POSTFIELDS, $postData); curl_setopt($ch, CURLOPT_HTTPHEADER, [ Authorization: Bearer . $this-apiToken, Content-Type: application/json ]); curl_setopt($ch, CURLOPT_TIMEOUT, 10); $response curl_exec($ch); $httpCode curl_getinfo($ch, CURLINFO_HTTP_CODE); curl_close($ch); if ($httpCode 200) { echo 发送成功: {$wxid}\n; } else { echo 发送失败HTTP状态码: {$httpCode}\n; } usleep(500000); } } if (php_sapi_name() cli) { $worker new WeChatQueueWorker(); $worker-run(); }三、 生产环境部署建议在生产环境中建议使用进程管理工具来托管该PHP脚本确保进程在意外挂掉时自动拉起从而保障高可用性。
)
