mqtt遗嘱消息

时间: 2025-07-08 11:48:12 AIGC 浏览: 39
### MQTT 遗嘱消息的功能及其设置与使用 #### 1. **遗嘱消息概述** MQTT 协议中的遗嘱消息(Last Will and Testament, LWT)是一种机制,当客户端因意外情况而断开连接时,服务器会自动将该客户端预先设定好的消息发送给指定的主题。这种功能对于监控设备在线状态或实现故障恢复非常有用[^1]。 --- #### 2. **如何配置遗嘱消息** 在建立 MQTT 连接的过程中,可以通过 `CONNECT` 报文来配置遗嘱消息的相关参数。以下是主要的配置选项: - **Will Topic**: 定义遗嘱消息的目标主题。 - **Will Payload**: 设定要发送的具体消息内容。 - **Will QoS**: 指定遗嘱消息的服务质量等级 (Quality of Service),可选值为 0、1 或 2。 - **Will Retain**: 如果此字段设置为 true,则遗嘱消息会被标记为保留消息 (Retained Message) 并存储到服务器中[^4]。 例如,在 Python 中可以利用 Paho-MQTT 库完成如下配置: ```python import paho.mqtt.client as mqtt client = mqtt.Client(client_id="test_client") # 设置遗嘱消息 will_topic = "device/status" will_payload = "{data:state,state:offline}" will_qos = 1 will_retain = True client.will_set(will_topic, will_payload, will_qos, will_retain) # 连接到 Broker broker_address = "localhost" port = 1883 client.connect(broker_address, port) ``` 在此示例中,如果客户端非正常断开连接,Broker 将向主题 `device/status` 发送 `{data:state,state:offline}` 的消息,并将其作为保留消息保存[^5]。 --- #### 3. **处理遗嘱消息** 为了有效管理遗嘱消息,需关注以下几个方面: - **订阅目标主题** 订阅由遗嘱消息所指向的主题即可接收这些消息。例如,若遗嘱消息的目标主题为 `aaaaa`,则可以在另一端通过以下方式监听: ```python client.subscribe("aaaaa", qos=1) ``` - **触发条件** 遗嘱消息会在特定条件下被触发,比如客户端由于网络中断或其他原因未能优雅地关闭连接。某些情况下也可以手动模拟异常断开来测试效果[^2]。 - **延迟间隔** 可以通过设置 `Will Delay Interval` 来控制遗嘱消息的实际发布时间。这一属性允许开发者定义一个时间窗口,在确认无法重新连接后再正式发出遗嘱消息。 --- #### 4. **实际应用场景** - **设备状态监测** 使用遗嘱消息报告 IoT 设备的状态变化,如从“在线”切换至“离线”。例如,先发布一条带有保留标志的消息表示当前处于活动状态,再借助遗嘱消息更新为下线状态[^3]。 - **错误诊断与告警** 当远程节点发生不可预见的问题时,及时通知管理员采取措施修复服务。 ---
阅读全文

相关推荐

