开发者社区> 问答> 正文

php的阿里云mqtt,如何订阅多个主题?目前只能订阅一个?

##此处填写阿里云帐号 AccessKey
$accessKey = 'xxxxxxxxx';
##此处填写阿里云帐号 SecretKey
$secretKey = 'xxxxxxxxxxxxxxxxx';
## 接入点地址,购买实例后从控制台获取
$endPoint = 'xxxxxxxxxxxxxxxx';
##实例 ID,购买后从控制台获取
$instanceId = 'post-cn-v641cj56e0b';
## MQTT Topic,其中第一级 Topic 需要在 MQTT 控制台提前申请
$topic = 'kuwande_dlc1001_userLogin';
## MQTT 客户端ID 前缀, GroupID,需要在 MQTT 控制台申请
$groupId = 'GID_10001';
## MQTT 客户端ID 后缀,DeviceId,业务方自由指定,需要保证全局唯一,禁止 2 个客户端连接使用同一个 ID
$deviceId = '10001';
##用于设置顺序属性的系统命令 topic
$sysCmdTopic='$SYS/enableOrderMsg';
$qos = 1;
$port = 1883;
$keepalive = 90;
$cleanSession = true;
$clientId = $groupId . '@@@' . $deviceId;
echo $clientId . "\n";

$mid = 0;
## 初始化客户端,需要设置 clientId 和 CleanSession 参数,参考官网文档规范
$mqttClient = new Mosquitto\Client($clientId, $cleanSession);


## 设置鉴权参数,参考 MQTT 客户端鉴权代码计算 username 和 password
$username = 'Signature|' . $accessKey . '|' . $instanceId;
$sigStr = hash_hmac("sha1", $clientId, $secretKey, true);
$password = base64_encode($sigStr);
echo "UserName:" . $username . "  Password:" . $password . "\n";
$mqttClient->setCredentials($username, $password);

## 设置连接成功回调
$mqttClient->onConnect(function ($rc, $message) use ($mqttClient, &$mid, $topic, $qos, $sysCmdTopic) {
    echo "Connnect to Server Code is " . $rc . " message is " . $message . "\n";
    ## 连接成功后需要在发消息之前提前设置顺序属性,然后再发消息,才能保证同一个 clientId 发的消息顺序。
    $mqttClient->subscribe($topic, $qos);
});
## 设置消息接收回调
$mqttClient->onMessage(function ($message) {
    echo "Receive Message From mqtt, topic is " . $message->topic . "  qos is " . $message->qos . "  messageId is " . $message->mid . "  payload is " . $message->payload . "\n";
});
$mqttClient->connect($endPoint, $port, $keepalive);
$mqttClient->loopForever();


以上方法怎么改进下 可以订阅多个主题?

展开
收起
浪子2015 2019-10-23 08:42:06 2114 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
阿里云栖开发者沙龙PHP技术专场-直面PHP微服务架构挑战-高驰涛 立即下载
PHP安全开发:从白帽角度做安全 立即下载
PHP 2017.北京 全球开发者大会——高可用的PHP 立即下载