当前位置：首页 > PHP

php实现im

2026-01-29 23:33:11PHP

PHP 实现 IM（即时通讯）功能

使用 WebSocket 实现实时通讯

WebSocket 是实现即时通讯的最佳选择之一，PHP 可以通过 Ratchet 库来实现 WebSocket 服务器。

安装 Ratchet：

composer require cboden/ratchet

创建 WebSocket 服务器：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

require dirname(__DIR__) . '/vendor/autoload.php';

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

$server->run();

创建 Chat 类处理消息：

namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

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();
    }
}

使用 AJAX 轮询作为备选方案

如果无法使用 WebSocket，可以采用 AJAX 轮询的方式实现准实时通讯。

客户端 JavaScript：

function pollMessages() {
    $.ajax({
        url: 'get_messages.php',
        success: function(data) {
            // 处理收到的消息
            console.log(data);
        },
        complete: function() {
            // 继续轮询
            setTimeout(pollMessages, 1000);
        }
    });
}

服务器端 PHP (get_messages.php)：

// 查询数据库获取新消息
$messages = getNewMessagesSince($_SESSION['last_message_id']);
echo json_encode($messages);
// 更新最后获取的消息ID
$_SESSION['last_message_id'] = end($messages)->id;

数据库设计

创建消息存储表：

CREATE TABLE messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    sender_id INT NOT NULL,
    receiver_id INT NOT NULL,
    content TEXT NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    is_read BOOLEAN DEFAULT FALSE
);

用户在线状态管理

创建用户状态表：

CREATE TABLE user_status (
    user_id INT PRIMARY KEY,
    is_online BOOLEAN DEFAULT FALSE,
    last_active TIMESTAMP
);

更新用户状态：

// 用户登录时
updateUserStatus($userId, true);

// 用户退出时
updateUserStatus($userId, false);

// 定期检查不活跃用户
function checkInactiveUsers() {
    $inactiveThreshold = date('Y-m-d H:i:s', strtotime('-5 minutes'));
    $query = "UPDATE user_status SET is_online = FALSE WHERE last_active < ?";
    $stmt = $pdo->prepare($query);
    $stmt->execute([$inactiveThreshold]);
}

消息推送通知

实现消息推送可以使用 Firebase Cloud Messaging (FCM) 或 Apple Push Notification Service (APNS)。

PHP FCM 示例：

function sendPushNotification($deviceToken, $message) {
    $url = 'https://fcm.googleapis.com/fcm/send';
    $fields = [
        'to' => $deviceToken,
        'notification' => [
            'title' => '新消息',
            'body' => $message,
            'sound' => 'default'
        ]
    ];

    $headers = [
        'Authorization: key=YOUR_SERVER_KEY',
        'Content-Type: application/json'
    ];

    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($fields));
    $result = curl_exec($ch);
    curl_close($ch);

    return $result;
}