当前位置：首页 > PHP

php 实现im

2026-02-15 00:26:09PHP

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 类处理消息：

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) {
            $client->send($msg);
        }
    }

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

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

前端连接 WebSocket

前端 JavaScript 连接 WebSocket 服务器：

const conn = new WebSocket('ws://localhost:8080');
conn.onmessage = e => console.log(e.data);
conn.send('Hello World');

数据库存储消息记录

使用 MySQL 存储聊天记录：

$pdo = new PDO('mysql:host=localhost;dbname=im_db', 'username', 'password');
$stmt = $pdo->prepare('INSERT INTO messages (sender, content, timestamp) VALUES (?, ?, ?)');
$stmt->execute([$senderId, $message, time()]);

用户认证与鉴权

通过 JWT 实现用户认证：

use Firebase\JWT\JWT;

$key = 'secret_key';
$payload = ['user_id' => 123];
$token = JWT::encode($payload, $key);

消息队列处理高并发

使用 Redis 作为消息队列缓冲：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->lPush('message_queue', json_encode(['to' => 456, 'msg' => 'Hi']));

实现私聊功能

在 onMessage 中增加目标用户判断：

php 实现im

$data = json_decode($msg, true);
if (isset($data['to'])) {
    foreach ($this->clients as $client) {
        if ($client->userId == $data['to']) {
            $client->send($data['msg']);
        }
    }
}