1 前言

MQTT(消息队列遥测传输)是ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议。它工作在 TCP/IP协议族上，是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议，为此，它需要一个消息中间件。MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。在很多情况下，包括受限的环境中，如：机器与机器（M2M）通信和物联网（IoT）。其在，通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。

2 驱动目的

在中台控制智能空开的开启和关闭，其他MQTT协议的设备可以根据此驱动进行二次开发。

3 驱动代码

#!coding:utf8
import sys

sys.path.append("..")
from driver import *
import json
import time
import paho.mqtt.client as mqtt

reload(sys)
sys.setdefaultencoding('utf8')


def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    client.subscribe("/wf/wifiswitch/server")  # 订阅消息


def on_subscribe(client, userdata, mid, granted_qos):
    print("On Subscribed: qos = %d" % granted_qos)


def on_disconnect(client, userdata, rc):
    if rc != 0:
        print("Unexpected disconnection %s" % rc)


class TemplateDriver(IOTOSDriverI):
    def on_message(self, client, userdata, msg):
        print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
        a = json.loads(msg.payload)
        if str(a[u'act']) == str('allmsg'):
            sn = a[u'sw'][u'sw']
            self.setValue(u'open',sn)
            sn1 = a[u'sw2'][u'sw']
            self.setValue(u'open2', sn1)

    def InitComm(self, attrs):
        self.online(True)
        self.setPauseCollect(False)
        self.setCollectingOneCircle(False)
        self.client = mqtt.Client()
        self.air_host = self.sysAttrs['config']['param']['host']
        self.air_port = self.sysAttrs['config']['param']['port']
        self.air_username = self.sysAttrs['config']['param']['username']
        self.air_password = self.sysAttrs['config']['param']['password']
        self.air_id = self.sysAttrs['config']['param']['id']
        self.air_value = self.sysAttrs['config']['param']['value']
        # 注册事件
        self.client.on_connect = on_connect
        self.client.on_message = self.on_message
        self.client.on_subscribe = on_subscribe
        self.client.on_disconnect = on_disconnect
        self.client.username_pw_set(username=self.air_username, password=self.air_password)
        # 连接到服务器
        self.client.connect(host=self.air_host, port=self.air_port, keepalive=60)
        self.client.loop_start()

    def Collecting(self, dataId):
        sn = ''
        sn1 = ''
        self.client.publish(self.air_id, payload="act=getallmsg&mode=0", qos=0)  # 发送消息
        # self.setValue(u'open', 0)
        for key, value in self.data2attrs.items():  # 拿出数据点的键和值
            if "private" in value['config']['param']:
                # 在private中识别开关控制的反控标签
                if value['config']['param']['private'] == "open":
                    self.key_s = key  # 将下发数据点的dataid保存到self中，后续Event_setData中判断下发数据点时需要用到
                    self.debug(self.key_s)
                    if "memoryvalue" not in self.data2attrs[key]:
                        self.setValue(u'open', sn)
                    else:
                        self.setValue(u'open', self.data2attrs[key]["memoryvalue"])
                if value['config']['param']['private'] == "open2":
                    self.key_s1 = key  # 将下发数据点的dataid保存到self中，后续Event_setData中判断下发数据点时需要用到
                    self.debug(self.key_s1)
                    if "memoryvalue" not in self.data2attrs[key]:
                        self.setValue(u'open2', sn1)
                    else:
                        self.setValue(u'open2', self.data2attrs[key]["memoryvalue"])

        time.sleep(20)
        return ()

    def Event_setData(self, dataId, value):
        if dataId == self.key_s:
            self.setValue(u'open', value)
            data = "act=ctrlio&sw=" + str(value)
            self.client.publish(self.air_id+self.air_value, payload=data, qos=0)  # 发送消息
        if dataId == self.key_s1:
            self.setValue(u'open2', value)
            data = "act=ctrlio2&sw=" + str(value)
            self.client.publish(self.air_id+self.air_value, payload=data, qos=0)  # 发送消息
        # if dataId=="a8c3" and value==True:
        #     # self.setValue(u'data', '333333333')
        #     self.info(u"Data delivery succeeded>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>switch=1")
        # if dataId=="e8e4" and value==False:
        #     return json.dumps({'code': 10010, 'msg': '下发失败', 'data': ''})
        return json.dumps({'code': 0, 'msg': '', 'data': ''})

4 驱动解析

4.1 从设备实例上获取配置的参数

• 配置参数如下：

• sdk中获取参数配置如下：

4.2 配置mqtt连接参数：

4.3 获取空开当前状态

• 给mqtt服务器发送请求

  

• 将请求的值发送给中台

  

4.4 下发按钮控制空开状况

• 先获取到当前数据点的值，存储到value中
  根据获取到的值向mqtt发送指定消息

• 运行.bat文件后结果如下
  

• 可以看到mqtt每20s向中台传一次数据
  当进行数据下发时，开关状况也发生了改变

5 使用示例

  对于中台的具体操作流程可以参考开发时间 -> HelloWorld，这里只简述了大概的步骤

• 5.1 创建模板

  依次点击【系统设备】->【模板驱动】->【我的模板】,点击右上角创建模板。详见系统设备管理-模板驱动，空开的驱动模板示例如下，驱动名称最好与驱动根目录配置中的“driver”属性一致，驱动配置中的“driver”表示需要运行的驱动文件类，“param”表示驱动运行的所需参数，对于该智能空调设备，需要配置的参数有“host”“port” “username”“password”“topic”“id” “value”,前面四个参数是连接MQTT服务器的必要参数，“host”“port”表示需要连接的MQTT服务器的地址和端口，“username”“password”为连接MQTT服务器需要的鉴权，“topic”为需要订阅的topic，“id”和“value”为该设备的关于发布和订阅所需要的参数信息，其他设备同理可以自行定义，配置完这些的参数，点击确定即可：

  

• 5.2 创建网关

  依次点击【系统设备】->【通信网关】,点击右上角创建网关。详见系统设备管理-通信网关。填写网关名称即可，这里我创建了我自己中台的网关实例，方便大家理解

  

• 5.3 创建设备

  依次点击【系统设备】 -> 【通信网关】 -> 【设备实例】，点击右上角创建设备实例。详见系统设备管理-设备实例。填写设备名称，选择刚才创建的网关和模板即可（检查一下驱动根配置的“driver”参数，若在创建模板时已按要求配置，则现在无需修改，否则则需要在此进行配置，配置标准见创建模板），这里我创建了我自己中台的设备实例，方便大家理解

  

• 5.4 创建数据点

• 创建数据点，点击【我的设备】 -> 【通信网关】 -> 【设备实例】 -> 【数据点】，并在【设备实例】下拉列表选择刚刚创建的设备实例，然后进行数据点的创建。需要创建的数据如下详见系统设备管理-数据点。注：运行驱动时先删除系统自带的那四个数据点（设备持续在线时长、网关持续运行时长、设备网络状态、网关网络状态）
  

  需要在在数据点的高级配置中配置“private”，值为“switch”，如下：
  

• 5.5 运行驱动

  方式一：在SDK目录下的_example文件夹下建立一个.bat文件，建立完成后双击进行运行
  
  

  方式二：点击中台【系统设备】->【通信网关】，选择刚刚创建好的网关，点击高级，开启云网关，密码为账户密码。
  

• 5.6 查看数据

  

• 5.7 下发

  点击数据点open的下发按钮，将开关设置为开启，即可打开空气开关。
  
  后台情况