/************************************************************************ * 文件名称: LTE_DTU.c * 功能名称: DTU模块驱动 * 实验平台: 物联开发板STM32F103RBT6 * OneNET 多协议平台 MQTT: MQTT服务器IP: mqtt.heclouds.com MQTT服务器端口:6002 主题topic:IOT_LBW、IOT_TOPIC 产品ID:220520 设备ID:657554468 设备密钥:LBWIOT 用到的MQTT指令: 1. @config@[email protected],6002,657554468,60### --设置mqtt服务器IP和端口号,以及设备ID号和心跳保活时间 2. @config@user@220520,LBWIOT,0### ---设置MQTT账户名和密码 3. @config@remain@1,2018-10-31### -----设置会话 4. @config@will@0,0,0,0,0### ---设置无遗嘱模式 5. @config@sub@IOT_LBW,0### -----订阅主题 @config@sub@IOT_TOPIC,0### -----订阅主题 6. @config@pub@IOT_LBW,0,0,0### ---发布主题 @config@pub@IOT_TOPIC,0,0,0### ---发布主题 7. @config@para@save### ----保存参数 8. @get@platform connect state@ --查询登录平台状态 **************************************************************************/ #include "LTE_DTU.h" #include <stdio.h> #include "string.h" #include "USART1.h" #include "USART2.h" #include "DelayTime.h" /*变量声明*/ u8 TCP_Connectflag=0;//TCP连接标志,1 成功,0 失败 u8 Congfig_flag=0; //配置服务器参数标志 1 成功,0 失败 u8 DTU_Readyflag;//DTU运行状态标志;1 正常,0 异常 u8 Login_OneNET_flag=0; //登录OneNET平台标志(TCP模式),1 成功,0 失败 u8 Loginflag=0; //登录OneNET平台标志(mqtt模式),1 成功,0 失败 extern char Usart2_RX_Buf[]; //串口2缓存 extern u8 Usart2_RX_Data_Len; //串口2缓存首地址 extern char Usart2_TX_Buf[Usart2_TX_MAXLEN]; /* OneNET平台登陆报文格式示例:*产品ID号#鉴权信息#cupluas* (本次实验例程的鉴权信息使用模块IMEI号) 例如:*394915#868777055277606#cupluas* */ char LoginMessage[35]="*394915#";//初始值含有产品ID号 /*开辟缓存,注意设置的存储长度要=实际长度m+1*/ char Buf_IMEI[16]; //IMEI 缓存 char Buf_ICCID[21];//ICCID 缓存 char Buf_CSQ[3]; //信号质量 缓存 char Buf_longitude[13]={0}; //经度 char Buf_latitude[13]={0}; //纬度 /* TCP服务器配置参数*/ char tcp_agreement[]="tcp";//TCP协议 char DTU_HeartData[]="";//无需心跳包 char DTU_HeartTime[]="60";//心跳间隔默认60s char DTU_IP[]="183.230.40.40";//OneNET TCP服务器IP地址 char DTU_PORT[]="1811";//OneNET服务器:TCP透传端口号 /* MQTT服务器配置登录账号信息*/ // 当采用MCU配置MQTT参数,才会用到下列三元组信息 char mqtt_deviceclientid[]="657554468"; // mqtt 客户端:设备ID char mqtt_username[]="220520"; // mqtt 用户名:产品ID号 char mqtt_password[]="LBWIOT"; // mqtt 密码:设备密钥 //char mqtt_IP[]="183.230.40.39";//OneNET mqtt服务器域名mqtt.heclouds.com char mqtt_IP[]="119.3.236.206"; char mqtt_PORT[]="18083";//OneNET mqtt 端口号 char mqtt_HeartTime[]="60";//心跳保活时间 char MQTT_Encryptflag[]="0";//用户信息加密 //此处修改您需要订阅的主题 char mqtt_subtopic[]="IOT_LBW"; //mqtt 订阅主题 char mqtt_pubtopic[]="IOT_LBW"; //mqtt 发布主题 char MQTT_Qos[]="0";//主题等级0~2 char MQTT_Dup[]="0";//消息是否重发,0 不重发,1 重发 char MQTT_Retain[]="0";//遗嘱消息是否存储到服务器,0不需要,1 需要 /*********************************************************** 【函数名称】DTU_Initconfig() 【功 能】配置MQTT服务器连接初始化配置 【输入参数】无 【返回参数】Congfig_flag 【备 注】DTU_Mode:TCP=0、MQTT=1 ***********************************************************/ void DTU_Initconfig(int DTU_Mode) { //首先要配置模块所处的工作模式 //选择联网方式 if(DTU_Mode==1) { Usart2_SendString("AT+CFGNET=1\r\n");//mqtt模式 Delay_Ns(1); if(FindString(Usart2_RX_Buf,"AT+CFGNET=1\r\n")) { printf("已设置为MQTT模式,等待模块重启\n"); } else { printf("配置失败\n"); } Usart2_SendString("AT+CFGPARA=SAVE\r\n");//保存参数,并等待重启 Delay_Ns(6); MQTT_Initconfig(); } else { Usart2_SendString("AT+CFGNET=0\r\n");//mqtt模式 Delay_Ns(1); if(FindString(Usart2_RX_Buf,"AT+CFGNET?\r\n")) { printf("已设置为TCP模式,等待模块重启\n"); } Usart2_SendString("AT+CFGPARA=SAVE\r\n");//保存参数,并等待重启 Delay_Ns(6); NETCongfig(tcp_agreement,DTU_HeartData,DTU_HeartTime,DTU_IP,DTU_PORT); } } /*********************************************************** 【函数名称】MQTT_Initconfig 【功 能】配置MQTT服务器连接初始化配置 【输入参数】 【返回参数】Congfig_flag 【备 注】非阿里云平台登录例程 ***********************************************************/ void MQTT_Initconfig() { //配置服务器和客户端ID MQTT_ServerCongfig(mqtt_IP,mqtt_PORT,mqtt_deviceclientid,mqtt_HeartTime); //配置登录平台账户密码 MQTT_CountCongfig(mqtt_username,mqtt_password,MQTT_Encryptflag); //设置会话模式 MQTT_RemainCongfig(); //设置遗嘱模式 MQTT_WILLCongfig(); //设置订阅主题:如果存在更换平台,要使用清除订阅主题指令@clean@sub@,清除旧的订阅主题,清除时需要发保存指令才能生效。 MQTT_SubTopicConfig(mqtt_subtopic,MQTT_Qos); //设置发布主题 MQTT_PubTopicConfig(mqtt_pubtopic,MQTT_Qos,MQTT_Retain,MQTT_Dup); //保存参数设置 Usart2_SendString("AT+CFGPARA=SAVE");//保存参数,并等待重启 Delay_Ns(6); //延时等待,注意:只要是模块重启操作,延时等待时间要求10秒以上 } /*********************************************************** 【函数名称】NETCongfig 【功 能】配置远程服务器参数 【输入参数】Mode 协议,tcp HeartData 心跳包内容 Time 心跳间隔时间 IP 服务器IP地址 Port 端口号 【返回参数】Congfig_flag 【备 注】无 ***********************************************************/ void NETCongfig(char*Mode,char*HeartData,char*Time,char*IP,char*Port) { int i,j; //注意心跳包长度,Congfig_Server申请的空间长度要大于整条指令长度。 char Congfig_Server[50]="@config@server@"; char str2[]="###"; char str1[]=","; strcat(Congfig_Server,Mode); strcat(Congfig_Server,str1); strcat(Congfig_Server,HeartData); strcat(Congfig_Server,str1); strcat(Congfig_Server,Time); strcat(Congfig_Server,str1); strcat(Congfig_Server,IP); strcat(Congfig_Server,str1); strcat(Congfig_Server,Port); strcat(Congfig_Server,str2); //打印拼接后的服务器配置指令 j=strlen(Congfig_Server); //计算出长度 // printf("j=%d\n",j); for(i=0;i<=j;i++) { printf("%c",Congfig_Server[i]); } printf("\n"); // 清除串口2缓存数据 Clear_Usart2Buf(); Delay_Ns(1); //TCP连接--服务器配置指令 Usart2_SendString((char*)Congfig_Server); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"AT+CFGSERVER?")) { Usart2_SendString("AT+CFGPARA=SAVE"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"AT+CFGPARA?")) { Congfig_flag=1; printf("Congfig_flag=%d\n",Congfig_flag); printf("IP和端口号已配置完成,等待模块重启\n"); } else { Congfig_flag=0; printf("Congfig_flag=%d\n",Congfig_flag); printf("配置失败,模组串口无响应,请检查串口\n"); } } else { Congfig_flag=0; // printf("Congfig_flag=%d\n",Congfig_flag); printf("配置指令无响应,请检查串口\n"); } } /*********************************************************** 【函数名称】MQTT_ServerCongfig 【功 能】配置远程MQTT服务器参数 【输入参数】 Time 心跳间隔时间 IP 服务器IP地址 Port 端口号 【返回参数】无 【备 注】示例@config@[email protected],6002,657554468,60### ***********************************************************/ void MQTT_ServerCongfig(char*IP,char*Port,char*MQTT_Client,char*Time) { int i,j; char Congfig_Server[50]="@config@server@"; char str2[]="###"; char str1[]=","; strcat(Congfig_Server,IP); strcat(Congfig_Server,str1); strcat(Congfig_Server,Port); strcat(Congfig_Server,str1); strcat(Congfig_Server,MQTT_Client); strcat(Congfig_Server,str1); strcat(Congfig_Server,Time); strcat(Congfig_Server,str2); //打印拼接后的服务器配置指令 j=strlen(Congfig_Server); //计算出长度 printf("j=%d\n",j); for(i=0;i<=j;i++) { printf("%c",Congfig_Server[i]); } printf("\n"); // 清除串口1缓存数据 Clear_Usart2Buf(); Delay_Ns(1); Usart2_SendString((char*)Congfig_Server); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"AT+CFGSERVER?")) { printf("Server Congfig OK\n"); } else { printf("Server Congfig fail!\n"); } } /*********************************************************** 【函数名称】MQTT_CountCongfig 【功 能】配置登录账户密码 【输入参数】 MQTT_User 用户名 MQTT_Keyword 秘钥 MQTT_Encrypt 用户信息加密 【返回参数】无 【备 注】示例@config@user@220520,LBWIOT,0### ***********************************************************/ void MQTT_CountCongfig(char*MQTT_User,char*MQTT_Keyword,char*MQTT_Encrypt) { int i,j; char Congfig_User[50]="@config@user@";//开辟的存储长度要根据账户密码所占长度需求设定 char str2[]="###"; char str1[]=","; strcat(Congfig_User,MQTT_User); strcat(Congfig_User,str1); strcat(Congfig_User,MQTT_Keyword); strcat(Congfig_User,str1); strcat(Congfig_User,MQTT_Encrypt); strcat(Congfig_User,str2); //打印拼接后的服务器配置指令 j=strlen(Congfig_User); //计算出长度 // printf("j=%d\n",j); for(i=0;i<=j;i++) { printf("%c",Congfig_User[i]); } printf("\n"); // 清除串口1缓存数据 Clear_Usart2Buf(); Delay_Ns(1); Usart2_SendString((char*)Congfig_User); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@config@user@ok###")) { printf("UserCount Congfig OK\n"); } else { printf("UserCount Congfig fail!\n"); } } /*********************************************************** 【函数名称】MQTT_RemainCongfig 【功 能】配置MQTT会话 【输入参数】无 【返回参数】无 【备 注】示例@config@remain@1,2018-10-31### ***********************************************************/ void MQTT_RemainCongfig() { // 清除串口2缓存数据 Clear_Usart2Buf(); Delay_Ns(1); Usart2_SendString("@config@remain@1,2018-10-31###"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@config@remain@ok###")) { printf("Remain Congfig OK\n"); } else { printf("Remain Congfig fail!\n"); } } /*********************************************************** 【函数名称】MQTT_WILLCongfig 【功 能】配置MQTT遗嘱消息,默认无遗嘱模式 【输入参数】无 【返回参数】无 【备 注】示例@config@will@0,0,0,0,0### 若要遗嘱模式,请参考字节拼接函数的使用方法,用户自己定义一个函数 本示例只演示MQTT 无遗嘱模式连接服务器用法 ***********************************************************/ void MQTT_WILLCongfig() { // 清除串口2缓存数据 Clear_Usart2Buf(); Delay_Ns(1); Usart2_SendString("@config@will@0,0,0,0,0###"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@config@will@ok###")) { printf("WILL Congfig OK\n"); } else { printf("WILL Congfig fail!\n"); } } /*********************************************************** 【函数名称】 MQTT_SubTopicConfig 【功 能】 设置订阅主题 【输入参数】topicMode,对MQTT主题的操作,订阅或者取消订阅 topicname, 主题名 qos,主题等级,分别有三个 0/1/2 【返回参数】无 【备 注】订阅@config@sub@OK4ZS40G93619F5Y/+,0### 若想取消订阅,则要清除订阅主题即可 ***********************************************************/ void MQTT_SubTopicConfig(char*topicname,char*topic_qos) { int i,j; //注意心跳包长度,Congfig_Server申请的空间长度要大于整条指令长度。 char SUB_Topic[50]="@config@sub@"; char str1[]=","; char str2[]="###"; strcat(SUB_Topic,topicname); strcat(SUB_Topic,str1); strcat(SUB_Topic,topic_qos); strcat(SUB_Topic,str2); //打印拼接后的服务器配置指令 j=strlen(SUB_Topic); //计算出长度 printf("j=%d\n",j); for(i=0;i<=j;i++) { printf("%c",SUB_Topic[i]); } printf("\n"); //订阅主题 //清除串口2缓存数据 Clear_Usart2Buf(); Delay_Ns(1); Usart2_SendString((char*)SUB_Topic); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@config@sub@ok###")||FindString(Usart2_RX_Buf,"@config@sub@repeat###"))//成功订阅主题 { printf("Subtopic set ok!"); } else { printf("Subtopic set fail!"); //订阅失败 } } /*********************************************************** 【函数名称】 MQTT_PubTopicConfig 【功 能】配置发布主题 【输入参数】topicname 主题 qos 主题等级 mqtt_retain 遗嘱消息是否存储到服务器 mqtt_dup 消息是否重发 mqtt_messge 要发送的消息内容 【返回参数】无 【备 注】无;@config@pub@topic,qos,retain,dup,messge### 例如@config@pub@OK4ZS40G93619F5Y,0,0,0### ***********************************************************/ void MQTT_PubTopicConfig(char*topicname,char*qos,char*mqtt_retain,char*mqtt_dup) { int i,j; //注意心跳包长度,Congfig_Server申请的空间长度要大于整条指令长度。 char PUB_PubTopic[50]="@config@pub@"; char str1[]=","; char str2[]="###"; strcat(PUB_PubTopic,topicname); strcat(PUB_PubTopic,str1); strcat(PUB_PubTopic,qos); strcat(PUB_PubTopic,str1); strcat(PUB_PubTopic,mqtt_retain); strcat(PUB_PubTopic,str1); strcat(PUB_PubTopic,mqtt_dup); strcat(PUB_PubTopic,str2); //打印拼接后的服务器配置指令 j=strlen(PUB_PubTopic);//计算出长度 printf("j=%d\n",j); for(i=0;i<=j;i++) { printf("%c",PUB_PubTopic[i]); } // 清除串口2缓存数据 Clear_Usart2Buf(); Delay_Ns(1); Usart2_SendString((char*)PUB_PubTopic); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@config@pub@ok###")) { printf("Pubtopic set ok"); } else { printf("Pubtopic set fail"); } } /******************************************************************** 【函数名称】 GET_GNSS() 【功 能】获取GNSS定位信息 【输入参数】无 【返回参数】无 【备 注】E是东经 W是西经 N是北纬 S是南纬 假设返回:@get@[email protected],N27.3778766,0,01### ********************************************************************/ void GET_GNSS() { int i,j,lenth1,lenth2; char *pFind_1 = NULL;//指针,地址1 char *pFind_2 = NULL;//指针,地址2 char *p_buf= NULL; //分割后的字符指针 char *delim1 = ","; //分隔符 Clear_Usart2Buf(); // 清除串口2缓存数据 Delay_Ns(1); Usart2_SendString("@get@decode@"); Delay_Ns(5); //此时要等待,获取定位需要时间 if(FindString(Usart2_RX_Buf,"@get@gnss@NoFix###")==NULL ) { printf("GNSS Get Faile!\n"); } else { printf("GNSS Get sucess!\n"); //截取这段经度数据, E114.6027950 pFind_1=strstr(Usart2_RX_Buf, "@get@decode@"); pFind_2=strstr(Usart2_RX_Buf, ","); lenth1=pFind_2-pFind_1; //求出该地址区间数据长度 printf("lenth1=%d\n",lenth1); for(i=12;i<lenth1;i++) { Buf_longitude[i]=Usart2_RX_Buf[i]; printf("longitude=%c",Buf_longitude[i]); } //先分割字符串,分隔符为“ ,” p_buf = strtok(Usart2_RX_Buf,delim1); p_buf= strtok(NULL,delim1); lenth2=strlen(p_buf);//计算出该区间数据长度 printf("latitude_lenth2=%d\n",lenth2);//计算出该区间数据长度 printf("latitude="); //截取这段纬度数据,N27.3778766 for(j=0;j<lenth2;j++) { Buf_latitude[j]=p_buf[j]; printf("%c",Buf_latitude[j]); } } } /*********************************************************** 【函数名称】 GET_IMEI() 【功 能】获取IMEI号 【输入参数】无 【返回参数】无 【备 注】无;IMEI号长度15个字节 ***********************************************************/ void GET_IMEI() { int i,j=0,m; for(m=0;m<3;m++) { Clear_Usart2Buf(); // 清除串口1缓存数据 Delay_Ns(1); Usart2_SendString("@get@imei@"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@get@imei@error")) { printf("IMEI号获取失败!\n"); printf("故障提示:(1)请检查模块是否开机?\n"); printf("故障提示:(2)请检查串口通信是否故障?\n"); } else { printf("IMEI:"); for(i=10;i<25;i++) { Buf_IMEI[j]=Usart2_RX_Buf[i]; printf("%c",Buf_IMEI[j]); j++; } printf("\n"); break ; } } } /*********************************************************** 【函数名称】 GET_CSQ 【功 能】获取信号值 【输入参数】无 【返回参数】无 【备 注】无 ***********************************************************/ void GET_CSQ() { int i,j=0,m; for(m=0;m<3;m++)//查询5次 { Clear_Usart2Buf();//清除串口1缓存数据 Delay_Ns(1); Usart2_SendString("@get@csq@"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@get@csq@error")) { printf("4G信号CSQ值获取失败!\n"); printf("故障提示:(1)请检查模块是否开机?\n"); printf("故障提示:(2)请检查串口通信是否故障?\n"); printf("故障提示:(3)请检查SIM卡是否插入?\n"); } else { printf("4G信号CSQ="); for(i=9;i<11;i++) { Buf_CSQ[j]=Usart2_RX_Buf[i]; printf("%c",Buf_CSQ[j]); j++; } printf("\n"); break; } } } /*********************************************************** 【函数名称】 GET_SIM_ICCID() 【功 能】获取ICCID号 【输入参数】无 【返回参数】无 【备 注】1获取成功,0获取失败 ***********************************************************/ void GET_ICCID() { int i,j=0,m; for(m=0;m<3;m++)//查询3次 { Clear_Usart2Buf();// 清除串口2缓存数据 Delay_Ns(1); Usart2_SendString("@get@iccid@"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@get@iccid@error")) { printf("ICCID 获取失败!\n"); printf("故障提示:(1)请检查串口通信是否故障?\n"); printf("故障提示:(2)请检查SIM卡是否插入?\n"); } else { printf("SIM卡ICCID:"); for(i=12;i<31;i++) { Buf_ICCID[j]=Usart2_RX_Buf[i]; printf("%c",Buf_ICCID[j]); j++; } printf("\n"); break; } } } /*********************************************************** 【函数名称】 GET_AGPS_Position() 【功 能】获取基站定位信息 【输入参数】无 【返回参数】无 【备 注】1获取成功,0获取失败 DTU指令: @get@position@ 示例:模块反馈的信息 @get@[email protected],023.1598603### ***********************************************************/ void GET_AGPS_Position() { int i,k=0,j=0,m; char Buf_AGPS_LOG[]={0}; //经度 char Buf_AGPS_LAT[]={0}; //纬度 for(m=0;m<3;m++)//查询3次 { Clear_Usart2Buf();// 清除串口1缓存数据 Delay_Ns(1); Usart2_SendString("@get@position@"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@get@position@error")) { printf("AGPS_Position基站定位信息获取失败!\n"); printf("故障提示:(1)请检查串口通信是否故障?\n"); printf("故障提示:(2)请检查SIM卡是否插入?\n"); } else { printf("AGPS_Position基站定位信息:\n"); printf("经度:"); for(i=14;i<25;i++) { Buf_AGPS_LOG[j]=Usart2_RX_Buf[i];//获取经度 printf("%c",Buf_AGPS_LOG[j]); j++; } printf("\n"); printf("纬度:"); for(i=26;i<37;i++) { Buf_AGPS_LAT[k]=Usart2_RX_Buf[i];//获取纬度 printf("%c",Buf_AGPS_LAT[k]); k++; } printf("\n"); break; } } } /*********************************************************** 【函数名称】 GET_Version() 【功 能】获取版本号 【输入参数】无 【返回参数】无 【备 注】1获取成功,0获取失败 DTU指令: @get@version@ 示例:模块反馈的信息@get@[email protected]### ***********************************************************/ void GET_Version() { int i,j=0,m; for(m=0;m<3;m++) { Clear_Usart2Buf(); // 清除串口1缓存数据 Delay_Ns(1); Usart2_SendString("@get@version@"); Delay_Ns(1); if(FindString(Usart2_RX_Buf,"@get@position@error###")) { printf("版本号获取失败!\n"); printf("故障提示:(1)请检查模块是否开机?\n"); printf("故障提示:(2)请检查串口通信是否故障?\n"); } else { printf("模块固件版本号Version:"); for(i=14;i<23;i++) { Buf_IMEI[j]=Usart2_RX_Buf[i]; printf("%c",Buf_IMEI[j]); j++; } printf("\n"); break ; } } } /**************************************************************** 【函数名称】 Check_DTU_network 【功 能】 检测模块状态 【输入参数】num 检测次数 【返回参数】无 【备 注】检测模块是否已就绪。每间隔1秒查询一次 *****************************************************************/ void Check_DTU_network(u8 num) { int k; for(k=0;k<num;k++)//检测TCP连接状态 { Clear_Usart2Buf(); // 清除串口2缓存数据 Delay_Nms(100); Usart2_SendString("@get@netstate@");//查询网络连接状态 Delay_Nms(400); if(FindString(Usart2_RX_Buf,"@get@netstate@ok")) { TCP_Connectflag=1; printf("TCP_Connectflag=%d\n",TCP_Connectflag); printf("TCP连接成功!\n"); break; } else { TCP_Connectflag=0; printf("TCP_Connectflag=%d\n",TCP_Connectflag); printf("TCP连接失败!\n"); printf("故障提示:(1)请检查模块IP地址和端口是否正确?\n"); printf("故障提示:(2)请检查SIM卡是否欠费?是否被地域限制和机卡绑定?\n"); } } } /**************************************************************** 【函数名称】 Login_OneNET_Server 【功 能】 登陆OneNET服务器平台 【输入参数】number 次数 【返回参数】无 【备 注】发送登录包,重发number次 *****************************************************************/ void Login_OneNET_Server(u8 number) { u8 j,m; //如果登陆包发送成功,服务器会应答设备OK for(j=0;j<number;j++) { for(m=0;m<=strlen(LoginMessage);m++)//打印登录包信息 { printf("%c",LoginMessage[m]); } printf("\n"); Clear_Usart2Buf(); // 清除串口1缓存数据 Delay_Nms(100); Usart2_SendString(LoginMessage); Delay_Nms(400);//延时等待 if(FindString(Usart2_RX_Buf,"received")) { Login_OneNET_flag=1; printf("登陆包发送成功!\n"); break; } else { Login_OneNET_flag=0; printf("登陆包发送失败!\n"); printf("故障提示:(1)请检查服务器平台是否存在该设备编号?\n"); printf("故障提示:(2)请检登录包格式是否完整?\n"); } } } /**************************************************************** 【函数名称】 Login_Message 【功 能】 组建登录包 【输入参数】无 【返回参数】无 【备 注】检测模块是否已就绪。每间隔1秒查询一次,超时时间为20秒 使用strcat()函数向str1字符串追加内容的时候,由于str1空间比较小, 而追加的字符又很多,就会导致多出来的字符溢出到相邻的存储空间中, 导致软件运行奔溃。 *****************************************************************/ void Login_Message() { /*在OneNET平台上LUA脚本取名要与登录包中的脚本名称要一致*/ char str1[]="#cupluas*";//关联的LUA脚本名称:cupluas strcat(LoginMessage,Buf_IMEI);//拼接IMEI strcat(LoginMessage,str1);//拼接脚本名称 strcat(LoginMessage,"\0");//拼接结尾符 } /**************************************************************** 【函数名称】 FindString 【功 能】判断缓存中是否含有指定的字符串 【输入参数】字符串 p 【返回参数】整型值1或0 【备 注】调用extern char *strstr(char *str1, char *str2)该函数 *****************************************************************/ int FindString(char* p1,char* p2) { if(strstr(p1,p2)!=NULL) { return 1; } return 0; } /*********************************************************** 【函数名称】LTE_KEYGPIOConfig 【功 能】配置LTE_KEY GPIO端口 【输入参数】无 【返回参数】无 【备 注】电源通断引脚KEY GPIO配置 ***********************************************************/ void LTE_KEYGPIOConfig() { GPIO_InitTypeDef GPIO_InitStructure; RCC_APB2PeriphClockCmd(LTE_PWRKEY_RCC, ENABLE); GPIO_InitStructure.GPIO_Pin = LTE_PWRKEY; GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz; GPIO_Init(LTE_PWRKEY_PORT, &GPIO_InitStructure); } /*********************************************************** 【函数名称】LTE_RSTGPIOConfig 【功 能】配置LTE_RST GPIO端口 【输入参数】无 【返回参数】无 【备 注】推挽输出 ***********************************************************/ void LTE_RSTGPIOConfig() { GPIO_InitTypeDef GPIO_InitStructure; RCC_APB2PeriphClockCmd(LTE_RST_RCC, ENABLE); GPIO_InitStructure.GPIO_Pin = LTE_RST; GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz; GPIO_Init(LTE_RST_PORT, &GPIO_InitStructure); } /*********************************************************** 【函数名称】LTE_DTU_RESET 【功 能】复位DTU模块 【输入参数】无 【返回参数】无 【备 注】推挽输出 ***********************************************************/ void LTE_DTU_RESET() { LTE_RST_H;//拉高复位模块 Delay_Nms(200);//延时200ms LTE_RST_L;//拉低,禁止复位 Delay_Ns(5);//延时5秒,等待模块完成重启 } 在不更改原代码的情况下,将DTU指令更改为AT指令

