MQTT协议-心跳请求和心跳响应
心跳请求是客户端发送给服务器的,心跳响应是服务器回应给客户端的
作用是保持客户端与服务器之间的连接
CONNECT报文的可变报头是由协议名(Procotol Name)+协议级别(Procotol Level)+连接标志(Connect Flags)+保持连接(keep Alive)四个部分组成的,可看到最后有一个保持连接的部分,这个就是心跳请求
0x64的十进制是100,因此设置了100秒的保持连接时间,客户端在与服务器建立连接后的100秒内,需要发送数据到服务器进行通信,否则服务器会自动断开连接,假如客户端在这100秒内没有数据发送,但又不想与服务器失去连接,就要发送心跳请求报文
心跳请求报文PINGREQ的组成
心跳请求报文比较简单,只有固定报头,固定报头由两个字节组成,第一个字节为固定为C0,第二个字节为剩余长度,但后面没有有效载荷的内容,因此剩余长度为0,所以心跳请求报文就为C0 00
心跳响应报文PINGRESP的组成
心跳响应报文由服务器接收到客户端的心跳请求后返回,与心跳请求报文一样,只有固定报头,为D0 00
程序中发送心跳报文
先定义一个发送心跳报文的函数
uint8_t mqtt_buff[2] = {0};
void mqtt_Ping(void)
{
//组合报文
mqtt_buff[0]=0xC0;
mqtt_buff[1]=0x00;
//发送报文
mqtt_DealTxData(mqtt_buff,2);
}
用定时器中断调用mqtt_Ping函数进行定时发送,定时器可在客户端连接上服务器并发送了一个报文数据后打开,假设CONNECT报文设置的保持连接时间是100秒,那心跳请求可以每30秒或50秒发送一次,只要小于100秒就行,因此定时器可初始化为30秒或50秒,根据实际来定。
void TIM3_IRQHandler(void)
{
if(TIM_GetITStatus(TIM3,TIM_IT_Update)!=RESET)
{
//发送心跳请求
mqtt_Ping();
TIM_ClearITPendingBit(TIM3,TIM_IT_Update);
}
}