PHP Websocket development guide to implement real-time flight query function-PHP Tutorial-php.cn

PHP Websocket development guide to implement real-time flight query function

王林

Release： 2023-12-02 12:20:01

Original

1047 people have browsed it

PHP Websocket开发指南，实现实时航班查询功能

PHP Websocket Development Guide: Real-time Flight Query Function

Introduction:
Websocket is a protocol that implements full-duplex communication between the client and the server , which can achieve real-time messaging and data updates. This article will introduce how to use PHP to develop Websocket, and give specific code examples combined with the real-time flight query function.

1. Understand the Websocket protocol:
The Websocket protocol is a protocol based on TCP and has the following characteristics:

Resident connection: Websocket is between the client and the server Establish ever-lasting connections for real-time communication.
Two-way communication: The client and server can send and receive messages at the same time, achieving true two-way communication.
Header compression: Websocket uses binary headers for compression to reduce data transmission overhead.
Heartbeat maintenance: Websocket can send heartbeat information to keep the connection active.

2. Tool selection for PHP development of Websocket:
PHP itself does not natively support Websocket, but it can be implemented through third-party libraries. In this article, we choose to use the Ratchet library to implement Websocket.

Ratchet is a PHP Websocket library that provides powerful tools and interfaces to simplify the Websocket development process.

3. Project preparation:
First, make sure Composer is installed in your project, and then execute the following command on the command line to install the Ratchet library:

composer require cboden/ratchet

After successful installation, create a new PHP file (for example: index.php) and start writing the code for the Websocket server.

4. Server code example:
The following is a simple example code of a Websocket server, which implements the function of real-time flight query.

// 引入Ratchet库
require 'vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use GuzzleHttpClient;

class FlightQuery 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, $msg)
    {
        // 接收到消息时的处理
        // 在这里进行航班查询的逻辑
        $result = $this->queryFlight($msg);

        // 向所有的客户端发送查询结果
        foreach ($this->clients as $client) {
            $client->send($result);
        }
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 连接关闭时的处理
        $this->clients->detach($conn);

        echo "连接关闭：(#{$conn->resourceId})
";
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // 错误处理
        echo "发生错误：(#{$conn->resourceId}): {$e->getMessage()}
";

        $conn->close();
    }

    private function queryFlight($flightNumber)
    {
        // 使用外部的航班查询API
        $httpClient = new Client();
        $response = $httpClient->get("https://api.flightquery.com/flight/{$flightNumber}");

        return $response->getBody();
    }
}

// 启动Websocket服务器
$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new FlightQuery()
        )
    ),
    8080
);

echo "Websocket服务器启动成功
";

$server->run();

Copy after login

The above code implements a simple Websocket server, running on port 8080, receiving client messages and conducting flight queries, and then sending the query results to all clients.

5. Client code example:
The following is a sample code for a simple HTML page, which realizes the connection and message sending and receiving with the Websocket server.

<!DOCTYPE html>
<html>
<head>
    <title>实时航班查询</title>
    <script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
    <script>
        $(function () {
            // 连接Websocket服务器
            var websocket = new WebSocket('ws://localhost:8080');

            // 接收Websocket消息的处理
            websocket.onmessage = function (event) {
                var result = event.data;
                // 处理航班查询结果
                $("#result").text(result);
            };

            // 发送航班查询请求
            $("#query-button").click(function () {
                var flightNumber = $("#flight-number").val();
                websocket.send(flightNumber);
            });
        });
    </script>
</head>
<body>
    <h1>实时航班查询</h1>
    <input type="text" id="flight-number" placeholder="请输入航班号">
    <button id="query-button">查询</button>
    <div id="result"></div>
</body>
</html>

Copy after login

The above code implements a simple HTML page, including an input box and a button for entering flight numbers and sending query requests. The query results will be displayed on the page in real time.

6. Run and test:
Save the above server code to index.php, and save the client code to an HTML file. Open the HTML file through the browser to run and test. Real-time flight query function.

Summary:
Through the above-mentioned Websocket development guide and code examples, we can realize the function of real-time flight query. The two-way communication feature of Websocket allows the client and server to communicate messages in real time, making our applications more real-time and responsive. By using the Ratchet library, we can develop Websocket applications faster.

Of course, actual development may require further development and adjustments based on specific business needs, but the sample code provided in this article is for reference and basic use. I wish you success in Websocket development!

The above is the detailed content of PHP Websocket development guide to implement real-time flight query function. For more information, please follow other related articles on the PHP Chinese website!