Paho C を使用して MQTT クライアントを接続する

MQTTAsync_disconnect(クライアント、NULL);
MQTTAsync_destroy(&client) ディレクティブ

MQTT 3.1.1の特長

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include "MQTTAsync.h" を使う

#define ADDRESS "tcp://localhost:1883"
#define TOPIC "センサー/温度"
#define PAYLOAD "180"
#QOSの定義 1
#define タイムアウト 10000L

終了 = 0;

void create_clientid(char *str, int str_length) を生成します。
お問い合わせ
srand (時間(NULL));
コント文字 *英数字 = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz", *PREFIX = "crystalmq_";
strncpy(str, PREFIX, strlen(PREFIX));
用 (int i = 0; i < (str_length-strlen(PREFIX))); . . .
str[10 + i] = alphanum[rand() % 62]; // 62 は alphanum の長さ キーワード
お問い合わせ
str[str_length] = '\0';
お問い合わせ

onDisconnect(void*文脈) を無効化します。 MQTTAsync_successData* 応答
お問い合わせ
printf("Successful disconnection\n"); ;
終了 = 1;
お問い合わせ

onSubscribe(void*文脈) を省略します。 MQTTAsync_successData* 応答
お問い合わせ
printf("Subscribe は成功しました\n");
お問い合わせ

onConnectFailure(void* コンテキスト) を無効にします。 MQTTAsync_failureData* 応答
お問い合わせ
printf("Connect が失敗しました, rc %d\n", response ? 応答->code : 0);
終了 = 1;
お問い合わせ

void onConnect(void* コンテキスト) MQTTAsync_successData* 応答
お問い合わせ
printf("成功関係\n");
お問い合わせ

int msgarrvd(void *context、char *topicName、int トピックレン、MQTTAsync_message *メッセージ
お問い合わせ
サインイン
char*のペイロードプター;
printf("メッセージは到着しました\n");
printf(" トピック: %s\n", トピック名);
printf(") メッセージ: ");
payloadptr = メッセージ->ペイロード;
(i=0 の場合)ペイロードレン; i++)
お問い合わせ
putchar(*ペイロードプラー++);
お問い合わせ
パチャー('\n');
MQTTAsync_freeMessage(&メッセージ)。
MQTTAsync_free(トピック名);
リターン1;
お問い合わせ

