MQTT客户端代码示例

MQTT-c
    ├── include
    ├── lib
    ├── src
        ├── ConnectorSync.c
        ├── PublisherSync.c
        ├── SubscriberSync.c
    ├── Makefile
    ├── root_cert.pem

LIB_PATH = /home/iot/MQTT-c/
INCLUDE_PATH = /home/iot/MQTT-c/incl

using uPLibrary.Networking.M2Mqtt;

using uPLibrary.Networking.M2Mqtt.Messages;

string enpoint = "yourendpointname.mqtt.iot.gz.baidubce.com"; 
int port = 1884;  // 端口默认1884
string user = "username";  //创建thing，返回username
string pwd = "password";   //创建principal，返回password
string clientid = Guid.NewGuid().ToString();  // 获取一个独一无二的id
string[] topic = new string[] { "yourtopic" };  //输出订阅发布的主题

mqtt-py
    ├── sub_py2.py                                  //sub订阅代码示例
    ├── pub_py2.py                                  //pub发布代码示例
    ├── paho-mqtt-1.1.tar.gz                        //mqtt client端

git clone https://github.com/eclipse/paho.mqtt.python.git
cd org.eclipse.paho.mqtt.python.git
python setup.py install

import paho.mqtt.client as mqtt

trust = "C:\Users\username\Desktop\iot\mqtt-py/root_cert.pem" #开启TLS时的认证文件目录
user = "01endpoint/01thing"                			#成功创建thing后返回的username
pwd = "O7hrHKUYJLqxwajP/5/2fqdZ8KIDZ/aR4/CWrmRt6Gg="   #成功创建principal后返回的password
endpoint = "01endpoint.mqtt.iot.gz.baidubce.com"       #实例(endpoint)地址
port = 1884                                            #endpoint端口
topic = "test iot service"                             #订阅的主题内容

def on_connect(client, userdata, flags, rc):  #连接后返回0为成功
    print("Connected with result code "+str(rc))
    client.subscribe(topic, qos=1) #qos

def on_message(client, userdata, msg):
    print("topic:"+msg.topic+" Message:"+str(msg.payload))

client = mqtt.Client(
    client_id="test_mqtt_receiver_1", #用来标识设备的ID，用户可自己定义，在同一个实例下，每个实体设备需要有一个唯一的ID
    clean_session=True,
    userdata=None,
    protocol=mqtt.MQTTv3
)

client.tls_insecure_set(True) #检查hostname的cert认证
client.tls_set(trust) #设置认证文件
client.username_pw_set(user, pwd) #设置用户名，密码
client.on_connect = on_connect #连接后的操作
client.on_message = on_message #接受消息的操作
client.connect(endpoint, port, 60) #连接服务 keepalive=60
client.loop_forever()

import time
import paho.mqtt.client as mqtt
import datetime
  
def on_publish(msg, rc):   #成功发布消息的操作
    if rc == 0:
        print("publish success, msg = " + msg)

def on_connect(client, userdata, flags, rc):  #连接后的操作 0为成功
    print("Connection returned " + str(rc))

client = mqtt.Client(
    client_id="test_mqtt_sender_1", #用来标识设备的ID，用户可自己定义，在同一个实例下，每个实体设备需要有一个唯一的ID
    clean_session=True,
    userdata=None,
    protocol='MQTTv311'
)

trust = "C:\Users\username\Desktop\iot\mqtt-py/root_cert.pem" #开启TLS时的认证文件目录
user = "01endpoint/01thing"
pwd = "O7hrHKUYJLqxwajP/5/2fqdZ8KIDZ/aR4/CWrmRt6Gg="
endpoint = "01endpoint.mqtt.iot.gz.baidubce.com"
port = 1884
topic = "test iot service"

client.tls_insecure_set(True) #检查hostname的cert认证
client.tls_set(trust) #设置认证文件
client.username_pw_set(user, pwd) #设置用户名，密码
client.connect(endpoint, port, 60) #连接服务 keepalive=60
client.on_connect = on_connect #连接后的操作
client.loop_start()
time.sleep(2)
count = 0
while count < 5: #发布五条消息
    count = count + 1
    msg = str(datetime.datetime.now())
    rc , mid = client.publish(topic, payload=msg, qos=1) #qos
    on_publish(msg, rc)
    time.sleep(2)