Cara menggunakan PHP dan Socket untuk mencapai komunikasi data masa nyata

Dengan perkembangan berterusan Internet, komunikasi data masa nyata telah menjadi standard untuk pelbagai aplikasi. Menggunakan PHP dan Socket untuk melaksanakan komunikasi data masa nyata adalah salah satu cara biasa. Artikel ini akan memperkenalkan cara menggunakan PHP dan Socket untuk mencapai komunikasi data masa nyata.

Soket ialah mekanisme yang digunakan untuk berkomunikasi antara aplikasi. Ia menyediakan set antara muka standard yang membenarkan aplikasi yang berbeza untuk berkomunikasi antara komputer yang berbeza. Dalam PHP, anda boleh menggunakan perpustakaan sambungan Socket untuk melaksanakan komunikasi Socket.

Melaksanakan sambungan Soket

Untuk menggunakan sambungan Soket untuk mencapai komunikasi data masa nyata, anda perlu mewujudkan sambungan Soket terlebih dahulu. Sambungan Soket biasanya terdiri daripada dua titik akhir: bahagian pelayan dan bahagian klien.

Sebelah pelayan:

$ip = '127.0.0.1';
$port = 8888;

$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_bind($server, $ip, $port);

socket_listen($server);

$client = socket_accept($server);

socket_close($server);

Pihak pelanggan:

$ip = '127.0.0.1';
$port = 8888;

$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_connect($client, $ip, $port);

socket_close($client);

Di atas adalah operasi asas untuk mewujudkan sambungan Soket, di mana objek Soket dicipta menggunakan fungsi socket_create dan dilaksanakan oleh socket_bind Untuk pengikatan setempat, fungsi socket_listen mula mendengar permintaan sambungan daripada klien Ia akan menyekat sehingga klien bersambung Fungsi socket_accept kembali objek Soket baharu. Cipta sambungan baharu. Pengendalian klien juga agak mudah Gunakan fungsi socket_connect untuk menyambung ke pelayan dan gunakan fungsi socket_close untuk menutup sambungan. socket_create 函数创建一个 Socket 对象，socket_bind 函数实现本机的绑定，socket_listen 函数开始监听来自客户端的连接请求，它会一直阻塞直到有客户端连接上来，socket_accept 函数返回一个新的 Socket 对象用于新建连接。客户端的操作也比较简单，使用 socket_connect 函数连接到服务器，并用 socket_close 函数关闭连接。

实现实时数据通信

成功建立 Socket 连接后，就可以开始进行实时数据通信了。在Socket连接中，数据是通过流传输的。服务器端可以通过 socket_recv 函数接收客户端发来的数据，而客户端可以通过 socket_send 函数向服务器端发送数据。

服务器端：

$ip = '127.0.0.1';
$port = 8888;

$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_bind($server, $ip, $port);

socket_listen($server);

$client = socket_accept($server);

while(true){
    $message = socket_recv($client, 1024, MSG_WAITALL);

    if($message === false){
        socket_close($client);
        break;
    }

    echo "收到消息: $message 
";
}

socket_close($server);

客户端：

$ip = '127.0.0.1';
$port = 8888;

$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

socket_connect($client, $ip, $port);

$message = "Hello World!";
socket_send($client, $message, strlen($message), 0);

socket_close($client);

以上是发送和接收消息的基本操作，在服务器端通过循环解决了一次只能接收一条消息的弊端。这种实时数据通信的方式使用简单、高效，若使用合理，十分有利。

使用WebSocket实现实时数据通信

WebSocket是一种基于HTTP协议的协议，可以在浏览器和服务器之间创建持久连接。在PHP中，可以使用Ratchet等第三方库来实现WebSocket通信。

实现WebSocket连接

服务端代码：

require __DIR__ . '/vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class WebSocketServer implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "有新的客户端连接：{$conn->resourceId}
";
    }

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

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "客户端离开：{$conn->resourceId}
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "发生错误：{$e->getMessage()}
";
        $conn->close();
    }

    public function run() {
        $server = RatchetServerIoServer::factory(
            new RatchetHttpHttpServer(
                new RatchetWebSocketWsServer(
                    $this
                )
            ),
            8080
        );

        echo "WebSocket服务已启动...
";

        $server->run();
    }
}

$server = new WebSocketServer();
$server->run();

