美文网首页
树莓派接入巴法云

树莓派接入巴法云

作者: 巴法云 | 来源:发表于2022-05-04 19:24 被阅读0次

    最近有小伙伴咨询树莓派接入的问题,其实简单,使用直接在树莓派中运行python程序就可以。

    示例说明:示例中使用的python3.x版本,如果是2.x版本的python,运行前把 print 指令的()括号去掉,应该就可以了。如果需要控制树莓派io引脚,推送使用 RPi.GPIO ,百度上面教程很多,这里就不细说了。

    第一,tcp协议连接

    说明:
    tcp服务器地址:bemfa.com 端口 8344
    tcp协议详细订阅、发布指令,见接入文档:点击跳转

    # -*- coding: utf-8
    import socket
    import threading
    import time
    
    def connTCP():
        global tcp_client_socket
        # 创建socket
        tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # IP 和端口
        server_ip = 'bemfa.com'
        server_port = 8344
        try:
            # 连接服务器
            tcp_client_socket.connect((server_ip, server_port))
            #发送订阅指令
            substr = 'cmd=1&uid=4d9ec352e0376f2110a0c601a2857225&topic=led002\r\n'
            tcp_client_socket.send(substr.encode("utf-8"))
        except:
            time.sleep(2)
            connTCP()
    
    #心跳
    def Ping():
        # 发送心跳
        try:
            keeplive = 'ping\r\n'
            tcp_client_socket.send(keeplive.encode("utf-8"))
        except:
            time.sleep(2)
            connTCP()
        #开启定时,30秒发送一次心跳
        t = threading.Timer(30,Ping)
        t.start()
    
        
    connTCP()
    Ping()
    
    while True:
        # 接收服务器发送过来的数据
        recvData = tcp_client_socket.recv(1024)
        if len(recvData) != 0:
            print('recv:', recvData.decode('utf-8'))
        else:
            print("conn err")
            connTCP()
    
    

    第二,MQTT 协议连接

    说明:
    mqtt服务器地址:bemfa.com 端口:9501
    连接服务器
    1.用户私钥作为连接MQTT服务器的客户端ID
    2.连接时用户名和密码为空,或随意填写,即设备连接时不需要账号和密码

    mqtt程序使用前需安装mqtt库文件,安装命令:

    pip3 install paho-mqtt
    
    # -*- coding: utf-8 -*-
    # 以下代码在2021年10月21日 python3.10环境下运行通过
    
    import paho.mqtt.client as mqtt
    
    HOST = "bemfa.com"
    PORT = 9501
    client_id = "4d9ec352e0376f2110a0c601a2857225"                       
    #连接并订阅
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code "+str(rc))
        client.subscribe("led00202")         # 订阅消息
    
    #消息接收
    def on_message(client, userdata, msg):
        print("主题:"+msg.topic+" 消息:"+str(msg.payload.decode('utf-8')))
    
    #订阅成功
    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)
    
    
    client = mqtt.Client(client_id)
    client.username_pw_set("userName", "passwd")
    client.on_connect = on_connect
    client.on_message = on_message
    client.on_subscribe = on_subscribe
    client.on_disconnect = on_disconnect
    client.connect(HOST, PORT, 60)
    client.loop_forever()
    
    
    

    相关文章

      网友评论

          本文标题:树莓派接入巴法云

          本文链接:https://www.haomeiwen.com/subject/nplgyrtx.html