Use php to develop Websocket to create real-time data statistics function-PHP Tutorial-php.cn

Use php to develop Websocket to create real-time data statistics function

王林

Release： 2023-12-02 09:10:01

Original

1297 people have browsed it

Use php to develop Websocket to create real-time data statistics function

Use PHP to develop Websocket to create real-time data statistics function

Introduction:
Websocket is a full-duplex communication protocol that can communicate between the browser and the server Establish a persistent connection between them to achieve real-time communication. In Web development, Websocket is often used to implement real-time data transmission, such as real-time chat, real-time monitoring, real-time data statistics and other functions. This article will introduce how to use PHP to develop Websocket and provide specific code examples to implement real-time data statistics functions.

1. Understand Websocket
Websocket is a communication protocol based on TCP protocol, which supports two-way communication. Websocket uses ws:// (or wss://) as the URL prefix instead of the common http:// (or https://). Unlike HTTP requests, Websocket communication maintains a continuous connection rather than a request-response mode. When the connection is established, the server and client can send messages to each other at any time.

2. Build a Websocket server
In PHP, we can use the Swoole extension to build a Websocket server. Swoole is a coroutine network communication engine that provides a series of APIs to facilitate developers to use PHP language for high-performance network programming.

1. Install the Swoole extension
We can install the Swoole extension through the following command:

$ pecl install swoole

Copy after login

2. Write a Websocket server

<?php
$server = new swoole_websocket_server("0.0.0.0", 9501);

// 监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "New connection: {$request->fd}
";
});

// 监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
    // 在这里处理接收到的消息
    echo "Received message: {$frame->data}
";
});

// 监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "Connection closed: {$fd}
";
});

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

Copy after login

3. Send real-time data
In the message event of the Websocket server, we can process the received message and send data to the client based on business logic. In the real-time data statistics function, the latest data is usually sent to the client regularly.

1. Get real-time data
We can write code at the appropriate location to get the latest real-time data from the database or other sources.

2. Send data regularly

function sendMessageToAllClients($server, $message) {
    foreach ($server->connections as $fd) {
        $server->push($fd, $message);
    }
}

function sendRealtimeData($server) {
    // 获取实时数据
    $data = getDataFromDatabase();

    // 将数据转换成JSON格式
    $json = json_encode($data);

    // 发送数据给所有客户端
    sendMessageToAllClients($server, $json);
}

// 设置定时任务，每隔5秒发送最新的实时数据给所有客户端
swoole_timer_tick(5000, function ($timerId) use ($server) {
    sendRealtimeData($server);
});

Copy after login

4. Front-end page
Finally, we need to write a front-end page to display real-time data.

<!DOCTYPE html>
<html>
<head>
    <title>实时数据统计</title>
</head>
<body>
    <h1>实时数据统计</h1>
    <div id="realtime-data"></div>

    <script>
        var ws = new WebSocket("ws://your-websocket-server-address");
        
        ws.onmessage = function(event) {
            var data = JSON.parse(event.data);
            // 在这里处理接收到的实时数据
            document.getElementById("realtime-data").innerText = JSON.stringify(data);
        };
    </script>
</body>
</html>

Copy after login

Conclusion:
By developing Websocket server with PHP, we can easily implement real-time data statistics function. This article gives specific implementation steps and code examples, hoping to be helpful to developers. Using Websocket technology, we can implement more real-time functions, such as real-time chat, real-time monitoring, etc. With the widespread application of Websocket technology, we can provide users with a better interactive experience and real-time data display.

The above is the detailed content of Use php to develop Websocket to create real-time data statistics function. For more information, please follow other related articles on the PHP Chinese website!