以上是一个简单的WebSocket Server，使用 MessageComponentInterface 实现了四个基本方法，分别是 onOpen, onMessage, onClose, onError。 在 onOpen 方法中添加了新客户端的资源 ID 以便在客户端离开时识别出该客户端，onMessage 方法中广播了接收到的消息，onClose 方法中从客户端列表中移除离线客户端，onError 方法中处理了与客户端的连接错误。

客户端代码：

var socket = new WebSocket('ws://' + window.location.host + ':8080');

socket.onopen = function() {
    console.log('WebSocket已打开');
};

socket.onerror = function() {
    console.log('WebSocket出错');
};

socket.onmessage = function(event) {
    console.log('收到消息：' + event.data);
};

socket.onclose = function() {
    console.log('WebSocket已关闭');
};

以上是客户端代码，使用 WebSocket 对象创建了一个 WebSocket 连接，并分别处理了 onopen, onerror, onmessage, onclose 事件。在 onmessage

Komunikasi data masa nyata

Selepas berjaya mewujudkan sambungan Soket, anda boleh memulakan komunikasi data masa nyata. Dalam sambungan Soket, data dipindahkan melalui strim. Pelayan boleh menerima data daripada klien melalui fungsi socket_recv dan klien boleh menghantar data ke pelayan melalui fungsi socket_send.

Sebelah pelayan:

rrreee

Pihak pelanggan: 🎜rrreee🎜Di atas adalah operasi asas menghantar dan menerima mesej Kelemahan hanya menerima satu mesej pada satu masa diselesaikan dengan menggelung pada sisi pelayan. Kaedah komunikasi data masa nyata ini adalah mudah dan cekap untuk digunakan, dan sangat bermanfaat jika digunakan dengan betul. 🎜🎜Gunakan WebSocket untuk komunikasi data masa nyata🎜🎜WebSocket ialah protokol berdasarkan protokol HTTP yang boleh mencipta sambungan berterusan antara penyemak imbas dan pelayan. Dalam PHP, perpustakaan pihak ketiga seperti Ratchet boleh digunakan untuk melaksanakan komunikasi WebSocket. 🎜🎜Laksanakan sambungan WebSocket🎜🎜Kod pelayan: 🎜rrreee🎜Di atas ialah Pelayan WebSocket yang mudah, menggunakan MessageComponentInterface untuk melaksanakan empat kaedah asas, iaitu onOpen, onMessage, onClose, onError . Menambah ID sumber pelanggan baharu dalam kaedah onOpen untuk mengenal pasti klien apabila ia keluar, menyiarkan mesej yang diterima dalam kaedah onMessage, Pelanggan luar talian ialah dialih keluar daripada senarai klien dalam kaedah onClose dan ralat sambungan dengan klien dikendalikan dalam kaedah onError. 🎜🎜Kod pelanggan: 🎜rrreee🎜Di atas ialah kod pelanggan, yang menggunakan objek WebSocket untuk membuat sambungan WebSocket dan mengendalikan acara onopen, onerror, onmessage, onclose masing-masing. Mesej yang diterima dicetak dalam kaedah onmessage. 🎜🎜WebSocket menjadikan komunikasi masa nyata antara penyemak imbas dan pelayan lebih mudah daripada Socket tradisional. Menggunakan perpustakaan pihak ketiga seperti Ratchet untuk melaksanakan komunikasi WebSocket boleh mengurangkan kerumitan pembangunan. 🎜🎜Kesimpulan🎜🎜Melalui pengenalan di atas, kita dapat melihat bahawa menggunakan PHP dan Socket untuk mencapai komunikasi data masa nyata secara relatifnya lebih fleksibel dan boleh digunakan untuk pelbagai senario aplikasi. Pada masa yang sama, komunikasi WebSocket menggunakan perpustakaan pihak ketiga seperti Ratchet adalah lebih mudah untuk dimulakan daripada komunikasi Socket tradisional yang dilaksanakan pada bahagian pelayar dan pelayan, dan boleh mempercepatkan pembangunan komunikasi dalam masa yang lebih singkat. Pembangun boleh memilih kaedah komunikasi yang sesuai mengikut keperluan mereka sendiri. 🎜

Atas ialah kandungan terperinci Cara menggunakan PHP dan Socket untuk mencapai komunikasi data masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!