PHP與MQTT: 建立即時天氣資料取得與展示系統
摘要：本文介紹如何使用PHP與MQTT協定建構一個即時天氣資料取得與展示系統。透過使用MQTT協議進行資料交換和即時更新，我們可以從一個天氣資料來源獲取最新的天氣信息，並將其展示在網站上。
require 'vendor/autoload.php';
$client = new PhpMqttClientMqttClient('mqtt://your-mqtt-server');
$client->connect();
$client->subscribe('weather', function (string $topic, string $message) {
// 处理收到的天气数据
});
while ($client->loop()) {
// 始终保持连接
}在程式碼中，我們使用mqtt.php函式庫來建立一個MQTT客戶端，然後連接到MQTT伺服器。然後，我們透過呼叫subscribe()方法來訂閱一個名為"weather"的主題，並指定一個回呼函數來處理收到的天氣資料。最後，我們使用循環來保持與MQTT伺服器的連接，確保我們能夠持續接收資料。
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();在程式碼中，我們定義了一個名為getWeatherData()的函數，它會傳送一個HTTP請求到OpenWeatherMap API來取得天氣資料。我們需要提供一個API金鑰和城市名稱作為參數。然後，我們使用file_get_contents()函數傳送HTTP請求，並使用json_decode()函數解析回應。最後，我們返回天氣資料中的描述資訊。
$client->publish('weather', $weatherData);在程式碼中，我們使用publish()方法將天氣資料發佈到名為"weather"的主題。可以在每次取得到新的天氣資料後呼叫這個方法，以便將最新的天氣資料傳送給訂閱者。
<!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>在程式碼中，我們先建立一個MQTT客戶端，並使用connect()方法連接到MQTT伺服器。然後，我們使用subscribe()方法訂閱"weather"主題，並在收到新訊息時更新網頁上的天氣資料。
結論
透過使用PHP和MQTT協議，我們可以建立一個即時天氣資料獲取與展示系統。透過獲取天氣數據來源的即時數據，並使用MQTT協議將數據傳遞給訂閱者，我們能夠為用戶提供準確的天氣資訊。希望本文能幫助你建立一個即時天氣數據展示系統，並提供更好的使用者體驗。
以上是PHP與MQTT: 建構即時天氣資料取得與展示系統的詳細內容。更多資訊請關注PHP中文網其他相關文章！