大家在看

recommend-type

convex optimiation教材及课后答案

stanford的stephen boyd教授的最经典教材凸优化及课后解答,学习机器学习同学的至宝。
recommend-type

电子教学套件

电子教学套件教学工具集应用开发,现代电子教学应用开发
recommend-type

快速傅里叶变换-史上最全Origin入门详细教程

快速傅里叶变换 示例准备: ① 创建包含1 个X 列和2 个Y 列的工作表。 ② 用【Set Values 】对话框将A(X)列值设置为 " ( i- l ) *pi/50", 范围Row(i) : " 1 To 100 "。 ③ 将B(Y)、C(Y)列值分别设置为" sin(Col(A)) "、" sin(Col(A) +0.5*sin(10*Col(A)))"。 ① 选中Sheet l 工作表中的B(Y)列。 ② 单击菜单命令【Analysis 】→ 【Signal Processing 】→ 【FFT】→【FFT】打开【Signal Processing\FFT: fft1 】对话框 * 山东农业大学化学与材料科学学院 朱树华
recommend-type

Frequency-comb-DPLL:数字锁相环软件,用于使用Red Pitaya锁定频率梳

数字锁相环,用于使用红色火龙果锁定频率梳 固件/软件允许使用此硬件来锁相频率梳。 更一般而言,它与硬件一起提供了一个数字控制盒,该数字控制盒可以支持双通道锁相环,包括输入rf信号的前端IQ检测。 因此,虽然此数字控制盒可用于锁相其他系统,但下面的讨论假定用户正在操作频率梳。 入门 从“发布部分”( )下载所需的文件: 可以访问Python GUI的完整源代码存储库; b。 红火龙果的SD卡映像(red_pitaya_dpll_2017-05-31.zip) 阅读并遵循“ RedPitaya DPLL.pdf的说明和操作手册”文件。 软件版本 所需的Python发行版是WinPython-64bit-3.7.2( )。 FPGA Vivado项目在Vivado 2015.4中进行了编译,但是仅使用该软件就不需要安装Vivado。 附加信息 可以从NIST数字控制箱的说明手册中获得更多信
recommend-type

