Verwenden Sie PHP, um Websocket zu entwickeln und eine Echtzeit-Wettervorhersagefunktion zu erstellen

Verwenden Sie PHP, um WebSocket zu entwickeln und eine Echtzeit-Wettervorhersagefunktion zu erstellen.

Vorwort: WebSocket ist ein Netzwerkkommunikationsprotokoll, das eine dauerhafte Verbindung zwischen dem Client und dem Server herstellen kann, um eine bidirektionale Echtzeitkommunikation zu erreichen. In der Webentwicklung wird WebSocket häufig in Szenarien wie Instant Chat, Echtzeit-Push und Echtzeit-Datenaktualisierungen verwendet. In diesem Artikel wird erläutert, wie Sie mit PHP WebSocket entwickeln, um eine Echtzeit-Wettervorhersagefunktion zu implementieren.

Schritt 1: Erstellen Sie einen WebSocket-Server

Zunächst müssen wir einen WebSocket-Server erstellen, um Clientverbindungen und das Senden von Nachrichten zu verwalten. In PHP können Sie die Ratchet-Bibliothek verwenden, um die Funktionalität eines WebSocket-Servers zu implementieren.

Stellen Sie zunächst sicher, dass Composer ein Abhängigkeitsverwaltungstool für PHP installiert ist.
1. Erstellen Sie ein neues PHP-Projekt, erstellen Sie im Projektverzeichnis eine neue Datei „composer.json“ und fügen Sie den folgenden Inhalt hinzu:

2. {
       "require": {
           "cboden/ratchet": "^0.4"
       }
   }

Führen Sie im Projektverzeichnis den Befehl
3. aus, um die Ratchet-Bibliothek zu installieren. composer install
Erstellen Sie eine neue PHP-Datei mit dem Namen server.php, um die Hauptlogik des WebSocket-Servers zu implementieren. Das Codebeispiel lautet wie folgt:

4. <?php
   require __DIR__ . '/vendor/autoload.php';
   
   use RatchetMessageComponentInterface;
   use RatchetConnectionInterface;
   use RatchetServerIoServer;
   use RatchetHttpHttpServer;
   use RatchetWebSocketWsServer;
   
   class WeatherForecast implements MessageComponentInterface
   {
       public function onOpen(ConnectionInterface $conn)
       {
           // 当有新的客户端连接时，触发该方法
       }
   
       public function onClose(ConnectionInterface $conn)
       {
           // 当有客户端断开连接时，触发该方法
       }
   
       public function onMessage(ConnectionInterface $from, $msg)
       {
           // 当收到客户端发送的消息时，触发该方法
       }
   
       public function onError(ConnectionInterface $conn, Exception $e)
       {
           // 当发生错误时，触发该方法
       }
   
       public function broadcastMessage($msg)
       {
           // 向所有连接的客户端广播消息
       }
   }
   
   $server = IoServer::factory(
       new HttpServer(
           new WsServer(
               new WeatherForecast()
           )
       ),
       8080
   );
   
   $server->run();
   

Im obigen Code haben wir eine Klasse namens WeatherForecast erstellt, die die MessageComponentInterface-Schnittstelle von Ratchet implementiert, die verschiedene Ereignisverarbeitungsmethoden des WebSocket-Servers enthält, wie z. B. onOpen, onClose, onMessage wait. Wir können in diese Methoden eine spezifische Logik schreiben, um die Verbindung, Trennung und den Nachrichtenversand von Clients zu handhaben.

In der WeatherForecast-Klasse definieren wir außerdem eine BroadcastMessage-Methode, um Nachrichten an alle verbundenen Clients zu senden.

Verbinden Sie abschließend die drei Objekte HttpServer, WsServer und WeatherForecast über die Factory-Methode von IoServer miteinander und geben Sie die Portnummer des Servers als 8080 an.

Schritt 2: Zugriff auf die Wettervorhersage-API

Als nächstes müssen wir Echtzeit-Wettervorhersagedaten abrufen und diese an den verbundenen Client senden. In diesem Artikel verwenden wir eine öffentliche Wettervorhersage-API, Sie können jedoch je nach tatsächlichem Bedarf auch andere APIs auswählen.

