PHP et MQTT : Construire un système d'acquisition et d'affichage de données météorologiques en temps réel-tutoriel php-php.cn

PHP et MQTT : Construire un système d'acquisition et d'affichage de données météorologiques en temps réel

WBOY

Libérer： 2023-07-08 15:18:02

original

1420 Les gens l'ont consulté

PHP et MQTT : créer un système d'acquisition et d'affichage de données météorologiques en temps réel

Résumé : Cet article présente comment utiliser les protocoles PHP et MQTT pour créer un système d'acquisition et d'affichage de données météorologiques en temps réel. En utilisant le protocole MQTT pour l'échange de données et les mises à jour en temps réel, nous pouvons obtenir les dernières informations météorologiques à partir d'une source de données météorologiques et les afficher sur le site Web.

Introduction
Les données météorologiques sont très importantes pour de nombreuses applications et sites Web. En obtenant des données météorologiques en temps réel, nous pouvons fournir aux utilisateurs des informations météorologiques précises pour améliorer leur expérience. Cet article présentera comment utiliser les protocoles PHP et MQTT pour créer un système d'acquisition et d'affichage de données météorologiques en temps réel.
Préparation
Avant de commencer, nous devons nous assurer que vous avez installé les logiciels et les bibliothèques appropriés pour PHP et MQTT. Vous pouvez utiliser Composer pour installer la bibliothèque mqtt.php, qui est une bibliothèque PHP permettant de communiquer via le protocole MQTT. Vous aurez également besoin d'un serveur MQTT fonctionnel pour que nous puissions envoyer et recevoir des messages.
Connectez-vous au serveur MQTT
Tout d'abord, nous devons utiliser la bibliothèque mqtt.php pour nous connecter au serveur MQTT. Voici un exemple de code pour se connecter à un serveur MQTT et s'abonner à un sujet :

require 'vendor/autoload.php';

$client = new PhpMqttClientMqttClient('mqtt://your-mqtt-server');
$client->connect();

$client->subscribe('weather', function (string $topic, string $message) {
    // 处理收到的天气数据
});

while ($client->loop()) {
    // 始终保持连接
}

Copier après la connexion

Dans le code, nous utilisons la bibliothèque mqtt.php pour créer un client MQTT puis nous connecter au serveur MQTT. Ensuite, nous nous abonnons à un sujet nommé « météo » en appelant la méthode subscribe() et spécifions une fonction de rappel pour gérer les données météorologiques reçues. Enfin, nous utilisons une boucle pour maintenir la connexion au serveur MQTT, garantissant ainsi que nous continuons à recevoir des données. subscribe()方法来订阅一个名为"weather"的主题，并指定一个回调函数来处理收到的天气数据。最后，我们使用循环来保持与MQTT服务器的连接，确保我们能够持续接收数据。

获取天气数据
接下来，我们需要从一个天气数据源中获取实时的天气数据。你可以使用公开的天气API，如OpenWeatherMap API或Weather.com API。在以下示例中，我们假设我们使用了OpenWeatherMap API来获取天气数据。

function getWeatherData() {
    $apiKey = 'your-api-key';
    $city = 'your-city';

    $url = "http://api.openweathermap.org/data/2.5/weather?q=$city&appid=$apiKey";
    $response = file_get_contents($url);
    $data = json_decode($response, true);

    return $data['weather'][0]['description'];
}

$weatherData = getWeatherData();

Copier après la connexion

在代码中，我们定义了一个名为getWeatherData()的函数，它会发送一个HTTP请求到OpenWeatherMap API来获取天气数据。我们需要提供一个API密钥和城市名称作为参数。然后，我们使用file_get_contents()函数发送HTTP请求，并使用json_decode()函数解析响应。最后，我们返回天气数据中的描述信息。

发布天气数据
接下来，我们需要使用mqtt.php库将天气数据发布到MQTT服务器。以下是一个将天气数据发布到名为"weather"的主题的示例代码：

$client->publish('weather', $weatherData);

Copier après la connexion

在代码中，我们使用publish()方法将天气数据发布到名为"weather"的主题。可以在每次获取到新的天气数据后调用这个方法，以便将最新的天气数据发送给订阅者。

展示天气数据
最后，我们可以使用PHP和HTML来展示天气数据。以下是一个简单的示例代码：

<!DOCTYPE html>
<html>

<head>
    <title>实时天气数据</title>
</head>

<body>
    <h1>实时天气数据</h1>
    <div id="weather"></div>

    <script>
        var client = new Paho.MQTT.Client('your-mqtt-server', 1883, 'clientId');
        client.connect({
            onSuccess: function () {
                client.subscribe('weather');
            }
        });

        client.onMessageArrived = function (message) {
            document.getElementById('weather').innerHTML = message.payloadString;
        }
    </script>
</body>

</html>

Copier après la connexion

在代码中，我们首先创建一个MQTT客户端，并使用connect()方法连接到MQTT服务器。然后，我们使用subscribe()

Ensuite, nous devons obtenir des données météorologiques en temps réel à partir d'une source de données météorologiques. Vous pouvez utiliser des API météorologiques publiques telles que l'API OpenWeatherMap ou l'API Weather.com. Dans les exemples suivants, nous supposons que nous utilisons l'API OpenWeatherMap pour obtenir des données météorologiques.

getWeatherData()

file_get_contents()

json_decode()

publish()

connect()

subscribe()

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!