4. CoAP协议与资源发现：CoAP客户端/服务器实现、资源目录、DTLS安全握手、观察模式

4.1 本章概述

CoAP（Constrained Application Protocol）是IoT场景中最常用的RESTful协议之一，基于UDP，支持轻量级请求/响应、资源发现、观察模式以及DTLS安全通信。本章将带领你从零搭建一个跨系统CoAP集成原型，涵盖客户端/服务器的完整实现、资源目录（RD）的注册与查询、DTLS安全握手配置，以及观察者模式的订阅与推送。最终实现一个支持安全资源发现的温度传感器—网关—云平台联动原型。

4.2 CoAP核心原理与URI结构

4.3 CoAP服务器实现（基于libcoap）

采用libcoap库（C语言）在Linux开发板上部署服务器，暴露温度资源，并支持观察模式和资源发现（/.well-known/core）。

4.3.1 服务器代码框架

#include <coap3/coap.h>
#include <stdio.h>

static int attrs[] = { COAP_ATTR_FLAGS_OBSERVABLE, 0 };

static void
get_temperature(coap_resource_t *resource, coap_session_t *session,
                const coap_pdu_t *request, const coap_binary_t *token,
                const coap_string_t *query, coap_pdu_t *response) {
    // 模拟读取传感器
    float temp = 25.0 + (float)(rand()%10)/10.0;
    char buf[32];
    snprintf(buf, sizeof(buf), "%.1f", temp);
    coap_add_data_blocked_response(resource, session, request, response,
                                    token, COAP_MEDIATYPE_TEXT_PLAIN, 0,
                                    (uint8_t*)buf, strlen(buf));
}

int main(void) {
    coap_context_t *ctx = coap_new_context(NULL);
    coap_address_t addr;
    coap_address_init(&addr);
    addr.addr.sin6.sin6_family = AF_INET6;
    addr.addr.sin6.sin6_port = htons(5683);
    addr.addr.sin6.sin6_addr = in6addr_any;

    coap_endpoint_t *ep = coap_new_endpoint(ctx, &addr, COAP_PROTO_UDP);
    coap_resource_t *r = coap_resource_init(
        (const uint8_t*)"temperature", 11, 0);
    coap_register_handler(r, COAP_REQUEST_GET, get_temperature);
    coap_resource_set_get_observable(r, 1);
    coap_add_attr(r, (const uint8_t*)"obs", 3,
                  (const uint8_t*)"", 0, attrs);
    coap_add_resource(ctx, r);

    // 启动资源发现
    while (1) {
        coap_io_process(ctx, 10000);
    }
}

4.3.2 编译与运行

# 安装libcoap3-dev
sudo apt install libcoap3-dev

# 编译
gcc -o coap_server coap_server.c -lcoap-3

# 运行（绑定IPv6任意地址）
./coap_server

4.4 CoAP客户端实现：资源发现与数据获取

客户端首先向服务器发送GET请求到 /.well-known/core 发现资源列表，然后针对 temperature 发送GET请求获取数值，并可选订阅观察模式。

4.4.1 使用libcoap命令行工具快速验证

# 发现资源
coap-client -m get coap://[::1]/well-known/core

# 响应示例
</temperature>;obs;rt="temperature-celsius"

# 获取当前温度
coap-client -m get coap://[::1]/temperature

# 观察模式（持续接收）
coap-client -m get -s 120 -o - coap://[::1]/temperature

4.4.2 Python客户端实现（使用aiocoap库）

# 安装 aiocoap
# pip install aiocoap

import asyncio
from aiocoap import *

async def main():
    # 资源发现
    context = await Context.create_client_context()
    request = Message(code=GET, uri='coap://[::1]/well-known/core')
    response = await context.request(request).response
    resources = response.payload.decode()
    print("Discovered:", resources)

    # 获取温度并订阅观察
    request = Message(code=GET, uri='coap://[::1]/temperature',
                      observe=0)
    async for response in context.request(request).observation:
        temp = response.payload.decode()
        print(f"Temperature: {temp}°C")
        # 可以中断循环

