110 lines
3.7 KiB
C
110 lines
3.7 KiB
C
/*
|
|
* @Author: jiejie
|
|
* @Github: https://github.com/jiejieTop
|
|
* @Date: 2019-12-11 21:53:07
|
|
* @LastEditTime: 2020-06-08 20:38:41
|
|
* @Description: the code belongs to jiejie, please keep the author information and source code according to the license.
|
|
*/
|
|
#include <stdio.h>
|
|
#include <unistd.h>
|
|
#include <fcntl.h>
|
|
#include <stdlib.h>
|
|
#include <pthread.h>
|
|
#include "mqttclient.h"
|
|
|
|
// #define TEST_USEING_TLS
|
|
|
|
static const char *test_baidu_ca_crt = {
|
|
"-----BEGIN CERTIFICATE-----\r\n"
|
|
"MIIDXzCCAkegAwIBAgILBAAAAAABIVhTCKIwDQYJKoZIhvcNAQELBQAwTDEgMB4G\r\n"
|
|
"A1UECxMXR2xvYmFsU2lnbiBSb290IENBIC0gUjMxEzARBgNVBAoTCkdsb2JhbFNp\r\n"
|
|
"Z24xEzARBgNVBAMTCkdsb2JhbFNpZ24wHhcNMDkwMzE4MTAwMDAwWhcNMjkwMzE4\r\n"
|
|
"MTAwMDAwWjBMMSAwHgYDVQQLExdHbG9iYWxTaWduIFJvb3QgQ0EgLSBSMzETMBEG\r\n"
|
|
"A1UEChMKR2xvYmFsU2lnbjETMBEGA1UEAxMKR2xvYmFsU2lnbjCCASIwDQYJKoZI\r\n"
|
|
"hvcNAQEBBQADggEPADCCAQoCggEBAMwldpB5BngiFvXAg7aEyiie/QV2EcWtiHL8\r\n"
|
|
"RgJDx7KKnQRfJMsuS+FggkbhUqsMgUdwbN1k0ev1LKMPgj0MK66X17YUhhB5uzsT\r\n"
|
|
"gHeMCOFJ0mpiLx9e+pZo34knlTifBtc+ycsmWQ1z3rDI6SYOgxXG71uL0gRgykmm\r\n"
|
|
"KPZpO/bLyCiR5Z2KYVc3rHQU3HTgOu5yLy6c+9C7v/U9AOEGM+iCK65TpjoWc4zd\r\n"
|
|
"QQ4gOsC0p6Hpsk+QLjJg6VfLuQSSaGjlOCZgdbKfd/+RFO+uIEn8rUAVSNECMWEZ\r\n"
|
|
"XriX7613t2Saer9fwRPvm2L7DWzgVGkWqQPabumDk3F2xmmFghcCAwEAAaNCMEAw\r\n"
|
|
"DgYDVR0PAQH/BAQDAgEGMA8GA1UdEwEB/wQFMAMBAf8wHQYDVR0OBBYEFI/wS3+o\r\n"
|
|
"LkUkrk1Q+mOai97i3Ru8MA0GCSqGSIb3DQEBCwUAA4IBAQBLQNvAUKr+yAzv95ZU\r\n"
|
|
"RUm7lgAJQayzE4aGKAczymvmdLm6AC2upArT9fHxD4q/c2dKg8dEe3jgr25sbwMp\r\n"
|
|
"jjM5RcOO5LlXbKr8EpbsU8Yt5CRsuZRj+9xTaGdWPoO4zzUhw8lo/s7awlOqzJCK\r\n"
|
|
"6fBdRoyV3XpYKBovHd7NADdBj+1EbddTKJd+82cEHhXXipa0095MJ6RMG3NzdvQX\r\n"
|
|
"mcIfeg7jLQitChws/zyrVQ4PkX4268NXSb7hLi18YIvDQVETI53O9zJrlAGomecs\r\n"
|
|
"Mx86OyXShkDOOyyGeMlhLxS67ttVb9+E7gUJTb0o2HLO02JQZR7rkpeDMdmztcpH\r\n"
|
|
"WD9f\r\n"
|
|
"-----END CERTIFICATE-----"
|
|
};
|
|
|
|
static void topic1_handler(void* client, message_data_t* msg)
|
|
{
|
|
(void) client;
|
|
MQTT_LOG_I("-----------------------------------------------------------------------------------");
|
|
MQTT_LOG_I("%s:%d %s()...\ntopic: %s\nmessage:%s", __FILE__, __LINE__, __FUNCTION__, msg->topic_name, (char*)msg->message->payload);
|
|
MQTT_LOG_I("-----------------------------------------------------------------------------------");
|
|
}
|
|
|
|
void *mqtt_publish_thread(void *arg)
|
|
{
|
|
mqtt_client_t *client = (mqtt_client_t *)arg;
|
|
|
|
char buf[100] = { 0 };
|
|
mqtt_message_t msg;
|
|
memset(&msg, 0, sizeof(msg));
|
|
sprintf(buf, "welcome to mqttclient, this is a publish test...");
|
|
|
|
sleep(2);
|
|
|
|
mqtt_list_subscribe_topic(client);
|
|
|
|
msg.payload = (void *) buf;
|
|
msg.qos = 0;
|
|
while(1) {
|
|
sprintf(buf, "welcome to mqttclient, this is a publish test, a rand number: %d ...", random_number());
|
|
mqtt_publish(client, "topic1", &msg);
|
|
sleep(4);
|
|
}
|
|
}
|
|
|
|
int main(void)
|
|
{
|
|
int res;
|
|
pthread_t thread1;
|
|
mqtt_client_t *client = NULL;
|
|
|
|
printf("\nwelcome to mqttclient test...\n");
|
|
|
|
mqtt_log_init();
|
|
|
|
client = mqtt_lease();
|
|
|
|
#ifdef TEST_USEING_TLS
|
|
mqtt_set_port(client, "1884");
|
|
mqtt_set_ca(client, (char*)test_baidu_ca_crt);
|
|
#else
|
|
mqtt_set_port(client, "1883");
|
|
#endif
|
|
|
|
mqtt_set_host(client, "j6npr4w.mqtt.iot.gz.baidubce.com");
|
|
mqtt_set_client_id(client, random_string(10));
|
|
mqtt_set_user_name(client, "j6npr4w/mqtt-client-dev");
|
|
mqtt_set_password(client, "lcUhUs5VYLMSbrnB");
|
|
mqtt_set_clean_session(client, 1);
|
|
|
|
mqtt_connect(client);
|
|
|
|
mqtt_subscribe(client, "topic1", QOS0, topic1_handler);
|
|
|
|
res = pthread_create(&thread1, NULL, mqtt_publish_thread, client);
|
|
if(res != 0) {
|
|
MQTT_LOG_E("create mqtt publish thread fail");
|
|
exit(res);
|
|
}
|
|
|
|
while (1) {
|
|
sleep(100);
|
|
}
|
|
}
|