Coap服务器搭建Python版本

Coap 简介

• CoAP(Constrained Application Protocol)被设计用于同一受限网络（例如，低功耗、有损网络）上的设备之间、设备和因特网上的一般节点之间以及由因特网连接的不同受限网络上的设备之间使用。
• 定义四种消息类型
  • PUT
  • GET
  • POST
  • DELETE
• 基于请求/响应模型
• 双向通信（M2M）
• 轻量：轻量最小长度仅为4B
• 基于UDP
• 低功耗 ,非长连接通信

版本

• ubuntu 20.04
• python 3.8.5
• aiocoap

Step1 安装aiocoap

pip3 install --upgrade aiocoap

Step2 编写服务端程序

# coding=utf-8
# @filename     :server.py
# @time         :2021/12/1 10:28 pm
# @author       :changaolin@gmail.com
# @description  :
import asyncio

from aiocoap import Message, Context
from aiocoap.numbers import Code
from aiocoap.resource import Resource, Site


class Alarm(Resource):
    def __init__(self):
        super().__init__()
        self.state = "OFF"

    async def render_put(self, request):
        self.state = request.payload
        print('update: %s' % self.state)
        return Message(code=Code.CHANGED, payload=self.state)


def main():
    site = Site()
    site.add_resource(['alarm'], Alarm())
    asyncio.Task(Context.create_server_context(site, bind=('localhost', 5683)))
    print("开启coap 服务: coap://localhost/alarm")
    asyncio.get_event_loop().run_forever()


if __name__ == "__main__":
    main()

Step3 编写 客户端程序

# coding=utf-8
# @filename     :client.py
# @time         :2021/12/1 10:31 pm
# @author       :changaolin@gmail.com
# @description  :
import asyncio
import random

from aiocoap import Context, Message
from aiocoap.numbers.codes import Code


async def main():
    context = await Context.create_client_context()
    payload = random.choice([b'OFF', b'ON'])

    request = Message(code=Code.PUT, payload=payload, uri="coap://localhost/alarm")

    response = await context.request(request).response
    print('%s\n%r' % (response.code, response.payload))


if __name__ == "__main__":
    asyncio.get_event_loop().run_until_complete(main())

Step4 执行测试

python server.py # 在终端启动,等待链接
# 开启coap 服务: coap://localhost/alarm
# update: b'ON'

python client.py # 在新终端启动
# 2.04 Changed
# b'ON'