在使用paho-mqtt进行主题订阅时，多级通配符`#`的使用需严格遵循mqtt协议规范：`#`字符必须是主题过滤器中的最后一个字符。因此，像`a/#/b`这样的订阅格式是无效的，而`a/+/b`（使用单级通配符`+`）或`a/#`（`#`在末尾）则是有效的。理解这一核心规则对于正确实现mqtt多主题订阅至关重要，否则将导致`valueerror`。
MQTT主题通配符概述
MQTT协议支持两种类型的通配符，允许客户端灵活地订阅一系列相关主题，而无需为每个具体主题单独订阅：
单级通配符 (+)：
匹配主题层级中的任意一个级别。可以出现在主题过滤器的任何位置，但必须单独作为一个级别。例如，A/+/C 将匹配 A/X/C、A/Y/C，但不会匹配 A/X/Y/C 或 A/C。
多级通配符 (#)：
匹配主题层级中的零个或多个级别。它代表了通配符所在层级及其以下的所有子层级。例如，A/# 将匹配 A、A/B、A/B/C 等所有以 A 开头的主题。
多级通配符#的关键限制
根据MQTT v3.1.1协议规范（4.7.1.2 Multi-level wildcard），多级通配符#的使用有一个非常关键的限制：
多级通配符字符必须单独出现，或者跟在主题层级分隔符之后。在任何一种情况下，它都必须是主题过滤器中指定的最后一个字符。
这意味着，#只能出现在主题过滤器的末尾。任何在#之后还有其他字符（包括主题层级分隔符/）的过滤器都是无效的。
错误示例分析
考虑以下订阅尝试，它会导致ValueError: Invalid subscription filter.：
import paho.mqtt.client as mqttclient = mqtt.Client()# ... 假设客户端已连接到MQTT代理# 尝试订阅多个主题，其中包含无效的多级通配符用法invalid_topics = [('A/#/B', 1), ('A/#/C', 1), ('A/#/D', 1)]try: client.subscribe(invalid_topics)except ValueError as e: print(f"订阅失败: {e}") # 输出: 订阅失败: Invalid subscription filter.
这里的问题在于 A/#/B。尽管您可能希望它能匹配所有 A/…/B 形式的主题，但由于#之后跟着/B，这违反了#必须是最后一个字符的协议规定。Paho-MQTT客户端在内部会校验这些过滤器，如果发现不符合规范，就会抛出ValueError。
有效的通配符订阅示例
相比之下，以下两种情况是有效的，因为它们遵循了MQTT协议的规定：
单级通配符+的正确使用：单级通配符+可以出现在主题路径的中间，因为它只匹配一个层级，并且不会像#那样吞噬后续层级。
# 订阅多个使用单级通配符的主题valid_single_level_topics = [('A/+/B', 1), ('A/+/C', 1), ('A/+/D', 1)]client.subscribe(valid_single_level_topics)print("成功订阅: A/+/B, A/+/C, A/+/D")# 示例匹配: A/X/B, A/Y/C, A/Z/D
多级通配符#的正确使用：当#作为主题过滤器的最后一个字符时，它是完全有效的。
# 订阅一个使用多级通配符的主题valid_multi_level_topic = 'A/#'client.subscribe(valid_multi_level_topic)print("成功订阅: A/#")# 示例匹配: A, A/X, A/X/Y, A/X/Y/Z
更多无效和有效示例
为了进一步巩固理解，以下是一些根据MQTT规范判断的有效和无效主题过滤器：
有效示例：
sport/#：匹配 sport 和所有以 sport/ 开头的主题。#：匹配所有应用消息。sport/tennis/#：匹配 sport/tennis 和所有以 sport/tennis/ 开头的主题。+/tennis/#：匹配 X/tennis 和所有以 X/tennis/ 开头的主题。A/+/B/#：匹配 A/X/B 和所有以 A/X/B/ 开头的主题。
无效示例：
sport/tennis#：#之后不能有其他字符。sport/tennis/#/ranking：#之后不能有其他层级。A#B：#必须单独作为一个层级或跟在/之后。
总结与注意事项
#必须是最后一个字符：这是关于MQTT多级通配符最核心的规则。如果您希望匹配某个层级及其以下的所有内容，请确保#位于主题过滤器的末尾。+可以位于中间：单级通配符+可以灵活地放置在主题路径的任何层级中，用于匹配该层级的任意值。遵循协议是关键：Paho-MQTT库严格遵循MQTT协议规范。当您遇到Invalid subscription filter错误时，通常意味着您的主题过滤器不符合MQTT协议的规定。设计主题结构：在设计MQTT主题结构时，应充分考虑通配符的使用模式。如果需要订阅所有以某个前缀开头的主题，例如sensor/+/temperature和sensor/+/humidity，那么sensor/#是合适的。但如果您需要更精细的控制，例如只订阅sensor/+/temperature，则应使用单级通配符。
通过理解并严格遵守MQTT协议中关于通配符的这些规则，您可以有效地避免订阅错误，并构建出健壮的MQTT应用程序。
以上就是Paho-MQTT多级通配符订阅指南：理解#的使用限制的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1379772.html
微信扫一扫 
支付宝扫一扫 