PL2303驱动ForWindows11.zip

PL2303驱动ForWindows11.zip

最新推荐

recommend-type

基于python实现MQTT发布订阅过程原理解析

1. **发布/订阅模型**:MQTT采用发布/订阅模式,使得消息发布者和订阅者之间解耦,一个发布者可以向多个订阅者广播消息,而订阅者也能接收多个发布者的消息。 2. **消息传输透明**:MQTT协议并不关心消息的具体内容...
recommend-type

nuke id通道提取测试文件

nuke id通道提取测试文件
recommend-type

google-api-services-storage-v1-rev20230301-2.0.0.jar中文-英文对照文档.zip

1、压缩文件中包含: 中文-英文对照文档、jar包下载地址、Maven依赖、Gradle依赖、源代码下载地址。 2、使用方法: 解压最外层zip,再解压其中的zip包,双击 【index.html】 文件,即可用浏览器打开、进行查看。 3、特殊说明: (1)本文档为人性化翻译,精心制作,请放心使用; (2)只翻译了该翻译的内容,如:注释、说明、描述、用法讲解 等; (3)不该翻译的内容保持原样,如:类名、方法名、包名、类型、关键字、代码 等。 4、温馨提示: (1)为了防止解压后路径太长导致浏览器无法打开,推荐在解压时选择“解压到当前文件夹”(放心,自带文件夹,文件不会散落一地); (2)有时,一套Java组件会有多个jar,所以在下载前,请仔细阅读本篇描述,以确保这就是你需要的文件。 5、本文件关键字: jar中文-英文对照文档.zip,java,jar包,Maven,第三方jar包,组件,开源组件,第三方组件,Gradle,中文API文档,手册,开发手册,使用手册,参考手册。
recommend-type

