服务器侦听器和 iot_message 处理程序
项目描述
在 Raspberry Pi 上使用的应用程序作为传入消息的接收者并将它们传递给注册的处理程序(继电器、屏幕、传感器)
from message_listener.server import Server
from iot_message.message import Message
from message_listener.handler_debug import HandlerDebug
from iot_message.cryptor.base64 import Cryptor as B64
Message.node_name = "PC"
Message.add_decoder(B64())
#Message.drop_unencrypted = True
svr = Server()
# svr.ignore_missing_decoders = False
svr.add_handler('NodeOne', HandlerDebug({}))
svr.start()
添加多个处理程序:
svr = Server()
svr.add_handler('NodeOne', HandlerDebug({}))
svr.add_handler('NodeOne', HandlerDebug({}))
svr.start()
或者
svr = Server()
svr.add_handler('NodeOne', [
HandlerDebug({}),
HandlerDebug({})
])
svr.start()
添加工人:
Handler1(Worker1(), Worker2())
初始化:
__init__(self, port=5053, ip_address='0.0.0.0', buffer_size=65535)
阅读更多: