当前位置：首页 > PHP

php socket实现聊天室

2026-02-27 20:52:48PHP

使用 PHP Socket 实现聊天室

创建 Socket 服务器端

PHP 使用 stream_socket_server 函数创建服务器端 Socket，监听指定端口。以下是一个简单的服务器端代码示例：

$host = '0.0.0.0';
$port = 12345;
$socket = stream_socket_server("tcp://$host:$port", $errno, $errstr);
if (!$socket) {
    die("$errstr ($errno)");
}

$clients = array();
while (true) {
    $read = $clients;
    $read[] = $socket;
    $write = $except = null;
    if (stream_select($read, $write, $except, 0) < 1) {
        continue;
    }

    if (in_array($socket, $read)) {
        $new_client = stream_socket_accept($socket);
        $clients[] = $new_client;
        $key = array_search($socket, $read);
        unset($read[$key]);
    }

    foreach ($read as $client) {
        $data = fread($client, 1024);
        if ($data === false || strlen($data) === 0) {
            $key = array_search($client, $clients);
            fclose($client);
            unset($clients[$key]);
            continue;
        }

        foreach ($clients as $send_client) {
            if ($send_client != $client) {
                fwrite($send_client, $data);
            }
        }
    }
}
fclose($socket);

创建 Socket 客户端

客户端可以使用 stream_socket_client 连接到服务器，并发送和接收消息：

$host = '127.0.0.1';
$port = 12345;
$socket = stream_socket_client("tcp://$host:$port", $errno, $errstr);
if (!$socket) {
    die("$errstr ($errno)");
}

stream_set_blocking($socket, 0);
echo "Connected to server\n";

while (true) {
    $read = array($socket);
    $write = $except = null;
    if (stream_select($read, $write, $except, 0) > 0) {
        $data = fread($socket, 1024);
        if ($data) {
            echo "Received: $data";
        }
    }

    $input = fgets(STDIN);
    if ($input) {
        fwrite($socket, $input);
    }
}
fclose($socket);

多线程处理

PHP 本身不支持多线程，但可以使用 pcntl_fork 实现多进程处理：

php socket实现聊天室

$pid = pcntl_fork();
if ($pid == -1) {
    die('Could not fork');
} else if ($pid) {
    // Parent process
} else {
    // Child process
    // Handle client connection
}

使用 WebSocket 实现网页聊天室

对于网页聊天室，可以使用 WebSocket 协议。PHP 可以通过 Ratchet 库实现 WebSocket 服务器：

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

$app = new Ratchet\App('localhost', 8080);
$app->route('/chat', new Chat);
$app->run();

前端 WebSocket 连接

前端 JavaScript 使用 WebSocket 连接到服务器：

php socket实现聊天室

const socket = new WebSocket('ws://localhost:8080/chat');
socket.onmessage = function(event) {
    console.log('Message from server:', event.data);
};

function sendMessage(message) {
    socket.send(message);
}