php 连接 mqtt（php连接sqlserver）

要在PHP中连接到MQTT，可以使用MQTT客户端库。以下是一个示例代码，展示了如何使用phpMQTT库连接到MQTT代理。

首先，需要下载并安装phpMQTT库。可以从https://github.com/bluerhinos/phpMQTT下载。

<?php
require("phpMQTT.php");

$mqtt_server = "mqtt.example.com"; // MQTT代理服务器地址
$mqtt_port = 1883; // MQTT代理服务器端口
$mqtt_username = "username"; // MQTT代理服务器用户名
$mqtt_password = "password"; // MQTT代理服务器密码

$mqtt_client_id = "phpMQTT-subscriber"; // 客户端ID

$mqtt_topic = "topic"; // 订阅的主题

$mqtt = new phpMQTT($mqtt_server, $mqtt_port, $mqtt_client_id);

if ($mqtt->connect(true, NULL, $mqtt_username, $mqtt_password)) {
    $mqtt->subscribe($mqtt_topic, 0);
    while ($mqtt->proc()) {

    }
    $mqtt->close();
} else {
    echo "连接到MQTT代理服务器失败！";
}
?>

上述代码将连接到指定的MQTT代理服务器，并订阅一个主题。在while循环中，将处理收到的消息。可以根据需要添加逻辑来处理消息。

要连接到SQL Server，可以使用PHP的PDO扩展。以下是一个示例代码，展示了如何连接到SQL Server并执行查询。

<?php
$server = "server_name"; // SQL Server服务器名
$database = "database_name"; // 数据库名
$username = "username"; // 用户名
$password = "password"; // 密码

try {
    $conn = new PDO("sqlsrv:Server=$server;Database=$database", $username, $password);
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    $sql = "SELECT * FROM table_name";
    $stmt = $conn->query($sql);
    $result = $stmt->fetchAll(PDO::FETCH_ASSOC);

    foreach ($result as $row) {
        // 处理查询结果
    }

    $conn = null;
} catch (PDOException $e) {
    echo "连接到SQL Server失败: " . $e->getMessage();
}
?>

上述代码将连接到指定的SQL Server数据库，并执行一个查询。可以根据需要修改查询语句和处理查询结果的逻辑。

希望以上代码对你有所帮助！