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

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
简介: 在 v1.1.4 版本中,优化了重连的逻辑,增加了reconnect_delay配置参数,让用户自己设置重连的延时时间。

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

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

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 中就没有对应响应,通过抓包会发现其实是一直在重连的
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 的等级


PHP Fatal error:  Uncaught Simps\MQTT\Exception\ProtocolException: QoS 3 not supported

2.同样的,在 MQTT5 中 publish 可以通过topic_alias来进行发布,此时的topic可以为空,但是 MQTT3 中没有topic_alias的功能,所以就不支持发布topic为空的消息

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'));
});
PHP Fatal error:  Uncaught Simps\MQTT\Exception\ProtocolException: Protocol Error, Topic canno
相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
2月前
|
消息中间件 Java Apache
RocketMQ消息回溯实践与解析
在分布式系统和高并发应用的开发中,消息队列扮演着至关重要的角色,而RocketMQ作为阿里巴巴开源的一款高性能消息中间件,以其高吞吐量、高可用性和灵活的配置能力,在业界得到了广泛应用。本文将围绕RocketMQ的消息回溯功能进行实践与解析,分享工作学习中的技术干货。
77 3
|
3月前
|
消息中间件 Linux API
centos7 安装rabbitmq自定义版本及配置
centos7 安装rabbitmq自定义版本及配置
|
4月前
|
消息中间件 Java C语言
消息队列 MQ使用问题之在使用C++客户端和GBase的ESQL进行编译时出现core dump,该怎么办
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
4月前
|
消息中间件 存储 监控
消息队列 MQ使用问题之客户端重启后仍然出现broker接收消息不均匀,该怎么办
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
1月前
|
消息中间件 存储 监控
RocketMQ消息重试机制解析!
RocketMQ消息重试机制解析!
RocketMQ消息重试机制解析!
|
1月前
|
数据处理 Python
深入探索:Python中的并发编程新纪元——协程与异步函数解析
深入探索:Python中的并发编程新纪元——协程与异步函数解析
27 3
|
3月前
|
消息中间件 开发者
【RabbitMQ深度解析】Topic交换器与模式匹配:掌握消息路由的艺术!
【8月更文挑战第24天】在消息队列(MQ)体系中,交换器作为核心组件之一负责消息路由。特别是`topic`类型的交换器,它通过模式匹配实现消息的精准分发,适用于发布-订阅模式。不同于直接交换器和扇形交换器,`topic`交换器支持更复杂的路由策略,通过带有通配符(如 * 和 #)的模式字符串来定义队列与交换器间的绑定关系。
72 2
|
3月前
|
开发者 Python
深入解析Python `httpx`源码,探索现代HTTP客户端的秘密!
深入解析Python `httpx`源码,探索现代HTTP客户端的秘密!
89 1
|
3月前
|
API C# 开发框架
WPF与Web服务集成大揭秘:手把手教你调用RESTful API,客户端与服务器端优劣对比全解析!
【8月更文挑战第31天】在现代软件开发中,WPF 和 Web 服务各具特色。WPF 以其出色的界面展示能力受到欢迎,而 Web 服务则凭借跨平台和易维护性在互联网应用中占有一席之地。本文探讨了 WPF 如何通过 HttpClient 类调用 RESTful API,并展示了基于 ASP.NET Core 的 Web 服务如何实现同样的功能。通过对比分析,揭示了两者各自的优缺点:WPF 客户端直接处理数据,减轻服务器负担,但需处理网络异常;Web 服务则能利用服务器端功能如缓存和权限验证,但可能增加服务器负载。希望本文能帮助开发者根据具体需求选择合适的技术方案。
165 0
|
3月前
|
消息中间件 Java RocketMQ
微服务架构师的福音:深度解析Spring Cloud RocketMQ,打造高可靠消息驱动系统的不二之选!
【8月更文挑战第29天】Spring Cloud RocketMQ结合了Spring Cloud生态与RocketMQ消息中间件的优势,简化了RocketMQ在微服务中的集成,使开发者能更专注业务逻辑。通过配置依赖和连接信息,可轻松搭建消息生产和消费流程,支持消息过滤、转换及分布式事务等功能,确保微服务间解耦的同时,提升了系统的稳定性和效率。掌握其应用,有助于构建复杂分布式系统。
67 0

推荐镜像

更多
下一篇
无影云桌面