MQTT 生产者（同步）代码解读

一、问题引入

官方给出了MQTT Client的同步和异步发布的例子，本随笔就是同步发布的example。同步和异步都有一套API函数和结构体。

同步发布消息算是最简单的案例了，这里总结一下代码。

二、解决过程

简要介绍编写 MQTT Producer的消息发布（同步）过程：

• 第1步：创建客户端

LIBMQTT_API int MQTTClient_create(MQTTClient* handle, const char* serverURI, const char* clientId,
		int persistence_type, void* persistence_context);

• 第2步：设置客户端与服务器的连接选项属性

MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;

conn_opts.keepAliveInterval = 30;
//conn_opts的其它选项

• 第3步：连接服务器

LIBMQTT_API int MQTTClient_connect(MQTTClient handle, MQTTClient_connectOptions* options);

• 第4步：设置消息发布选项属性

MQTTClient_message pubmsg = MQTTClient_message_initializer;

pubmsg.qos = 1;
//pubmsg的其他选项

• 第5步：发布消息

LIBMQTT_API int MQTTClient_publishMessage(MQTTClient handle, const char* topicName, 
        MQTTClient_message* msg, MQTTClient_deliveryToken* dt);

• 第6步：等待消息发布完成（同步消息发布模式才有这一步）

LIBMQTT_API int MQTTClient_waitForCompletion(MQTTClient handle, MQTTClient_deliveryToken dt, unsigned long timeout);

• 第7步：断开与服务器的连接

LIBMQTT_API int MQTTClient_disconnect(MQTTClient handle, int timeout);

• 第8步：释放内存

LIBMQTT_API void MQTTClient_destroy(MQTTClient* handle);

2-1 数据类型的声明

创建客户端需要定义一个客户端指针(其实是一个无类指针)，客户端成功创建会申请一段内存，该指针指向这段内存，且程序结束后要进行释放

/**
 * A handle representing an MQTT client. A valid client handle is available
 * following a successful call to MQTTClient_create().
 */
typedef void* MQTTClient;

MQTTClient client;

连接客户端，需要通过一个结构体传送设置选项信息

// MQTTClient_connectOptions 类型的变量通过指定宏进行初始化
#define MQTTClient_connectOptions_initializer { {'M', 'Q', 'T', 'C'}, 8, 60, 1, 1, NULL, NULL, NULL, 30, 0, NULL,\
0, NULL, MQTTVERSION_DEFAULT, {NULL, 0, 0}, {0, NULL}, -1, 0, NULL, NULL, NULL}

MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;

MQTTClient_connectOptions结构体的成员：

MQTTClient_willOptions结构体的成员

消息发布中的属性通过一个结构体传送

// MQTTClient_message 类型的变量通过指定宏进行初始化
#define MQTTClient_message_initializer { {'M', 'Q', 'T', 'M'}, 1, 0, NULL, 0, 0, 0, 0, MQTTProperties_initializer }

MQTTClient_message pubmsg = MQTTClient_message_initializer;

MQTTClient_message结构体的成员

消息发布后，会产生一个token令牌，该令牌被用作检查消息是否被分发到目的地。

typedef int MQTTClient_deliveryToken;
typedef int MQTTClient_token;

三、反思总结

验证同步发布消息是否成功，通过函数：MQTTClient_waitForCompletion() 进行阻塞判断，返回值为：MQTTCLIENT_SUCCESS 表示消息成功发布到Broker。

同步发布消息的效率很低，但可靠性很强，不会造成消息未发送完成，但消息丢失的情况。

四、参考引用

无