int main(int argc, char* argv[)]) の
お問い合わせ
// クライアントを作成する
char clientid[21];
生成_clientid(clientid、20);
MQTTAsyncクライアント;
MQTTAsync_create(&client, ADDRESS, Clientid, MQTTCLIENT_PERSISTENCE_NONE, MQTTAsync_create(&client, ADDRESS, Clientid, MQTTCLIENT_PERSISTENCE_NONE, MQTTAsync_create(&client, ADDRESS, Clientid), MQTTAsync_create(&client), MQTTAsync_create(&client, ADDRESS, Clientid), MQTTCLIENT_PERSISTENCE_NONE, NULL;
MQTTAsync_setCallbacks(クライアント、NULL、NULL、msgarrvd、NULL);

MQTTAsync_connectOptions conn_opts = MQTTAsync_connectOptions_initializer;
conn_opts.keepAliveインターバル = 60;
conn_opts.cleansession = 1 ;
conn_opts.on成功 = onConnect;
サインイン 失敗 = onConnectFailure;
conn_opts.context = クライアント;
int の rc;
if ((rc = MQTTAsync_connect(client, &conn_opts))) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf("Connect, return code %d\n", rc" を起動できません)
出口(EXIT_FAILURE);
お問い合わせ
睡眠(1);

// 購読する
MQTTAsync_responseOptions サブ_opts = MQTTAsync_responseOptions_initializer;
sub_opts.on成功 = onSubscribe;
sub_opts.context = クライアント;
if ((rc = MQTTAsync_subscribe(client, TOPIC, QOS, ◀_opts))) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf("サブスクリプションに失敗し、コードを%d\n、rcを返す);
出口(EXIT_FAILURE);
お問い合わせ

// 公開
MQTTAsync_message pubmsg = MQTTAsync_message_initializer;
pubmsg.ペイロード = PAYLOAD;
pubmsg.payloadlen = strlen(PAYLOAD);
pubmsg.qos = QOS;
pubmsg.retained = 0;
if ((rc = MQTTAsync_sendMessage(client, TOPIC, &pubmsg, NULL))) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf(" sendMessage を開始できなかった, 戻りコード %d\n", rc);
出口(EXIT_FAILURE);
お問い合わせ

しばらく(!終了)
#if 定義(WIN32) | 定義(WIN64)
睡眠(100);
ログイン
usleep(10000L);
パスワード
MQTTAsync_destroy(&client) ディレクティブ
リターン rc;
お問い合わせ

MQTT 5の特長

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include "MQTTAsync.h" を使う

#define ADDRESS "tcp://localhost:1883"
#define TOPIC "センサー/湿気"
#define PAYLOAD "20.3"
#QOSの定義 1
#define タイムアウト 10000L

終了 = 0;

void create_clientid(char *str, int str_length) を生成します。
お問い合わせ
srand (時間(NULL));
コント文字 *英数字 = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz", *PREFIX = "crystalmq_";
strncpy(str, PREFIX, strlen(PREFIX));
用 (int i = 0; i < (str_length-strlen(PREFIX))); . . .
str[10 + i] = alphanum[rand() % 62]; // 62 は alphanum の長さ キーワード
お問い合わせ
str[str_length] = '\0';
お問い合わせ

onDisconnect(void*文脈) を無効化します。 MQTTAsync_successData* 応答
お問い合わせ
printf("Successful disconnection\n"); ;
終了 = 1;
お問い合わせ

onConnectFailure(void* コンテキスト) を無効にします。 MQTTAsync_failureData* 応答
お問い合わせ
printf("Connect が失敗しました, rc %d\n", response ? 応答->code : 0);
終了 = 1;
お問い合わせ

void onConnect(void* コンテキスト) MQTTAsync_successData* 応答
お問い合わせ
printf("成功関係\n");
お問い合わせ

int msgarrvd(void *context、char *topicName、int トピックレン、MQTTAsync_message *メッセージ
お問い合わせ
サインイン
char*のペイロードプター;
printf("メッセージは到着しました\n");
printf(" トピック: %s\n", トピック名);
printf(") メッセージ: ");
payloadptr = メッセージ->ペイロード;
(i=0 の場合)ペイロードレン; i++)
お問い合わせ
putchar(*ペイロードプラー++);
お問い合わせ
パチャー('\n');
MQTTAsync_freeMessage(&メッセージ)。
MQTTAsync_free(トピック名);
リターン1;
お問い合わせ

int main(int argc, char* argv[)]) の
お問い合わせ
// クライアントを作成する
char clientid[21];
生成_clientid(clientid、20);
MQTTAsyncクライアント;
MQTTAsync_createOptions create_opts = MQTTAsync_createOptions_initializer;
create_opts.MQTTVersion = MQTTVERSION_5;
int rc = MQTTAsync_createWithOptions(&client, ADDRESS, clientid, クライアント, MQTTCLIENT_PERSISTENCE_NONE, NULL, &create_opts; は、
MQTTAsync_setCallbacks(クライアント、NULL、NULL、msgarrvd、NULL);

// CONNECT の設定 プロパティ
MQTTAsync_connectOptions conn_opts = MQTTAsync_connectOptions_initializer5;
conn_opts.keepAliveInterval = 20;
conn_opts.cleanstart = 1 ;
conn_opts.on成功 = onConnect;
サインイン 失敗 = onConnectFailure;
conn_opts.context = クライアント;

MQTTProperties props = MQTTProperties_initializer;
// // セッションの有効期限インターバル
MQTTプロパティ1;
プロパティ1.identifier = MQTTPROPERTY_CODE_SESSION_EXPIRY_INTERVAL;
プロパティ1.value.integer2 = 90;
MQTTProperties_add(&props、&property1);

// // 最大パケットサイズ
MQTTPropertyプロパティ2;
プロパティ2.identifier = MQTTPROPERTY_CODE_MAXIMUM_PACKET_SIZE;
プロパティ2.value.integer4 = 4094;
MQTTProperties_add(&props、&property2);

conn_opts.connectプロパティ = &props
if ((rc = MQTTAsync_connect(client, &conn_opts))) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf("Connect, return code %d\n", rc" を起動できません)
出口(EXIT_FAILURE);
お問い合わせ
睡眠(1);

// 購読する
もし(rc = MQTTAsync_subscribe(client, TOPIC, QOS, NULL)) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf("サブスクリプションに失敗し、コードを%d\n、rcを返す);
出口(EXIT_FAILURE);
お問い合わせ
睡眠(1);

// 公開
MQTTAsync_message pubmsg = MQTTAsync_message_initializer;
pubmsg.ペイロード = PAYLOAD;
pubmsg.payloadlen = strlen(PAYLOAD);
pubmsg.qos = QOS;
pubmsg.retained = 0;
// 公開プロパティを設定する
MQTTAsync_responseOptions pub_opts = MQTTAsync_responseOptions_initializer;
pub_opts.context = クライアント;
MQTTProperties pub_props = MQTTProperties_initializer;
MQTTPropertyプロパティ3;
プロパティ3.identifier = MQTTPROPERTY_CODE_TOPIC_ALIAS;
プロパティ3.value.integer4 = 90;
MQTTProperties_add(&pub_props、&property3)。
pub_opts.properties = pub_props;

もし(rc = MQTTAsync_sendMessage(client, TOPIC, &pubmsg, &pub_opts)) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf(" sendMessage を開始できなかった, 戻りコード %d\n", rc);
出口(EXIT_FAILURE);
お問い合わせ

睡眠(1);

もし(rc = MQTTAsync_unsubscribe(client, TOPIC, NULL)) != MQTTASYNC_SUCCESS(マクタスイック)
お問い合わせ
printf("unsubscribe, 戻りコード%d\n", rc);
出口(EXIT_FAILURE);
お問い合わせ
しばらく(!終了)
#if 定義(WIN32) | 定義(WIN64)
睡眠(100);
ログイン
usleep(10000L);
パスワード
MQTTAsync_destroy(&client) ディレクティブ
リターン rc;
お問い合わせ

$ gcc -o mqttclient mqttclient.c -lpaho-mqtt3a -lpaho-mqtt3as
$ ./mqttclient