0 前言

    2014年8月yeelink推出基於MQTT協議的開關型別裝置控制API，相比於基於HTTP RESTful的輪訓方式，通過訂閱相關主題訊息，可以遠端控制類應用實時性更好。本文使用兩種方式實現開關型別裝置的遠端控制，一種是基於nodeJS的MQTT.js擴充套件庫，另一種是基於python的paho-mqtt擴充套件庫。    【相關博文——MQTT】    【相關博文——HTTP RESTful】1 安裝和使用mqtt.js    由於沒有在樹莓派上安裝nodeJS，也沒有安裝GPIO擴充套件庫，所以本例並沒有演示如何通過yeelink推送的訊息控制GPIO。所以本例暫時只能在PC機上執行，但是通過該例子可以熟悉yeelink MQTT的基本使用方法。1.1 安裝mqtt.js

npm install mqtt 或 cnpm install mqtt1.2 實現程式碼——yeelink_mqtt.js

var mqtt = require('mqtt'); 

var username = 'U-ApiKey'; 
var password = 'ffa3826972d6cc7ba5b17e104ec5xxxx'; 
var hostname = 'mqtt.yeelink.net'; 
var topic = '/v1.1/device/1949/sensor/2511/datapoints'; 

var url = 'mqtt://' + username + ':' + password + '@' + hostname; 

console.log(url);

var client = mqtt.connect(url); 
// 訂閱主題 
client.subscribe(topic); 

client.on('message', function(topic, message) { 
    console.log(topic); 
    console.log(message); 
});
 

1.3 執行    【執行程式碼】    node yeelink_mqtt.js    【修改狀態】    登入yeelink平臺通過網頁修改開關裝置狀態，也可通過其他方法修改裝置狀態。一旦裝置狀態發生修改，那麼控制檯便會輸出被推送的訊息，整個過程幾乎沒有延時。    【控制檯輸出】mqtt://U-ApiKey:[email protected]
/v1.1/device/1949/sensor/2511/datapoints
{"sensor_id":2511,"timestamp":1410835745,"value":1}
/v1.1/device/1949/sensor/2511/datapoints
{"sensor_id":2511,"timestamp":1410835754,"value":0}

1.4 簡單說明    【1】MQTT協議中可指定使用者名稱和密碼，在yeelink協議中，使用者名稱變為U-ApiKey，密碼為U-ApiKey的具體值。    【2】訂閱主題為裝置URI，需要把API版本號修改為v1.1    【3】主機名稱為mqtt.yeelink.net，而不是api.yeelink.net    在mqtt.js的示例程式碼中：client = mqtt.connect('mqtt://user:[email protected]');    在yeelink的示例程式碼中：client = mqtt.connect("mqtt://U-ApiKey:<your_key>@mqtt.yeelink.net");    以上的兩個示例程式碼更可以說明各引數的對應關係。2 安裝和使用paho-mqtt    本例演示在樹莓派上安裝paho-mqtt，通過推送訊息的內容控制GPIO2.1 安裝paho-mqtt    pip install paho-mqtt2.2 實現程式碼

# -*- coding: utf-8 -*-  
import paho.mqtt.client as mqtt
import RPi.GPIO as GPIO
import json

hostname = 'mqtt.yeelink.net'
username = 'U-ApiKey'
password = 'ffa3826972d6cc7ba5b17e104ec5xxxx'
topic = '/v1.1/device/1949/sensor/2511/datapoints'
# BCM GPIO編號
pins = [17,18,27,22,23,24,25,4]
pin = 18

def gpio_setup():
    # 採用BCM編號
    GPIO.setmode(GPIO.BCM)
    # 設定所有GPIO為輸出狀態，且輸出低電平
    for pin in pins:
        GPIO.setup(pin, GPIO.OUT)
        GPIO.output(pin, GPIO.LOW)
        
def gpio_destroy():
    for pin in pins:
        GPIO.output(pin, GPIO.LOW)
        GPIO.setup(pin, GPIO.IN)
        
# 連線成功回撥函式
def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    # 連線完成之後訂閱主題
    client.subscribe(topic)

# 訊息推送回調函式
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))
    # 獲得負載中的pin 和 value
    gpio = json.loads(str(msg.payload))

    if gpio['value'] == 0:
        GPIO.output(pin, GPIO.LOW)
    else:
        GPIO.output(pin, GPIO.HIGH)    

if __name__ == '__main__':
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    gpio_setup()
    
    try:
        # 配置使用者名稱和密碼
        client.username_pw_set(username, password)
        client.connect(hostname, 1883, 60)
        client.loop_forever()
    except KeyboardInterrupt:
        client.disconnect()
        gpio_destroy()

2.3 執行    【執行程式碼】    python yeelink_mqtt.js    【修改狀態】    登入yeelink平臺通過網頁修改開關裝置狀態，也可通過其他方法修改裝置狀態。一旦裝置狀態發生修改，那麼控制檯便會輸出被推送的訊息，整個過程幾乎沒有延時。    【控制檯輸出】Connected with result code 0/v1.1/device/1949/sensor/2511/datapoints {"sensor_id":2511,"timestamp":141083559 8,"value":1} /v1.1/device/1949/sensor/2511/datapoints {"sensor_id":2511,"timestamp":141083560 2,"value":0}2.4 簡單說明    【1】請注意程式碼中的使用者名稱，密碼設定，通過client.username_pw_set(username, password)設定使用者名稱和密碼，但是使用者名稱和密碼此時變為了U-ApiKey和U-ApiKey的具體值。    【2】on_connect為連線成功回撥函式，on_message為收到推送訊息回撥函式。    【3】連線成功之後訂閱主題，若接收到伺服器推送的訊息，通過訊息中value控制GPIO。3 總結    【1】在yeelink應用中U-ApiKey變為了使用者名稱和密碼    【2】裝置URI變為了主題    【3】訂閱了相關主題的訊息之後，若通過其他方法（HTTP RESTful）改變開關裝置狀態，那麼裝置便會接收到來自yeelink平臺的推送訊息，我們可以認為訊息推送是實時的。    【4】相對於裝置控制，MQTT協議比HTTP協議要簡潔些，實時性更好。4 參考資料