pdf-icon

UIFlow Guide

UIFlow 1.0 Blockly

Event

Unit

UIFlow 1.0 Project

coming soon...

Atomic PoE

案例程序


功能说明

poe.tcp_udp_config('', 0, 1, 1)
  • 初始化局域网连接。配置远程IP地址、端口号和选择使用的通信协议类型(TCP/UDP),以及指定设备作为服务器或客户端。
poe.mqtt_config('mqtt.m5stack.com', 1883, '', '', '', 120)
  • 初始化MQTT服务器连接,包含服务器地址、端口号、客户端ID、用户名、密码及心跳间隔(keepalive)。
poe.is_available_packet(1)
  • 检查当前是否有可用的TCP数据包,并返回数据包的数量。
poe.get_ezdata(ezdata_get_KzSyFcb, 'GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')
  • 从指定的MQTT话题中获取数据,基于话题名和token进行操作。
poe.remove_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')
  • 从MQTT服务器中删除指定的话题,使用话题名和token进行删除操作。
poe.set_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '', '', 0)
  • 将指定的数据保存到某个话题中,并使用token进行身份验证。
poe.get_if_config()
  • 获取当前网络或设备的配置信息。
poe.http_get('', True)
  • 通过HTTP或HTTPS协议从指定的URL获取数据,可以选择获取完整内容或其他方式。
poe.http_post('', 'application/json', '')
  • 通过HTTP或HTTPS协议向指定的URL发送数据,数据可以是JSON、表单等多种格式。
poe.local_ip()
  • 获取设备在局域网中的本地IP地址。
poe.mqtt_is_connect()
  • 检查当前设备是否已成功连接到MQTT服务器。
poe.mqtt_connect()
  • 连接到指定的MQTT服务器。
poe.mqtt_disconnect()
  • 断开当前与MQTT服务器的连接。
poe.mqtt_poll_loop()
  • u轮询从MQTT服务器接收到的下行消息。
poe.mqtt_publish('', '', 0)
  • 发布一条消息到指定的MQTT主题(topic)。
poe.mqtt_subscribe('', atom_poe_mqtt_cb, 0)
  • 订阅指定的MQTT主题(topic),可以指定消息传递的服务质量(QoS)。
def atom_poe_mqtt_cb(poe_mq_topic, poe_mq_payload):
  global ezdata_value1, lan_topic, lan_msg
  lan_topic = poe_mq_topic
  lan_msg = poe_mq_payload
  pass
  • 设置一个回调函数,当指定的MQTT主题接收到消息时,调用该回调处理消息。
poe.remote_ip()
  • 获取远程设备的IP地址。
poe.socket_close()
  • 关闭当前的网络套接字连接。
poe.tcp_receive_packet(0)
  • 接收通过TCP协议传输的数据包,并根据指定的字节大小读取数据。
poe.tcp_send_packet('1234')
  • 通过TCP协议发送数据包,数据内容为指定的字符串或数字。
poe.udp_receive_packet(0)
  • 接收通过UDP协议传输的数据包,并根据指定的字节大小读取数据。
poe.udp_send_packet('', 0, '')
  • 通过UDP协议发送数据包,指定目标IP地址、端口号和发送的数据内容。
On This Page