前言：
MQTT
是一種基于客戶端服務(wù)端架構(gòu)的發(fā)布
/
訂閱模式的消息傳輸協(xié)議。它的設(shè)計(jì)思想是輕巧、開(kāi)放、
簡(jiǎn)單、規(guī)范，易于實(shí)現(xiàn)。這些特點(diǎn)使得它對(duì)很多場(chǎng)景來(lái)說(shuō)都是很好的選擇，特別是對(duì)于受限的環(huán)境如機(jī)器與
機(jī)器的通信（
M2M
）以及物聯(lián)網(wǎng)環(huán)境（
IoT
）。? ? ? ?
----MQTT
協(xié)議中文版
一.linux下EMQX服務(wù)器搭建
下載安裝包
免費(fèi)下載、試用 EMQ 產(chǎn)品
找對(duì)自己開(kāi)發(fā)環(huán)境版本
1.下載deb包
wget https://www.emqx.com/zh/downloads/broker/4.4.19/emqx-4.4.19-otp24.3.4.2-1-ubuntu16.04-amd64.deb
2.安裝
sudo apt install ./emqx-4.4.19-otp24.3.4.2-1-ubuntu16.04-amd64.deb
3.運(yùn)行
sudo systemctl start emqx
此時(shí)在瀏覽器登錄服務(wù)器IP??
http://（server_ip）:18083/#/
即可驗(yàn)證自己服務(wù)器安裝的是否成功，用戶名是 admin,初始密碼 public
二.客戶端工具M(jìn)QTTX的安裝
下載地址
免費(fèi)下載、試用 EMQ 產(chǎn)品
?我用的是windows下的，接著安裝運(yùn)行直接下一步走下去就行了。
name：客戶端的名字
client ID:客戶端ID
host:第一步里面服務(wù)器的IP地址
創(chuàng)建好了之后連接服務(wù)器，然后再創(chuàng)建一個(gè)客戶端，相互收發(fā)驗(yàn)證。
三.linux下paho.mqtt.c的開(kāi)發(fā)
1. paho.mqtt.c下載
git clone https://github.com/eclipse/paho.mqtt.c.git
cd?paho.mqtt.c
mkdir build
cd build
cmake ..
make
make install
安裝完成會(huì)在/usr/local/include和/usr/local/lib下看見(jiàn)mqtt的頭文件和動(dòng)態(tài)庫(kù)。
?2.mqtt代碼開(kāi)發(fā)
#include <MQTTAsync.h> //換成你自己的安裝路徑，不然回報(bào)錯(cuò)
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#define SERVERIP "xxx" //換成你自己的服務(wù)器
#define Clientid "sza123" //這個(gè)隨便寫(xiě)
int isConnected=0;
//消息回調(diào)函數(shù)
int onMessrecv(void* context,char*topicName,int topicLen,MQTTAsync_message*message){
printf("recv name:\ntopic:%s,payload:%s\n",topicName,(char*)message->payload);
MQTTAsync_free(topicName);
MQTTAsync_free(message);
return 1;
}
void onSubscribe(void* context,MQTTAsync_successData* response){
printf("sub success!");
}
//連接mqtt服務(wù)器
void onConnect(void *context,MQTTAsync_successData* response)
{
MQTTAsync client =(MQTTAsync)context;
int ret;
MQTTAsync_responseOptions response_opt=MQTTAsync_responseOptions_initializer;
printf("Succeed in connecting to mqtt-server!\n");
response_opt.onSuccess=onSubscribe;
ret=MQTTAsync_subscribe(client,"/pub",1,&response_opt);//訂閱/pub主題消息
if(ret!=MQTTASYNC_SUCCESS){
printf("fail to sub!\n");
}
isConnected=1;
}
void disConnect(void *context,MQTTAsync_failureData* response)
{
printf("Failed to connect mqtt-server!\n");
}
void onSend(void* context,MQTTAsync_successData* response){
printf("send message to mqtt server success!\n");
}
int main()
{
MQTTAsync client;
int ret;
MQTTAsync_connectOptions conn_opt = MQTTAsync_connectOptions_initializer;//初始化連接選項(xiàng)
ret=MQTTAsync_create(&client,SERVERIP,Clientid,MQTTCLIENT_PERSISTENCE_NONE,NULL);
if(ret!=MQTTASYNC_SUCCESS)
{
printf("Cannot create mqtt client!\n");
return -1;
}
//初始化接收消息回調(diào)
ret=MQTTAsync_setCallbacks(client,NULL,NULL,onMessrecv,NULL);
if(ret!=MQTTASYNC_SUCCESS){
printf("cannnot set call back function!\n");
return -1;
}
conn_opt.onSuccess=onConnect;
conn_opt.onFailure=disConnect;
conn_opt.automaticReconnect=1;
conn_opt.context=client;
conn_opt.cleansession=0;
//conn_opt.username="xxx";//設(shè)置用戶名密碼換成自己的
//conn_opt.password="xxx";
ret=MQTTAsync_connect(client,&conn_opt);
//因?yàn)槭钱惒降?，?dāng)MQTTAsync_connect返回的時(shí)候只是代表底層代碼對(duì)參數(shù)進(jìn)行了檢查
//當(dāng)正確返回時(shí)，表示底層代碼接收了該connect連接命令
if(ret!=MQTTASYNC_SUCCESS)
{
printf("Cannot start a mqttt server connect!\n");
return -1;
}
while (1){
//1表示成功連接到我們的服務(wù)器
if(isConnected==1){
MQTTAsync_message message=MQTTAsync_message_initializer;
MQTTAsync_responseOptions res_option=MQTTAsync_responseOptions_initializer;
char buffer[200];
static int temp=16;
static int humid=58;
sprintf(buffer," temp:%d,humid：%d ",temp++,humid++);
message.payload=buffer;
message.payloadlen=strlen(buffer);
message.qos=1;
res_option.onSuccess=onSend;
printf("read the message is :");
//發(fā)布消息
ret=MQTTAsync_sendMessage(client,"/sensor/dht11/0",&message,&res_option);//發(fā)送消息
if(ret!=MQTTASYNC_SUCCESS){
printf("參數(shù)錯(cuò)誤！");
}
sleep(10);
if(temp>30|humid>90){
temp=16;
humid=58;
}
}
}
return 0;
}
?然后編譯
gcc mqtt.c -o mqtt -I /usr/local/include/ -lpaho-mqtt3a運(yùn)行mqtt
?
文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-740074.html
?此時(shí)windows上的客戶端工具就會(huì)接收相應(yīng)的內(nèi)容，也可以向linux客戶端發(fā)送消息。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-740074.html
到了這里，關(guān)于linux下MQTT服務(wù)器(EMQX)搭建及paho.mqtt.c客戶端開(kāi)發(fā)的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