if __name__ == "__main__":
    asyncio.run(main())

4.5 资源目录（RD）架构与注册流程

在集成系统中，传感器节点不会直接暴露给所有客户端，而是通过资源目录（CoRE Resource Directory）统一管理。节点向RD注册自己的资源，网关/云平台通过RD查询可用资源。

1. 注册（POST /rd）：传感器发送注册请求，主体包含资源描述（如 </temperature>;rt="temperature-celsius"）。
2. 更新（POST /rd/ep=<name>）：定期刷新有效性。
3. 查询（GET /rd-lookup/res）：客户端根据资源类型（rt）搜索。

4.5.1 RD服务器部署（使用libcoap示例）

# libcoap自带的资源目录服务器
git clone https://github.com/obgm/libcoap.git
cd libcoap
autoreconf -i
./configure --enable-examples
make
cd examples
# 启动RD服务器
./coap-rd -p 5683

4.5.2 传感器向RD注册

# 注册资源主体
echo -n '</temperature>;rt="temperature-celsius";obs' \
  | coap-client -m post \
    -f - coap://[::1]/rd?ep=sensor1
# 返回 Location-Path: /rd/abcd1234

# 查询所有温度资源
coap-client -m get \
  coap://[::1]/rd-lookup/res?rt="temperature-celsius"

4.6 DTLS安全握手配置

生产环境中必须对CoAP通信加密。DTLS支持PSK（预共享密钥）和基于证书的握手。以下演示PSK方式。

4.6.1 服务器启用DTLS（PSK）

# 生成PSK密钥文件（格式：身份:十六进制密钥）
echo "client1:0102030405060708" > psk_key.txt

# 启动支持DTLS的服务器
coap-server -p 5684 -k psk_key.txt -c "PSK"

4.6.2 客户端使用PSK连接

# 客户端指定PSK身份和密钥
coap-client -m get -k "0102030405060708" -u "client1" \
  coaps://[::1]/temperature

4.6.3 集成到资源目录场景

资源目录本身也可以支持DTLS，传感器通过coaps://rd:5684注册，网关通过coaps://rd:5684查询。注意RD的地址与端口必须提前配置到传感器固件中。

4.7 观察模式（Observe）实现与优化

观察模式使得客户端订阅资源后，服务器在资源变化时主动推送。适用于实时监控场景。

• 订阅：GET请求携带Observe:0，服务器返回当前值和序列号。
• 推送：服务器在变化时发送NON或CON消息，包含递增的Observe序号。
• 取消：客户端发送RST或设置Observe:1。

4.7.1 服务器观察实现要点

// 在libcoap服务器中，注册处理函数后调用
// coap_resource_set_get_observable(r, 1);
// 并在数据变化时调用
coap_resource_notify_observers(r, NULL);

4.7.2 客户端观察重连策略

// aiocoap 自动处理重连，但在弱网环境下建议设置超时
context = await Context.create_client_context()
request = Message(code=GET, uri='coap://[::1]/temperature',
                  observe=0)
async for response in context.request(request).observation:
    print(response.payload)
    # 如果长时间未收到推送，可主动重新订阅

4.8 完整集成架构图

4.9 调试方法与常见错误排查

4.10 性能优化与部署建议

• 非确认消息（NON）：对观察推送使用NON类型减少ACK开销，但需要在应用层处理丢包。
• DTLS会话缓存：在RD和服务器端启用会话ID缓存，减少重复握手。
• 资源目录缓存：网关本地缓存RD查询结果（TTL=60s），避免频繁请求RD。
• 观察推送速率控制：传感器端使用 coap_resource_notify_observers() 加上限速逻辑（例如每秒最多2次）。
• 部署步骤：
  1. 编译并启动RD服务器（启用DTLS）。
  2. 配置传感器固件：写入RD地址、PSK身份与密钥。
  3. 启动传感器节点，验证RD注册成功（查看RD日志）。
  4. 部署网关，实现资源查询与观察订阅逻辑。
  5. 端到端测试：模拟传感器温度变化，确认云平台收到推送。