标题: MQTT-relay-sdk-v21程序源码 [打印本页]

---

作者: aedkhz    时间: 2018-10-17 13:38
标题: MQTT-relay-sdk-v21程序源码
MQTT程序

单片机源程序如下:

1. #include "stdio.h"
   
2. #include "stdlib.h"
   
3. #include "stdint.h"
   
4. #include "string.h"
   
5. #include "system.h"
   
6. #include "sys.h"
   
7. #include "usart.h"
   
8. #include "sim900a.h"
   
9. #include "relay.h"
   
10. #include "mqtt-user.h"
    
11. #include "timer.h"
    
12. #include "timer_task.h"
    
13. #include "frozen.h"
    
14. #include "parameter.h"
    
15. #include "ctype.h"
    
16. #include "MQTTPacket.h"
    
17. 
    
18. /* 需要在这里更改服务器地址端口，用户名密码等信息 */
    
19. /* 设备默认会将IMEI(SIM800C模块上的标号)设置为clientID */
    
20. /*  */
    
21. #define MQTT_SERVER_IP  "relay.mqtt.iot.gz.baidubce.com"
    
22. #define MQTT_SERVER_PORT        "1883"
    
23. 
    
24. char client_id[128] = {0};
    
25. char user_name[128] = {"relay/relay"};
    
26. char password[128] = {"Zqu9im83wlVp8++FgyVJb9d+J4EKd4ytXpa9w02N2hE="};
    
27. char topic[64] = {"relay"};
    
28. 
    
29. int main(void)
    
30. {
    
31.     SystemInit();
    
32.     NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2);
    
33.     delay_init();
    
34.     usart1_init(921600);
    
35.     usart3_init(115200);
    
36.     timer3_init(10000, 7199);//10Khz的计数频率，计数到10000为1s
    
37.     sim900a_gpio_init();
    
38.     relay_init();
    
39.     relay_on();
    
40.    
    
41.     sim900a_user_config();
    
42.     sim900a_get_imei(client_id);   
    
43.    
    
44.     printf("\n*******MQTT INFO************\n");
    
45.     printf("CLIENT ID:%s\n", client_id);
    
46.     printf("USER NAME:%s\n", user_name);
    
47.     printf("PASSWORD:%s\n", password);
    
48.     printf("*******END************\n");
    
49. 
    
50.     mqtt_connection_init(MQTT_SERVER_IP, MQTT_SERVER_PORT, client_id, user_name, password);
    
51.     mqtt_subscribe(topic, 0);
    
52. 
    
53.     while(1) {
    
54.         while (!mqtt_state.connected || mqtt_state.error_count > 1) {
    
55.             mqtt_connection_init(MQTT_SERVER_IP, MQTT_SERVER_PORT, client_id, user_name, password);
    
56.             delay_ms(500);
    
57.             sim900a_cmd_with_reply("AT+CIPSTATUS", "OK", NULL, GSM_CMD_WAIT_NORMAL);
    
58.             mqtt_subscribe(topic, 0);
    
59.             mqtt_send_beat("topic_server", curr_state);
    
60.         }
    
61.         user_task_loop();
    
62.     }
    
63. }
    

复制代码

所有资料51hei提供下载:
mqtt-relay-sdk-v21.zip (387.68 KB, 下载次数: 32)

2018-10-17 13:37 上传

点击文件名下载附件
下载积分: 黑币 -5

---

欢迎光临 (http://www.51hei.com/bbs/)

Powered by Discuz! X3.1