Docker化部署TS3AudioBot教程与实践

### 标题知识点 #### TS3AudioBot_docker - **Dockerfile的用途与组成**:Dockerfile是一个文本文件,包含了所有构建Docker镜像的命令。开发者可以通过编辑Dockerfile来指定Docker镜像创建时所需的所有指令,包括基础镜像、运行时指令、环境变量、软件安装、文件复制等。TS3AudioBot_docker表明这个Dockerfile与TS3AudioBot项目相关,TS3AudioBot可能是一个用于TeamSpeak 3服务器的音频机器人,用于播放音频或与服务器上的用户进行交互。 - **Docker构建过程**:在描述中,有两种方式来获取TS3AudioBot的Docker镜像。一种是从Dockerhub上直接运行预构建的镜像,另一种是自行构建Docker镜像。自建过程会使用到docker build命令,而从Dockerhub运行则会用到docker run命令。 ### 描述知识点 #### Docker命令的使用 - **docker run**:这个命令用于运行一个Docker容器。其参数说明如下: - `--name tsbot`:为运行的容器指定一个名称,这里命名为tsbot。 - `--restart=always`:设置容器重启策略,这里是总是重启,确保容器在失败后自动重启。 - `-it`:这是一对参数,-i 表示交互式操作,-t 分配一个伪终端。 - `-d`:表示后台运行容器。 - `-v /home/tsBot/data:/data`:将宿主机的/home/tsBot/data目录挂载到容器内的/data目录上,以便持久化存储数据。 - `rofl256/tsaudiobot` 或 `tsaudiobot`:指定Docker镜像名称。前者可能是从DockerHub上获取的带有用户名命名空间的镜像,后者是本地构建或已重命名的镜像。 #### Docker构建流程 - **构建镜像**:使用docker build命令可以将Dockerfile中的指令转化为一个Docker镜像。`docker build . -t tsaudiobot`表示从当前目录中读取Dockerfile,并创建一个名为tsaudiobot的镜像。构建过程中,Docker会按顺序执行Dockerfile中的指令,比如FROM、RUN、COPY等,最终形成一个包含所有依赖和配置的应用镜像。 ### 标签知识点 #### Dockerfile - **Dockerfile的概念**:Dockerfile是一个包含创建Docker镜像所有命令的文本文件。它被Docker程序读取,用于自动构建Docker镜像。Dockerfile中的指令通常包括安装软件、设置环境变量、复制文件等。 - **Dockerfile中的命令**:一些常用的Dockerfile命令包括: - FROM:指定基础镜像。 - RUN:执行命令。 - COPY:将文件或目录复制到镜像中。 - ADD:类似于COPY,但是 ADD 支持从URL下载文件以及解压 tar 文件。 - ENV:设置环境变量。 - EXPOSE:声明端口。 - VOLUME:创建挂载点。 - CMD:容器启动时要运行的命令。 - ENTRYPOINT:配置容器启动时的执行命令。 ### 压缩包子文件的文件名称列表知识点 #### 文件命名 - **TS3AudioBot_docker-main**:此文件名表明了这是一个主要的代码库或Dockerfile的存放位置。在开发中,通常main分支代表当前的主版本或正在积极开发的分支。因此TS3AudioBot_docker-main可能表示这是在Dev分支上开发的Dockerfile的主要代码版本。主分支一般比较稳定,并作为新的特性开发的基础。 ### 综合知识点 - **Docker在DevOps中的角色**:Docker作为一种轻量级的容器化技术,在DevOps领域扮演重要角色。它可以快速部署、一致的运行环境、便于测试和迁移应用。通过Dockerfile的编写和docker build命令,开发者可以构建可移植的容器镜像,通过docker run命令则可以快速启动容器实例。 - **TS3AudioBot与TeamSpeak**:TS3AudioBot很可能是一个针对TeamSpeak 3服务器的自动化解决方案。TeamSpeak是一个语音通讯软件,广泛用于线上游戏团队进行沟通。一个音频机器人可以提供自动化的消息通知、音频流控制等功能,提高游戏社区的交流效率。 - **Docker镜像的版本管理**:镜像的命名通常包括用户名、项目名和标签。如rofl256/tsaudiobot中rofl256可能是一个用户名,tsaudiobot可能是项目名称,这样的命名规则有利于镜像的共享和管理。 在介绍以上知识点后,我们理解了标题、描述、标签及文件名称列表中所含的知识点。这些知识点涵盖了Dockerfile的构建、Docker镜像的使用、TS3AudioBot功能以及版本控制等多个方面,为IT专业人员在使用和开发Docker相关项目时提供了必要的信息。
recommend-type

