php如何实现消息推送

基础概念

PHP是一种广泛使用的服务器端脚本语言，特别适用于Web开发。消息推送是指服务器主动向客户端发送信息，而不是客户端轮询服务器获取信息。这种技术可以显著提高用户体验，减少服务器负载。

类型

长轮询（Long Polling）：客户端发送请求到服务器，服务器保持连接打开直到有新消息，然后响应。
WebSockets：提供全双工通信通道，允许服务器和客户端之间双向实时通信。
Server-Sent Events (SSE)：允许服务器向浏览器推送实时更新，是一种单向通信技术。

应用场景

聊天应用：实时聊天室、即时消息系统。
通知系统：邮件、短信、应用内通知。
实时数据更新：股票行情、天气预报等。

实现方法

1. 长轮询（Long Polling）

<?php
// server.php
header('Content-Type: application/json');

$clients = [];

if (isset($_POST['client_id'])) {
    $clients[$_POST['client_id']] = $_POST;
}

while (true) {
    foreach ($clients as $client_id => $client) {
        if (isset($client['last_message_id'])) {
            // 模拟从数据库获取新消息
            $new_message = getMessageFromDB($client['last_message_id']);
            if ($new_message) {
                echo json_encode(['message' => $new_message]);
                unset($clients[$client_id]);
                break;
            }
        }
    }
    usleep(100000); // 等待100毫秒
}

function getMessageFromDB($last_id) {
    // 模拟从数据库获取消息
    return ['id' => $last_id + 1, 'text' => 'New message'];
}
?>

客户端代码（JavaScript）：

function longPoll(clientId) {
    fetch('server.php', {
        method: 'POST',
        headers: {
            'Content-Type': 'application/json'
        },
        body: JSON.stringify({ client_id: clientId, last_message_id: getLastMessageId() })
    })
    .then(response => response.json())
    .then(data => {
        if (data.message) {
            console.log('New message:', data.message);
            updateLastMessageId(data.message.id);
        }
        longPoll(clientId);
    });
}

function getLastMessageId() {
    // 从本地存储获取最后一条消息的ID
    return localStorage.getItem('last_message_id') || 0;
}

function updateLastMessageId(id) {
    // 更新本地存储的最后一条消息的ID
    localStorage.setItem('last_message_id', id);
}

longPoll('client1');

2. WebSockets

使用Ratchet库实现WebSocket服务器：

<?php
// websocket_server.php
require 'vendor/autoload.php';

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new \SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();
?>

客户端代码（JavaScript）：

const socket = new WebSocket('ws://localhost:8080');

socket.onopen = function() {
    console.log('Connected');
};

socket.onmessage = function(event) {
    console.log('Message from server:', event.data);
};

socket.onclose = function() {
    console.log('Disconnected');
};

socket.onerror = function(error) {
    console.error('WebSocket Error:', error);
};