PHP實現Redis消息訂閱實時監聽與郵件通知的完整教程

M66 2025-10-28

PHP中實現Redis消息訂閱與郵件通知的思路

在現代實時應用中，消息通知功能已成為必不可少的組成部分。 Redis提供的發布訂閱機制（Pub/Sub）可以讓服務端和客戶端進行實時消息交互。而在PHP中結合Swoole協程擴展，就能實現高性能、持續監聽的消息處理與郵件通知系統。

安裝所需依賴

在編寫代碼之前，需要確保環境中已安裝好Swoole和Redis擴展。 Linux系統可以通過以下命令安裝：

 pecl install swoole
pecl install redis

如果您使用的是Windows系統，可以前往PECL官網手動下載相應的DLL擴展文件進行安裝。

創建PHP監聽腳本

創建一個名為notify.php的腳本文件，用於持續監聽Redis的消息訂閱並觸發郵件發送。代碼示例如下：

 <?php
require 'vendor/autoload.php';
use Swoole\Coroutine;
use Swoole\Coroutine\Redis;

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$redis->subscribe(['channel'], function ($redis, $channel, $message) {
    // 收到消息後發送郵件通知
    sendEmail($message);
});

Coroutine::create(function () use ($redis) {
    $redis->subscribe(['channel'], function ($redis, $channel, $message) {
        // 收到消息後發送郵件通知
        sendEmail($message);
    });
});

function sendEmail($message) {
    // 使用郵件發送庫發送郵件
    // code...
}

Coroutine::create(function () use ($redis) {
    while (true) {
        $redis->ping();
        Coroutine::sleep(5);
    }
});

在以上代碼中，我們先實例化Redis客戶端並連接至Redis服務器。通過subscribe方法訂閱指定頻道，當監聽到新消息時，回調函數會被觸發，從而調用sendEmail()函數發送郵件通知。該函數可根據項目需要集成任意郵件發送庫（如PHPMailer、SwiftMailer等）。

此外，使用Swoole協程可讓程序在後台保持活躍，定時與Redis服務器進行通信以防止連接斷開。

運行監聽腳本

保存上述代碼後，在命令行執行以下命令即可啟動監聽：

 php notify.php

此腳本會保持運行狀態，持續監聽Redis頻道的消息變化，並在接收到新消息時自動發送郵件通知。

總結

通過將PHP的Swoole協程與Redis發布訂閱機制結合，我們可以高效地實現實時消息監聽與郵件通知系統。這種架構特別適合實時聊天系統、系統預警通知、數據變更推送等應用場景。它不僅簡化了異步任務的處理邏輯，還能顯著提升系統的並發性能與響應速度。