零售销售数据的探索性分析与DeepAR模型预测

### 零售销售数据的探索性分析与DeepAR模型预测 #### 1. 探索性数据分析 在拥有45家商店的情况下,我们选择了第20号商店,来分析其不同部门在三年间的销售表现。借助DeepAR算法,我们可以了解不同部门商品的销售情况。 在SageMaker中,通过生命周期配置(Lifecycle Configurations),我们可以在笔记本实例启动前自定义安装Python包,避免在执行笔记本前手动跟踪所需的包。为了探索零售销售数据,我们需要安装最新版本(0.9.0)的seaborn库。具体操作步骤如下: 1. 在SageMaker的Notebook下,点击Lifecycle Config
recommend-type

llm agent平台

<think>好的,我现在需要帮用户寻找与LLM代理平台解决方案相关的信息。首先,我得明确用户的需求。用户提到了“LLM agent platform solutions”,也就是大型语言模型代理平台的解决方案。这可能涉及到如何构建、部署或优化基于LLM的代理系统。接下来,我应该回忆之前用户提供的引用内容,看看有没有相关的信息可以利用。 根据引用[1],提到构建LLM应用程序的步骤分解,可能涉及到代理平台的设计。引用[2]讨论了评估LLM的挑战,包括可重复性和开源模型的解决方案,这可能影响代理平台的稳定性和选择。引用[3]则提到大模型相关的岗位和面试题,可能涉及实际应用中的技术问题。 接下
recommend-type

