Antara muka API PHP: Cara menggunakan WebSockets

PHP ialah bahasa skrip bahagian pelayan sumber terbuka yang biasa digunakan untuk membina tapak web dinamik dan aplikasi web. Antara muka API PHP biasanya disediakan melalui protokol HTTP, tetapi dengan peningkatan permintaan aplikasi web moden, pengemaskinian data masa nyata menjadi lebih penting. Ini memerlukan penggunaan WebSockets untuk komunikasi dua hala untuk bertindak balas terhadap perubahan dengan lebih pantas.

WebSockets ialah jenis saluran komunikasi baharu antara pelanggan dan pelayan dalam HTML5. Ia menyediakan penghantaran data dua hala masa nyata dengan mengekalkan sambungan untuk masa yang lama. Tidak seperti permintaan HTTP, WebSockets membuka soket TCP pada sambungan WebSocket dan bukannya membuat satu dengan setiap permintaan. Ini bermakna WebSockets membolehkan pemindahan data masa nyata lebih cepat dan lebih mudah daripada permintaan HTTP.

Artikel ini akan memperkenalkan cara menggunakan antara muka API PHP untuk berkomunikasi dengan WebSockets untuk mengemas kini data dalam aplikasi web dalam masa nyata.

1. Pasang Ratchet
Untuk menggunakan WebSockets, anda perlu memasang Ratchet, perpustakaan WebSocket yang sangat popular dalam PHP. Anda boleh memuat turun Ratchet daripada Github dan menambahnya pada projek anda, atau memasangnya menggunakan Komposer.

Jika anda menggunakan Composer, anda boleh melaksanakan arahan berikut:

composer require cboden/ratchet

Ini akan memasang Ratchet secara automatik. Setelah dipasang, anda akan dapat mencipta pelayan WebSocket menggunakan kelas WebSocket Servernya.

2. Cipta Pelayan WebSocket
Menggunakan Ratchet, anda boleh mencipta pelayan WebSocket untuk komunikasi masa nyata dengan pelanggan. Berikut ialah kod contoh pelayan WebSocket asas:

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

require_once(__DIR__ . '/vendor/autoload.php');

class MyWebSocket implements MessageComponentInterface
{
    public function onOpen(ConnectionInterface $conn)
    {
        // 当有新客户端连接时执行
        echo "New connection! ({$conn->resourceId})
";
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        // 接收消息
        echo "Received message: {$msg}
";
    
        // 回复消息
        $from->send('Data received: ' . $msg);
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 当客户端断开连接时执行
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // 当出现错误时执行
        echo "An error has occurred: {$e->getMessage()}
";
    
        $conn->close();
    }
}

// 创建WebSocket服务器
$server = IoServer::factory(
    new WsServer(
        new MyWebSocket()
    ),
    8080
);

// 启动WebSocket服务器
$server->run();

Kod di atas mencipta pelayan WebSocket yang boleh menerima sambungan pelanggan dari port 8080. Ia tidak mempunyai sebarang logik perniagaan sebenar, hanya mencetak sambungan, mesej dan memutuskan sambungan. Anda boleh menggunakan ini sebagai titik permulaan dan menyesuaikan kelas pelayan WebSocket anda sendiri mengikut keperluan.

3. Pelanggan menggunakan API WebSocket
Di sisi pelanggan, anda boleh menggunakan API WebSocket untuk mewujudkan sambungan dengan pelayan dan menghantar serta menerima mesej. Berikut ialah contoh WebSocket pelanggan paling mudah:

var connection = new WebSocket('ws://localhost:8080');

connection.onopen = function () {
    console.log('WebSocket connected');
  
    // 发送消息
    connection.send('Hello, WebSocket server!');
};

connection.onmessage = function (event) {
    console.log('Received message: ' + event.data);
};

connection.onclose = function (event) {
    console.log('WebSocket connection closed with code ' + event.code + ' and reason: ' + event.reason);
};

connection.onerror = function (error) {
    console.log('WebSocket error: ' + error.message);
};

Kod ini akan cuba menyambung ke pelayan WebSocket yang baru kami tulis. Apabila acara sambungan diterima, ia menghantar mesej. Apabila mesej diterima daripada pelayan, ia log mesej ke konsol. Juga mengendalikan penutupan sambungan dan situasi ralat.

4. Menggunakan WebSockets melalui antara muka API PHP
Sekarang mari kita pertimbangkan cara berkomunikasi dengan WebSockets menggunakan antara muka API PHP. Anda boleh menggunakan penghala API tradisional untuk mengendalikan permintaan WebSocket. Apabila pelanggan menyambung ke pelayan WebSocket, anda boleh menggunakan antara muka ConnectionInterface Ratchet WebSocket untuk mendapatkan maklumat yang berkaitan. Anda juga boleh menggunakan maklumat ini untuk mengesahkan sambungan dan memastikan bahawa hanya pengguna yang disahkan boleh menyambung ke pelayan WebSocket.

Berikut ialah contoh kod:

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

require_once(__DIR__ . '/vendor/autoload.php');

// 自定义WebSocket服务器类
class MyWebSocket implements MessageComponentInterface
{
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        // 将新连接存储到$clients
        $this->clients->attach($conn);
    
        // 获取客户端地址
        $client_ip = $conn->remoteAddress;
    
        // 处理新连接（验证身份、发送欢迎消息等）
        // ...
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        // 处理收到的消息
        // ...
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 从$clients中删除关闭连接
        $this->clients->detach($conn);

        // 处理关闭连接
        // ...
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // 处理WebSocket错误
        // ...
        
        // 关闭连接
        $conn->close();
    }
}

// 创建WebSocket服务器
$server = IoServer::factory(
    new WsServer(
        new MyWebSocket()
    ),
    8080
);

// 启动WebSocket服务器
$server->run();

Dalam kaedah onOpen, kami boleh melakukan beberapa pemprosesan, seperti mengesahkan sambungan, menghantar mesej alu-aluan kepada pelanggan dan mengelog sambungan baharu. Dalam kaedah onClose, kami boleh mengendalikan acara menutup sambungan, seperti mengalih keluar sambungan daripada senarai dan menghantar pemberitahuan luar talian kepada pelanggan lain.

Dalam kaedah onMessage, kami boleh mengendalikan mesej yang dihantar oleh klien WebSocket. Memandangkan WebSocket ialah saluran komunikasi dua hala, ini bermakna pelanggan juga boleh menghantar mesej kepada pelayan, bukannya hanya pelayan menghantar mesej kepada pelanggan, yang sangat meningkatkan keupayaan aplikasi untuk menghantar dan menerima data.

Dengan berkomunikasi dengan WebSockets melalui antara muka API PHP, anda boleh mengemas kini data dalam masa nyata, yang sangat penting untuk aplikasi masa nyata seperti transaksi masa nyata, push mesej dan aplikasi permainan.

Atas ialah kandungan terperinci Antara muka API PHP: Cara menggunakan WebSockets. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!