In der onOpen-Methode der WeatherForecast-Klasse können wir eine HTTP-Anfrage initiieren, um Wettervorhersagedaten zu erhalten. Das Codebeispiel lautet wie folgt:

public function onOpen(ConnectionInterface $conn)
{
    $url = 'https://api.weatherapi.com/v1/current.json?key=YOUR_API_KEY&q=Beijing';
    $response = file_get_contents($url);
    $data = json_decode($response, true);

    // 处理天气预报数据，比如将数据发送给客户端
}

Darunter muss YOUR_API_KEY durch Ihren API-Schlüssel ersetzt werden und die abgefragte Stadt muss entsprechend den tatsächlichen Anforderungen geändert werden.

Schritt 3: Echtzeit-Wettervorhersagedaten senden

Nachdem wir die Wettervorhersagedaten erhalten haben, können wir die Daten über den WebSocket-Server an den verbundenen Client senden.

In der onOpen-Methode der WeatherForecast-Klasse können wir die BroadcastMessage-Methode aufrufen, um die Nachricht an alle verbundenen Clients zu senden. Das Codebeispiel lautet wie folgt:

public function onOpen(ConnectionInterface $conn)
{
    $url = 'https://api.weatherapi.com/v1/current.json?key=YOUR_API_KEY&q=Beijing';
    $response = file_get_contents($url);
    $data = json_decode($response, true);

    $this->broadcastMessage($data['current']);
}

Im obigen Code verwenden wir das aktuelle Feld der Wettervorhersagedaten als Nachrichteninhalt und senden es über die BroadcastMessage-Methode an alle verbundenen Clients.

In der onMessage-Methode der WeatherForecast-Klasse können wir die vom Client gesendeten Nachrichten verarbeiten und entsprechende Daten entsprechend dem tatsächlichen Bedarf senden. Das Codebeispiel lautet wie folgt:

public function onMessage(ConnectionInterface $from, $msg)
{
    if ($msg === 'getWeather') {
        $url = 'https://api.weatherapi.com/v1/current.json?key=YOUR_API_KEY&q=Beijing';
        $response = file_get_contents($url);
        $data = json_decode($response, true);

        $from->send($data['current']);
    }
}

Wenn der Client im obigen Code die getWeather-Nachricht sendet, initiieren wir erneut eine HTTP-Anfrage, um die neuesten Wettervorhersagedaten abzurufen und an den Client zu senden.

Schritt 4: Client-Zugriff und -Anzeige

Schließlich müssen wir Client-Code schreiben, um auf Echtzeit-Wettervorhersagedaten zuzugreifen und diese anzuzeigen. In diesem Artikel verwenden wir JavaScript, um clientseitige Funktionen zu implementieren.

<script>
    const socket = new WebSocket('ws://localhost:8080');

    socket.onopen = function(event) {
        socket.send('getWeather');
    }

    socket.onmessage = function(event) {
        const weatherData = JSON.parse(event.data);

        // 处理天气预报数据，比如展示在网页上
    }
</script>

Im obigen Code haben wir ein WebSocket-Objekt erstellt und die Adresse des Servers als ws://localhost:8080 angegeben. Im onopen-Ereignis haben wir die getWeather-Nachricht an den Server gesendet, um den Server zum Senden von Echtzeit-Wettervorhersagedaten zu veranlassen. Beim onmessage-Ereignis verarbeiten wir die vom Server gesendete Nachricht und zeigen sie auf der Webseite an.

Zusammenfassung

Durch die Entwicklung von WebSocket in PHP können wir eine Echtzeit-Wettervorhersagefunktion implementieren. Über den WebSocket-Server kann eine bidirektionale Echtzeitkommunikation zwischen dem Client und dem Server erreicht werden. Durch den Zugriff auf die Wettervorhersage-API und das Senden von Wettervorhersagedaten in Echtzeit können wir die neuesten Wettervorhersagedaten zeitnah an den verbundenen Client senden und auf dem Client anzeigen. Diese Methode kann nicht nur die Anforderungen der Echtzeit-Wettervorhersage erfüllen, sondern auch auf andere Echtzeit-Daten-Push-Szenarien angewendet werden.

Das obige ist der detaillierte Inhalt vonVerwenden Sie PHP, um Websocket zu entwickeln und eine Echtzeit-Wettervorhersagefunktion zu erstellen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!