Docker实现OAuth2代理:安全的HTTPS解决方案

### 知识点详细说明: #### Dockerfile基础 Dockerfile是一种文本文件,它包含了用户创建Docker镜像所需的命令和参数。Docker通过读取Dockerfile中的指令自动构建镜像。Dockerfile通常包含了如下载基础镜像、安装软件包、执行脚本等指令。 #### Dockerfile中的常用指令 1. **FROM**: 指定基础镜像,所有的Dockerfile都必须以FROM开始。 2. **RUN**: 在构建过程中执行命令,如安装软件。 3. **CMD**: 设置容器启动时运行的命令,可以被docker run命令后面的参数覆盖。 4. **EXPOSE**: 告诉Docker容器在运行时监听指定的网络端口。 5. **ENV**: 设置环境变量。 6. **ADD**: 将本地文件复制到容器中,如果是tar归档文件会自动解压。 7. **ENTRYPOINT**: 设置容器启动时的默认命令,不会被docker run命令覆盖。 8. **VOLUME**: 创建一个挂载点以挂载外部存储,如磁盘或网络文件系统。 #### OAuth 2.0 Proxy OAuth 2.0 Proxy 是一个轻量级的认证代理,用于在应用程序前提供OAuth认证功能。它主要通过HTTP重定向和回调机制,实现对下游服务的安全访问控制,支持多种身份提供商(IdP),如Google, GitHub等。 #### HTTPS和SSL/TLS HTTPS(HTTP Secure)是HTTP的安全版本,它通过SSL/TLS协议加密客户端和服务器之间的通信。使用HTTPS可以保护数据的机密性和完整性,防止数据在传输过程中被窃取或篡改。SSL(Secure Sockets Layer)和TLS(Transport Layer Security)是用来在互联网上进行通信时加密数据的安全协议。 #### Docker容器与HTTPS 为了在使用Docker容器时启用HTTPS,需要在容器内配置SSL/TLS证书,并确保使用443端口。这通常涉及到配置Nginx或Apache等Web服务器,并将其作为反向代理运行在Docker容器内。 #### 临时分叉(Fork) 在开源领域,“分叉”指的是一种特殊的复制项目的行为,通常是为了对原项目进行修改或增强功能。分叉的项目可以独立于原项目发展,并可选择是否合并回原项目。在本文的语境下,“临时分叉”可能指的是为了实现特定功能(如HTTPS支持)而在现有Docker-oauth2-proxy项目基础上创建的分支版本。 #### 实现步骤 要实现HTTPS支持的docker-oauth2-proxy,可能需要进行以下步骤: 1. **准备SSL/TLS证书**:可以使用Let's Encrypt免费获取证书或自行生成。 2. **配置Nginx/Apache服务器**:在Dockerfile中添加配置,以使用SSL证书和代理设置。 3. **修改OAuth2 Proxy设置**:调整OAuth2 Proxy配置以使用HTTPS连接。 4. **分叉Docker-oauth2-proxy项目**:创建项目的分支副本,以便进行修改。 5. **编辑Dockerfile**:在分叉的项目中编写或修改Dockerfile,包括下载基础镜像、设置环境变量、添加SSL证书、配置Nginx/Apache和OAuth2 Proxy等步骤。 6. **构建和测试新镜像**:使用Docker构建镜像,并在安全环境中进行测试,确保HTTPS配置正确,并且OAuth2 Proxy功能正常工作。 7. **部署到生产环境**:在确认无误后,将配置好的镜像部署到生产环境中。 #### 压缩包子文件的文件名称列表 - **docker-oauth2-proxy-master**: 这可能是指在GitHub等代码托管平台上,docker-oauth2-proxy项目的主分支或主仓库。名称列表中的“master”暗示了该文件夹包含的是主分支的代码。 总结来说,要实现一个支持HTTPS的docker-oauth2-proxy,开发者需要进行一系列的配置和编码工作,包括使用Dockerfile来构建自定义的Docker镜像,配置SSL/TLS证书,分叉并修改现有的开源项目代码。通过这些步骤,可以确保OAuth2 Proxy能够安全地处理HTTPS请求,并为下游服务提供安全认证功能。
recommend-type

