2025年物联网MQTT协议技术能力认证试卷

2025年物联网MQTT协议技术能力认证试卷考试时间：______分钟总分：______分姓名：______一、选择题（请将正确选项的代表字母填在括号内）1.MQTT协议的设计目标是？（）A.高吞吐量，适用于复杂事务处理B.轻量级，低带宽，低功耗，适用于资源受限的设备C.支持大规模设备同时连接D.提供复杂的数据加密和压缩功能2.在MQTT协议中，用于标识客户端的唯一字符串是？（）A.ClientIDB.TopicNameC.MessageIDD.SessionHandle3.MQTT消息的QoS（QualityofService）等级有几种？（）A.1种B.2种C.3种D.4种4.QoS0表示的消息传递方式是？（）A.至少传递一次（FireandForget）B.只传递一次C.最多传递一次D.保证传递顺序5.当客户端发送CONNECT消息时，为了维持连接状态，需要设置的连接选项是？（）A.Username和PasswordB.CleanSessionC.KeepAliveD.WillMessage6.当Broker收到客户端的CONNECT消息后，会向客户端发送哪个响应消息？（）A.PUBLISHB.PUBACKC.CONNACKD.SUBSCRIBE7.CONNACK消息中，`SessionPresent`标志位为1表示？（）A.Broker请求客户端创建会话B.Broker拒绝客户端创建会话C.客户端请求保持现有会话D.客户端请求创建新会话，Broker同意8.客户端订阅了一个主题（例如"home/+/temperature"），当Broker接收到一个发布消息（例如"home/bedroom/temperature",QoS1）时，该发布消息会被传递给订阅者吗？（）A.是B.否9.发布消息（PUBLISH）的报文类型是？（）A.CONNECTB.CONNACKC.PUBLISHD.SUBSCRIBE10.客户端向Broker发送SUBSCRIBE消息，请求订阅多个主题时，Broker会向客户端发送哪个响应消息？（）A.SUBACKB.PUBACKC.CONNACKD.UNSUBACK11.SUBACK消息中，每个订阅的Topic都会有一个对应的`GrantedQoSLevel`，其值可能是？（）A.0,1,2B.0,1C.1,2D.仅与客户端请求的QoS相同12.当客户端需要确认收到一个发布消息时，它会发送哪种类型的消息给Broker？（）A.PUBACKB.PUBRELC.PUBCOMPD.PUBLISH13.MQTT中，RetainedMessage（保留消息）的特点是？（）A.仅在客户端连接时存在B.只能由Broker存储C.当客户端订阅相关主题时，Broker会立即将保留消息发送给客户端D.只有QoS2的消息才能设置为保留消息14.客户端发送的UNSUBSCRIBE消息用于？（）A.取消订阅一个或多个主题B.订阅一个新主题C.确认收到发布消息D.维持与Broker的连接15.PINGREQ和PINGRESP消息用于？（）A.心跳检测，维持连接活性B.传递发布消息C.订阅或取消订阅主题D.客户端认证16.MQTT协议通常运行在哪种传输层协议之上？（）A.HTTPB.FTPC.TCP/IPD.UDP17.如果客户端与Broker之间的连接是通过TLS/SSL加密的，那么MQTT协议的哪个版本会被使用？（）A.MQTTv3.1B.MQTTv3.1.1C.MQTTv5D.MQTT-SN18.在MQTT认证中，使用用户名和密码，且不进行加密的认证方式是？（）A.PLAINB.SCRAMC.MQTT-SNAuthenticationD.Token-basedAuthentication19.下列哪个选项不是MQTTBroker的主要功能？（）A.管理客户端连接B.转发消息给订阅者C.存储客户端会话信息D.为每个客户端设备提供独立的应用层协议栈20.MQTT的发布/订阅模式的主要优势之一是？（）A.必须一对一连接B.消息传递顺序严格保证C.解耦了消息发布者和订阅者D.只能传递文本消息二、填空题（请将正确答案填在横线上）1.MQTT协议基于______传输层协议。2.客户端在连接Broker时使用的唯一标识符是______。3.QoS1的消息交付保证是______。4.用于客户端与Broker之间维持连接状态的定时器称为______。5.订阅主题时，客户端可以指定希望获得的最低服务质量等级，范围是______。6.发布消息中，负载（Payload）部分包含了______数据。7.当客户端断开连接时，会向Broker发送______消息。8.Broker接收到客户端的PUBLISH消息后，如果客户端已订阅该主题且请求QoS2，Broker会向发布者发送______消息以请求确认。9.MQTT协议中，支持会话持久化的连接选项是______。10.在MQTT安全机制中，使用X.509证书进行客户端和/或Broker认证的方式称为______。三、简答题（请简明扼要地回答下列问题）1.简述MQTT协议的连接建立过程，涉及的主要报文类型有哪些？2.解释MQTT中的“发布/订阅”模式，并说明其核心组件（Broker,Client,Topic）。3.简述MQTT客户端发送PUBLISH消息时，QoS0,QoS1,QoS2三种服务质量等级的传递机制和特点。4.什么是MQTT的会话（Session）？会话对于MQTT通信有什么重要性？5.简述MQTT客户端如何通过ClientID和CleanSession选项来管理连接状态。6.解释什么是MQTT的WillMessage（遗嘱消息），及其在什么情况下会被发送？四、论述题（请结合实际或场景进行分析说明）1.详细说明MQTT安全机制的重要性，并阐述至少三种不同的MQTT认证方式及其适用场景。2.结合一个具体的物联网应用场景（例如智能家居、环境监测、工业设备控制等），说明MQTT协议如何发挥作用，并讨论选择不同QoS等级的原因。五、代码分析题（请阅读以下代码片段，回答问题）```pythonimportpaho.mqtt.clientasmqtt#定义MQTT服务器地址和端口MQTT_BROKER=""MQTT_PORT=1883#创建MQTT客户端实例client=mqtt.Client()#设置遗嘱消息内容client.will_set("status/light","LightisOFF",qos=1,retain=True)#连接事件回调函数defon_connect(client,userdata,flags,rc):ifrc==0:print("Connectedsuccessfully.")#连接成功后订阅主题client.subscribe("home/+/status",qos=2)else:print(f"Connectfailedwithcode{rc}.")#订阅消息回调函数defon_message(client,userdata,msg):print(f"Received`{msg.payload.decode()}`from`{msg.topic}`withQoS{msg.qos}")#绑定回调函数client.on_connect=on_connectclient.on_message=on_message#连接MQTT服务器client.connect(MQTT_BROKER,MQTT_PORT)#开始循环处理网络事件client.loop_forever()```1.分析上述Python代码实现了MQTT客户端的哪些基本功能？2.在`on_connect`回调函数中，客户端尝试订阅的主题`"home/+/status"`的含义是什么？“+”通配符代表什么？3.`client.will_set`函数调用的作用是什么？在此调用中设置了哪些遗嘱消息的参数？如果客户端在发送WillMessage后立即断开连接，Broker会做什么？4.如果Broker接收到一个发布消息`PUBLISH("home/kitchen/temperature",payload="25",qos=2)`，该消息会被传递给哪些订阅者？请说明理由。试卷答案一、选择题1.B解析：MQTT设计目标是轻量级、低带宽、低功耗，适用于物联网场景。2.A解析：ClientID是客户端在Broker端的唯一标识。3.C解析：MQTT定义了三种QoS等级：0,1,2。4.A解析：QoS0为最多一次交付，即不保证送达。5.C解析：KeepAlive是客户端设置的心跳间隔，用于维持连接。6.C解析：Broker对CONNECT响应发送CONNACK消息。7.C解析：SessionPresent=1表示客户端请求保持会话。8.A解析：`home/+/temperature`匹配`home/bedroom/temperature`。9.C解析：发布消息（PUBLISH）的报文类型为PUBLISH。10.A解析：SUBSCRIBE响应为SUBACK。11.A解析：SUBACK可以返回0,1,2，表示Broker同意的QoS等级。12.B解析：客户端对收到的PUBLISH消息确认发送PUBREL。13.C解析：RetainedMessage是Broker在Topic上保留的，当有客户端订阅时会立即发送。14.A解析：UNSUBSCRIBE用于取消对一个或多个主题的订阅。15.A解析：PINGREQ/PINGRESP用于心跳检测连接状态。16.C解析：MQTT基于TCP/IP协议栈。17.C解析：通过TLS/SSL加密的MQTT通常称为MQTTv5。18.A解析：PLAIN认证使用明文用户名密码，不加密传输。19.D解析：Broker处理协议层面转发，设备端应用层协议栈由设备自身实现。20.C解析：发布/订阅模式解耦了发布者和订阅者，使其可以独立变化。二、填空题1.TCP/IP解析：MQTT建立在TCP/IP协议之上。2.ClientID解析：ClientID是客户端连接Broker的唯一标识。3.至少传递一次解析：QoS1保证消息至少被传递一次。4.KeepAlive解析：KeepAlive机制用于检测和维持连接活性。5.0,1,2解析：订阅时可指定最小QoS等级，范围是0到2。6.应用数据解析：负载部分包含实际要传递的业务数据。7.DISCONNECT解析：客户端断开连接时发送DISCONNECT消息。8.PUBREL解析：Broker收到QoS2的PUBLISH后，会向发布者发送PUBREL请求确认。9.CleanSession解析：CleanSession选项决定是否开启会话持久化。10.X.509Certificate解析：使用X.509证书进行身份认证的方式。三、简答题1.解答：MQTT连接建立过程：客户端向Broker发送CONNECT消息，包含ClientID、CleanSession、KeepAlive、WillMessage等选项和用户认证信息（如果需要）。Broker收到CONNECT消息后，进行认证（如果需要），并选择一个SessionID（如果CleanSession=0或需要会话）。Broker向客户端发送CONNACK消息，包含连接结果（成功/失败）和SessionID（如果生成了）。如果连接成功，客户端可以发送订阅（SUBSCRIBE）或发布（PUBLISH）消息。连接建立涉及的主要报文类型有CONNECT,CONNACK。2.解答：MQTT发布/订阅模式：核心思想是解耦发布者和订阅者。发布者将消息发布到一个中立的主题（Topic），订阅者向Broker订阅感兴趣的主题。核心组件：*Broker：中心节点，负责接收发布者消息，并根据订阅关系将消息转发给订阅者。*Client：可以是发布者，也可以是订阅者，或两者兼具。*Topic：主题名称，用于分类和组织消息，订阅者通过主题名来接收消息。这种模式使得发布者和订阅者无需直接建立连接，提高了系统的灵活性和可扩展性。3.解答：QoS传递机制和特点：*QoS0：最多一次（FireandForget）。发布者发送消息后不等待确认，Broker收到后尝试一次性发送给订阅者，不保证送达，也可能重复发送。特点是无确认，开销最小。*QoS1：至少一次（AtLeastOnce）。发布者发送消息后等待Broker的PUBACK确认。Broker将消息发送给订阅者，并等待订阅者发送PUBCOMP确认。Broker通过记录已发送但未确认的消息来避免重发，保证至少送达一次，但可能重复。特点是有确认，保证送达，可能重复。*QoS2：仅一次（ExactlyOnce）。发布者发送消息后等待Broker的PUBACK确认。Broker将消息发送给订阅者，订阅者发送PUBREL，Broker收到后发送PUBCOMP。发布者和订阅者都通过记录已处理的消息来避免重发，保证消息仅被成功送达一次。特点是最可靠，保证唯一性，开销最大。4.解答：MQTT会话（Session）：会话是Broker为每个连接的客户端维护的一组状态信息，包括订阅列表、未完成消息（PENDING消息）、遗嘱消息（WillMessage）等。会话通常与ClientID绑定，除非设置了CleanSession。重要性：*状态保持：即使客户端断开连接再重新连接，如果ClientID相同且CleanSession=0，Broker可以恢复之前的订阅状态和未完成消息，避免数据丢失或重复处理。*遗嘱消息：客户端断开连接时，如果设置了WillMessage，Broker会自动将其发送给订阅了对应主题的客户端。*提高效率：避免了每次连接都需要重新订阅所有主题。5.解答：ClientID和CleanSession管理连接状态：*ClientID：唯一标识客户端，Broker通过ClientID来区分不同的连接和关联会话信息。*CleanSession：连接选项，取值0或1。*CleanSession=1：每次连接都是全新的，Broker不会保留该ClientID的任何会话信息（订阅、未完成消息等）。断开连接后重新连接，相当于一个全新的客户端。*CleanSession=0：Broker会为该ClientID维护会话信息。客户端断开连接再重新连接（使用相同ClientID），Broker会恢复之前的会话状态（订阅列表、保留消息等）。CleanSession选项决定了连接是“无状态”还是“有状态”。6.解答：MQTT遗嘱消息（WillMessage）：WillMessage是客户端在连接请求（CONNECT）时可以设置的一个消息模板。如果客户端在发送完CONNECT消息后、收到CONNACK之前意外断开连接，或者连接在保持期间非正常断开（如网络中断、客户端崩溃），Broker会自动将这个预设的WillMessage发布出去。WillMessage包含主题名和负载内容，以及设置的QoS等级和是否保留（Retained）。重要性在于提供了一种自动通知机制，告知其他客户端该设备已离线。四、论述题1.解答：MQTT安全机制的重要性：物联网环境通常涉及大量分布广泛、资源受限的设备，且数据可能包含敏感信息，因此MQTT安全至关重要。重要性体现在：*身份认证：防止未授权设备接入网络，确保通信双方身份真实可信，防止中间人攻击。*数据保密：通过加密（如TLS/SSL），保护消息内容不被窃听，防止敏感数据泄露。*数据完整性：确保消息在传输过程中未被篡改，保证接收到的消息是原始发送者发送的。*防抵赖：通过数字签名等机制，确保发送者无法否认其发送过某条消息。MQTT认证方式：*PLAIN：最简单的认证方式，使用用户名和密码进行Base64编码传输，不加密。适用于信任网络环境，但安全性较低。*SCRAM：基于密码的认证，比PLAIN更安全，使用盐值、迭代次数等防止密码在网络中明文传输和暴力破解攻击。适用于需要密码认证的场景。*MQTT-SNAuthentication：MQTT-SN（MQTTforSecureNetworks）协议本身包含基于用户名/密码或Token的认证机制，适用于资源极度受限的设备。*X.509Certificate：使用数字证书进行认证，提供更强的身份验证和加密能力。适用于需要高安全性和证书管理的场景，如工业控制、政府项目等。适用场景：选择哪种认证方式取决于具体应用的安全需求、设备资源限制、部署复杂度等因素。高安全要求的场景（如金融、医疗）推荐使用X.509。资源受限场景可考虑PLAIN或MQTT-SN。内部可信网络可考虑SCRAM。2.解答：MQTT在物联网应用场景中的作用及QoS选择：以智能家居环境监测为例：*作用：*设备连接与数据采集：各个传感器（温度、湿度、光照、空气质量）作为MQTT客户端，将采集到的数据发布到预定义的主题（如`home/+/sensor/temperature`）。*数据集中与处理：家中的网关或云端的MQTTBroker接收来自各个传感器的数据。Broker根据订阅关系，将数据转发给家庭自动化控制器（如智能音箱、中控器）或云平台进行分析。*远程控制：用户通过手机App或语音助手，向Broker发布控制命令（如`home/light/kitchen/set`,QoS1或0），Broker将命令下发给相应的执行器（如智能灯泡）。*状态同步与告警：系统状态（如设备在线/离线）可以通过MQTT发布。异常数据（如温度过高）可以作为重要消息（可能要求QoS1或2）发布，触发告警通知。*QoS选择原因：*传感器数据上报：温湿度等常规数据，对实时性要求不是极高，偶尔丢失影响不大，可以选择QoS0（降低网络负担）或QoS1（保证基本送达）。*光照、空气质量等非关键数据：可选用QoS0或1。*用户控制指令：如开关灯，对可靠性要求高，不允许丢失，应选择QoS1（保证送达，可能重复）。*紧急告警信息：如烟雾报警、燃气泄漏，必须确保送达，应选择QoS2（保证唯一一次送达）。*系统状态信息（如设备上线/离线）：需要所有相关节点及时了解，可选用QoS1。选择QoS时需权衡消息的重要性、实时性要求、网络带宽、设备资源等因素。QoS2虽然最可靠但开销最大，应仅用于关键消息。五、代码分析题1.解答：代码实现了MQTT客户端的以下功能：*连接MQTT服务器（``，端口1883）。*设置遗嘱消息：如果客户端连接失败或非正常断开，Broker会自动发布主题`"status/light"`，内容为`"LightisOFF"`，QoS1，并设置为保留消息。*定义连接成功后的回调函数：`on_connect`。函数内部尝试订阅主题`"home/+/status"`，使用QoS2。如果连接失败，会打印失败代码。*定义消息接收回调函数：`on_message`。函数接收消息后，打印主题、负载内容和QoS等级。*绑定回调函数：将`on_connect`和`on_message`分别绑定到客户端的`on_connect`和`on_message`事件。*启动网络循环：调用`loop_forever()`，使客户端持续监听网络事件，保持连接。2.解答：主题`"home/+/status"`的含义：`+`是单层通配符，匹配任意一个层级。该主题模式表示客户端订阅了`home/`下的任何一层级的`status`主题及其子主题。例如，会匹配以下主题：*`home/status`*`home/bedroom/status`*`home/kitchen/status`*`home/office/status`*`home/garden/lawn/status`“+”通配符代表可以匹配一个层级的任意子主题，使得客户端可以方便地订阅一个区域或设备组的状态信息，而无需列