add mqtt client support for ec20 LTE DTU

2020-05-22 11:57:26 +08:00
parent 5906021658
commit adaac8789f
30 changed files with 760 additions and 2508 deletions
--- a/board/LTE_DTU_EC20_SIM7600CE/BSP/Src/mqtt_client.c
+++ b/board/LTE_DTU_EC20_SIM7600CE/BSP/Src/mqtt_client.c
@@ -0,0 +1,94 @@
+#include "ec20.h"
+#include "mcu_init.h"
+#include "tos_k.h"
+#include "mqttclient.h"
+
+//#define USE_SIM7600CE
+
+#define USE_EC20
+
+mqtt_client_t client;
+client_init_params_t init_params;
+
+static void tos_topic_handler(void* client, message_data_t* msg)
+{
+    (void) client;
+    LOG_I("-----------------------------------------------------------------------------------");
+    LOG_I("%s:%d %s()...\ntopic: %s, qos: %d. \nmessage:\n\t%s\n", __FILE__, __LINE__, __FUNCTION__, 
+            msg->topic_name, msg->message->qos, (char*)msg->message->payload);
+    LOG_I("-----------------------------------------------------------------------------------\n");
+}
+
+
+void mqttclient_task(void)
+{
+    int error;
+
+    char buf[100] = { 0 };
+    
+    mqtt_message_t msg;
+    
+    memset(&msg, 0, sizeof(msg));
+    
+#ifdef USE_SIM7600CE 
+    sim7600ce_sal_init(HAL_UART_PORT_2);
+#endif
+
+#ifdef USE_EC20
+    ec20_sal_init(HAL_UART_PORT_2);
+#endif
+    
+    init_params.read_buf_size = 256;
+    init_params.write_buf_size = 256;
+    
+#ifdef MQTT_NETWORK_TYPE_TLS
+    init_params.connect_params.network_params.network_ssl_params.ca_crt = test_ca_get();
+    init_params.connect_params.network_params.port = "8883";
+#else
+    init_params.connect_params.network_params.port = "1883";
+#endif
+    init_params.connect_params.network_params.addr = "111.230.189.156"; //"47.95.164.112";//"jiejie01.top"; //"129.204.201.235"; //"192.168.1.101";
+
+    init_params.connect_params.user_name = "RUAP1R610Vsupowang;12010126;OQHZL;1626061655"; // random_string(10); //"jiejietop-acer1";
+    init_params.connect_params.password = "ed41ae0cdf9100ce2aa5d5874566f8f4f77b1eab80b19ede4d1419eafe92eb54;hmacsha256"; //random_string(10); // "123456";
+    init_params.connect_params.client_id = "RUAP1R610Vsupowang";; //random_string(10); // "clientid-acer1";
+    init_params.connect_params.clean_session = 1;
+
+    log_init();
+
+    mqtt_init(&client, &init_params);
+
+    error = mqtt_connect(&client);
+    
+    LOG_D("mqtt connect error is %#x", error);
+    
+    //mqtt_set_interceptor_handler(&client,tos_topic_handler);
+    
+    mqtt_subscribe(&client, "RUAP1R610V/supowang/data", QOS0, tos_topic_handler);
+    
+    LOG_D("mqtt subscribe error is %#x", error);
+    
+    memset(&msg, 0, sizeof(msg));
+
+    for (;;) {
+        
+        sprintf(buf, "welcome to mqttclient, this is a publish test, a rand number: %d ...", random_number());
+        
+        msg.qos = QOS0;
+        msg.payload = (void *) buf;
+        
+        error = mqtt_publish(&client, "RUAP1R610V/supowang/data", &msg);
+
+        tos_task_delay(4000); 
+    }
+}
+
+
+void application_entry(void *arg)
+{
+    mqttclient_task();
+    while (1) {
+        printf("This is a mqtt demo!\r\n");
+        tos_task_delay(1000);
+    }
+}