利用AmazonSageMaker进行图像分类:从理论到实践

# 利用 Amazon SageMaker 进行图像分类:从理论到实践 ## 1. 主题建模与图像分类概述 在数据科学领域,从大量非结构化数据中提取信息和主题至关重要。像 SageMaker 的神经主题模型(NTM)这类主题建模技术,提供了线性和非线性学习方法,能帮助我们深入挖掘数据中的潜在主题。它通过特定的架构和内部机制工作,还支持分布式训练,将数据集分割成多个块进行并行处理。训练完成后,我们可以将模型部署为端点并进行推理,例如解读安然邮件中的主题。 图像分类在过去五年中一直是热门研究领域,因为它能解决众多行业的实际业务问题,如自动驾驶汽车行业就高度依赖图像分类和目标检测模型的准确性。A
recommend-type

wed前端开发网页设计

<think>好的,用户需要寻找关于Web前端开发和网页设计的相关资源或教程。首先,我需要理解用户的具体需求,他们可能刚入门,想要系统学习,或者有一定基础,需要进阶教程。根据用户的问题,他们提到了“教程”和“资源”,可能希望推荐书籍、在线课程、框架文档以及社区论坛等。 接下来,我需要参考用户提供的引用内容。引用[1]提到了周文洁的《HTML5网页前端设计实战》,这是一本配套的实战项目教程,适合有基础的读者,可能可以作为书籍推荐之一。引用[2]概述了Web前端开发的技术分类,包括客户端和服务器端技术,以及常用框架如Bootstrap、React等。引用[3]是关于Delphi的TMS WEB
recommend-type

eosforce下的scatter API应用实例教程

### eosforce使用分散API #### 知识点一:什么是EOSForce EOSForce是以EOSIO为技术基础,旨在为区块链应用提供高性能的公链解决方案。它类似于EOS,也使用了EOSIO软件套件,开发者可以基于EOSIO构建DAPP应用,同时它可能拥有与EOS不同的社区治理结构和经济模型。对于开发者来说,了解EOSForce的API和功能是非常关键的,因为它直接影响到应用的开发与部署。 #### 知识点二:scatter API的介绍 scatter API 是一个开源的JavaScript库,它的目的是为了简化EOSIO区块链上各类操作,包括账户管理和交易签名等。scatter旨在提供一个更为便捷、安全的用户界面,通过API接口与EOSIO区块链进行交互。用户无需保存私钥即可与区块链进行交互,使得整个过程更加安全,同时开发者也能够利用scatter实现功能更加强大的应用。 #### 知识点三:scatter API在EOSForce上的应用 在EOSForce上使用scatter API可以简化开发者对于区块链交互的工作,无需直接处理复杂的私钥和签名问题。scatter API提供了一整套用于与区块链交互的方法,包括但不限于账户创建、身份验证、签名交易、数据读取等。通过scatter API,开发者可以更加专注于应用逻辑的实现,而不必担心底层的区块链交互细节。 #### 知识点四:安装和运行scatter_demo项目 scatter_demo是基于scatter API的一个示例项目,通过它可以学习如何将scatter集成到应用程序中。根据提供的描述,安装该项目需要使用npm,即Node.js的包管理器。首先需要执行`npm install`来安装依赖,这个过程中npm会下载scatter_demo项目所需的所有JavaScript包。安装完成后,可以通过运行`npm run dev`命令启动项目,该命令通常与项目中的开发环境配置文件(如webpack.config.js)相对应,用于启动本地开发服务器和热重载功能,以便开发者实时观察代码修改带来的效果。 #### 知识点五:配置eosforce到scatter 在scatter_demo项目中,将eosforce配置到scatter需要进入scatter的设置界面。scatter提供了一个可视化的界面,允许用户管理自己的区块链网络配置。在scatter设置中选择“网络”一栏,然后选择“新建”,在此步骤中需要选择“eos”作为区块链类型。之后,将eosforce的节点配置信息填入对应区域,完成网络的设置。这样,scatter就能够连接到eosforce区块链,用户可以通过scatter API与eosforce区块链进行交互。 #### 知识点六:npm包管理器及安装命令 npm是Node.js的包管理器,它在Node.js项目中扮演着至关重要的角色,用来安装、管理和分享项目所需的代码包。`npm install`是npm的常用命令,用于安装项目依赖。在执行此命令时,npm会根据项目根目录中的`package.json`文件自动下载并安装所需的所有依赖包。这个文件描述了项目的依赖关系,包括每个依赖的版本范围。通过这种方式,开发者可以确保项目在不同的环境中都能够有相同的行为表现。 #### 结论 了解和掌握如何在EOSForce中使用scatter API对于区块链应用开发者来说是极其重要的。scatter简化了与EOSIO区块链的交互过程,提高开发效率,降低了实现复杂功能的技术门槛。在实际操作中,开发者需要关注如何正确安装scatter_demo项目,如何配置eosforce节点到scatter中,以及如何利用scatter API开发出功能完善的区块链应用。通过这些知识点的了解,开发者可以更好地把握EOSForce生态中的开发实践,并在项目中实现安全、便捷的区块链交互。