前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >PHPMQTT v1.1.4 版本发布,MQTT 协议解析 & 协程客户端

PHPMQTT v1.1.4 版本发布,MQTT 协议解析 & 协程客户端

作者头像
沈唁
发布2021-01-22 12:02:38
8961
发布2021-01-22 12:02:38
举报
文章被收录于专栏:沈唁志沈唁志

PHPMQTT v1.1.4 版本发布

在 v1.1.4 版本中,优化了重连的逻辑,增加了reconnect_delay配置参数,让用户自己设置重连的延时时间。

之前的版本为固定的3s,现在默认值为3s,可以自行设置

代码语言:javascript
复制
use Simps\MQTT\Client;
use Swoole\Coroutine;

Coroutine\run(function () {
    $config = [
        'host' => '127.0.0.1',
        'port' => 1883,
        'user_name' => '',
        'password' => '',
        'client_id' => \Simps\MQTT\Client::genClientID(),
        'keep_alive' => 10,
        'reconnect_delay' => 5,
    ];
    $swooleConfig = [
        'open_mqtt_protocol' => true,
        'package_max_length' => 2 * 1024 * 1024,
        'connect_timeout' => 1.0,
    ];
    $client = new Client($config, $swooleConfig);
});

优化了 connect 和 publish 的逻辑,增加了一些限制:

  1. 在 MQTT 的协议中是不支持 QoS 大于 3 的,MQTT5 中会返回相应的错误码0x9B表示不支持的 QoS,但是在 MQTT3 中就没有对应响应,通过抓包会发现其实是一直在重连的
代码语言:javascript
复制
include __DIR__ . '/examples/bootstrap.php';

use Simps\MQTT\Client;
use Swoole\Coroutine;

Coroutine\run(function () {
    $client = new Client(getTestConnectConfig(false), SWOOLE_MQTT_CONFIG);
    $will = [
        'topic' => 'simps-mqtt/user001/update',
        'qos' => 3,
        'message' => 'byebye',
    ];
    $res = $client->connect(false, $will);
    var_dump($res);
});

所以直接限制在 MQTT3 设置大于 QoS2 的等级

代码语言:javascript
复制
PHP Fatal error:  Uncaught Simps\MQTT\Exception\ProtocolException: QoS 3 not supported
  1. 同样的,在 MQTT5 中 publish 可以通过topic_alias来进行发布,此时的topic可以为空,但是 MQTT3 中没有topic_alias的功能,所以就不支持发布topic为空的消息
代码语言:javascript
复制
include __DIR__ . '/examples/bootstrap.php';

use Simps\MQTT\Client;
use Swoole\Coroutine;

Coroutine\run(function () {
    $client = new Client(getTestConnectConfig(false), SWOOLE_MQTT_CONFIG);
    $client->connect();
    var_dump($client->publish('', 'hello'));
});
代码语言:javascript
复制
PHP Fatal error:  Uncaught Simps\MQTT\Exception\ProtocolException: Protocol Error, Topic cannot be empty

感谢

前天将 PHPMQTT 提交到了 OSCHINA 的软件库(https://www.oschina.net/p/phpmqtt),今天发现 OSCHINA 的首页居然给了推荐,在此表示感谢

更新日志

增强

  • 优化重连逻辑,增加 reconnect_delay 参数 (#26)
  • 新增 ProtocolException,限制 publish 不能为空 topic (#27)
  • 更新 testPublishNonTopic 测试文件 (#28)
  • 优化 MQTT3 connect 封包 (e669288)

修复

  • 修复传入参数错误导致的未定义索引 (9d908b7)

关于 PHPMQTT

  • MQTT 协议解析 & 协程客户端
  • 适用于 PHP 的 MQTT 协议解析和协程客户端
  • 支持 MQTT 协议 3.1、3.1.1 和 5.0 版本,支持 QoS 0、QoS 1、QoS 2
  • 首个支持 MQTT v5.0 协议的 PHP library

文档:https://mqtt.simps.io

GitHub:https://github.com/simps/mqtt

Gitee:https://gitee.com/phpiot/mqtt

支持记得点个 Star~

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2021-01-14,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 沈唁志 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • PHPMQTT v1.1.4 版本发布
    • 感谢
      • 更新日志
        • 增强
          • 修复
            • 关于 PHPMQTT
            领券
            问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档