一文解决 CoAP 协议设备与外部网络沟通难题

Posted 2022-03-24 EMQ映云科技

CoAP 协议是一种支持在低功耗、低功率等受限设备间进行通信的物联网协议，这些设备往往都运行在受限网络中，因此 CoAP 协议设计得十分精炼， 同时采用 UDP 协议进行数据传输，所以能够很好的适应受限网络环境。 CoAP 通过类似于 HTTP 操作的方式，在受限设备组成的 M2M 网络中，对设备上抽象的资源进行操作，这样能够十分简洁、高效地实现受限设备间同步、 异步的信息交流。

CoAP 是专为受限硬件、环境而设计的通信协议，在受限网络中能够良好的工作，但如果受限网络需要和外部网络进行沟通，CoAP 则不能很好的适应。另外，因为 CoAP 设计时更多考虑的是 M2M 网络模型，所以 CoAP 缺乏对资源处理中心的支持（基于 CoAP 的 LwM2M 协议为此专门引入了资源的注册、资源的服务等概念）。

以上问题可以通过 ​​EMQX​​ 消息服务器得到很好的解决。本文就将介绍如何使用 EMQX 接入 CoAP 协议，实现 CoAP 协议设备与外部的沟通。

EMQX 的 CoAP 协议接入方式

对于需要和外部进行沟通的 CoAP 设备，使用 EMQX 作为消息中间件，可以很方便地实现以下功能：

• 对设备进行认证，拒绝不可信设备的数据
• 对资源进行权限管理，可以指定不同的设备对某个资源拥有不同的读/写权限
• 可以作为不同网络 CoAP 设备间的信息传输中心
• 可以作为其他应用，比如 CoAP 管理应用、数据分析应用和 CoAP 设备、网络间的接入中间件

EMQX 中提供了两种不同的 CoAP 接入方式，涵盖了大多数 CoAP 的业务场景，且接入简单，支持良好，不需对 CoAP 协议本身进行改动。而对原有的 CoAP 设备、应用，接入 EMQX 的成本也很小。

URL 模型

EMQX 通过 URL path 和 queryString 来实现对 CoAP 的接入，CoAP 接入时需要按照下面的规则组织 URL 模型:

coap 连接类型://Host:Port/模式/TopicName?c=客户端Id&u=用户名&p=密码

其中，​coap 连接类型​可以为:

• coap：使用普通的 UDP 进行传输
• coaps：启用安全传输层，关于如何启用 coaps (包括单向认证、双向认证)，详细见加密通信配置

​模式​ 目前有: ​​MQTT​​ 和 ​PubSub​ 两种，具体区别将会在下文详细介绍。

​TopicName​ : EMQX 中使用 Topic 作为 CoAP 中的资源标识符，一个 Topic 就代表一个资源对象， 而 Topic 可以为任意 UTF8 字符串，允许多个层级，比如 coap/ 、coap/test/queryString。

URL 中的 c、u、p 三个字段是必须的，其中：

• c 代表客户端 ID，为任意字符串，理论上每个客户端 ID 都应该需要是唯一的
• u 和 p 分别代码用户名和密码，需要在 EMQ X 的认证模块中预先设置好

MQTT 模式

MQTT 模式按照 MQTT 标准，对 CoAP 的 Method 进行转义，只有简单的 Pub/Sub 行为，转义对照表如下：

Method	Token	MQTT
GET	0	Subscribe
GET	1	UnSubscribe
GET	_	非法操作
PUT	_	Publish
POST	_	非法操作
DELETE	_	非法操作

该模式适用于以下场景:

• 只需要使用 EMQX 进行消息、指令或者其他实时信息传输
• 如果需要长时间使用​Observe​功能， 则需要处于专用网络或者内网中 这点比较重要，因为 UDP 是无连接的，所以在公网上产生的 UDP 链路是无法长时间保持的，这会导致​Observe​可能无法正常接受到数据
• 如果处于公网，则​Observe​只能用来做为​PUT​操作的结果监听机制，例如: 假设一个 CoAP 设备需要通过 EMQX 向另外的其他设备发送指令、数据，并且根据返回的数据进行后续处理，则可以:

1. 使用​PUT​方法向某个 Topic 发送指令
2. 使用​Observe​方式监听这个 Topic
3. 根据 EMQX 返回的数据进行处理 鉴于公网中 UDP 链路的维持时间，Observe 的时间在 30s 以内是安全的，在 15s 内是足够安全的

PubSub 模式

PubSub 模式相对于 MQTT 模式来说更加复杂些，但是也相对更符合 CoAP 中「资源」的概念，所有 Publish 的消息，会被当作「资源」存放在 EMQX 内，超时时间采用 CoAP 协议中的 ​max-age​ 可选字段进行控制，在超时前，消息都能通过 *GET* 方法获取到。

转义关系如下:

Method	Token	MQTT	Resouce
GET	0	Subscribe	_
GET	1	UnSubscribe	_
GET			读取该 Topic 对应的消息
PUT	_	Publish	更新该 Topic 对应的消息
POST	_	Publish	更新该 Topic 对应的消息
DELETE			删除该 Topic 对应的消息

这种模式相当于上面的 ​MQTT​ 模式的扩展，除了上述适用场景外，还适用于以下场景:

• 使用 EMQX 作为数据、信息等资源的交换汇总中心的场景 比如监控环境的 CoAP 设备,可以定时将自己采集到的数据​PUT​到 EMQX 中，而数据处理中心则通过订阅相关主题来接收这些数据，以此对环境状况进行分析； 又比如 CoAP 设备可以定时将自身状态推送到 EMQX 中，用户则可以通过 EMQX 直接观察设备的运行状态。
• 消息传输的频率低、对时延容忍度高的场景 这种场景中，可以使用​PUT​更新某个 Topic 的消息，而对该 Topic 感兴趣的客户端则可以按照自己的节奏，通过​GET​来获取最新的消息、数据等。

配置方法

EMQX 的 CoAP 协议网关相关配置在 emqx.conf 文件中，下面将会详细介绍。

非加密通信场景

对于数据敏感性不高，或者不需要传输链路保证通信安全的情况下，可以简单按照业务需求打开对应的端口进行监听即可。

比如下面的配置，在所有可用 IP 上监听 5683 端口，且在局域网 IP 192.168.1.2 上监听 5684 端口

coap.bind.udp.1 = 0.0.0.0:5683
coap.bind.udp.2 = 192.168.1.2:5684

加密通信场景

EMQX 的 CoAP 协议网关支持 DTLS 安全传输层协议，同时可配置单向/双向认证，默认配置会自动打开单向认证。

单向认证

单向认证的配置如下，如果不需要启用加密通信，应该注释掉这些配置。

## DTLS 监听的端口, 配置方式和上面的udp模式一样,可用按照需要配置多个端口
coap.dtls.port1 = 5684
coap.dtls.port2 = 192.168.1.2:6585

## DTLS 的私钥
## Value: File
coap.dtls.keyfile =  platform_etc_dir /certs/key.pem

## DTLS 的证书文件
## Value: File
coap.dtls.certfile =  platform_etc_dir /certs/cert.pem

双向认证

EMQX 的 CoAP 协议网关也支持双向认证，配置如下：

## 验证模式, 可选值为: verify_peer | verify_none
coap.dtls.verify = verify_peer

## 客户端没有发送证书时是否拒绝连接
coap.dtls.fail_if_no_peer_cert = false

## pem格式的CA证书
coap.dtls.cacertfile =  platform_etc_dir /certs/cacert.pem

​coap.dtls.verify​ 用来决定是否开启双向认证, 可选值为:

• verify_peer 验证客户端
• verify_none 不验证客户端

当双向认证开启时， coap.dtls.fail_if_no_peer_cert 用来决定当客户端没有发送证书时,服务器是否拒绝连接。 coap.dtls.cacertfile 为 pem 格式的CA证书，用来对客户端进行验证。关于双向认证，具体可以参考​​EMQX 启用双向 SSL/TLS 安全连接​​。

测试和验证

开启 CoAP 协议网关

使用 Dashboard 开启

在 Dashboard 中的 插件 目录下，选择 emqx_coap 点击开启即可，如图:

使用终端开启

在终端可使用下面的指令开启 emqx_coap 功能:

./bin/emqx_ctl plugins load emqx_coap

安装 CoAP 测试用客户端

coap.me

如果在 EMQX 的 CoAP 协议网关上配置的是公网 IP，可以使用https://coap.me/这个在线网站进行测试。具体使用方法见网站说明。

libcoap

libcoap 是一个 C 语言实现的、对 CoAP 所有相关标准都有完善支持的库，自带一个客户端应用，一般被视作 CoAP 的标准校验客户端。

在大多数 Linux 系统中，可以使用系统的包管理器进行安装，在 macOS 上可以使用 brew 进行安装，其他平台可能需要手动编译源代码。

安装好后的客户端一般叫做：coap-client 或者 libcoap。

测试 PubSub 模式

下面使用 libcoap 演示，先向服务器 publish 一个消息后，再读取该 Topic 对应的最新消息

# 使用 PubSub 模式,以 put 方法向 coap/test Topic 推送一条 json 格式的消息
coap-client -m put -e #msg => "Hello, CoAP" -t json "coap://127.0.0.1:5683/ps/coap/test?c=clientid1234&u=admin&p=public"

# 读取 coap/test 这个 Topic 最后一条消息, 将会得到 #msg => "Hello, CoAP"
coap-client -m get  "coap://127.0.0.1:5683/ps/coap/test?c=clientid1234&u=admin&p=public"

下面的例子演示如何进行订阅:

## 订阅 coap/observe 这个 topic, Token 设置为"token", 订阅超时为 60s
coap-client -m get -s 60 -B 30 -o - -T "token" "coap://127.0.0.1:5683/ps/coap/observe?c=clientid1234&u=admin&p=public"

## 使用另外一个 CoAP 客户端进行推送, 也可以使用其他任意的 MQTT 客户端
coap-client -m post -e #msg => "This is Observe" -t json "coap://127.0.0.1:5683/ps/coap/observe?c=clientid1234&u=admin&p=public"

## 这个时候订阅者将会收到:
## #msg => "This is Observe"

测试 MQTT 模式

MQTT 模式的测试和上面一样，只不过只有 publish/subscribe 两种操作。例子如下:

## publish
coap-client -m put -e #msg => "Hello, CoAP" -t json "coap://127.0.0.1:5683/mqtt/coap/test?c=clientid1234&u=admin&p=public"

## subscribe
coap-client -m get -s 60 -B 60 -o - -T "token" "coap://127.0.0.1:5683/mqtt/coap/sub?c=clientid1234&u=admin&p=public"

结语

至此，我们完成了 CoAP 协议设备接入 EMQX 的完整流程，实现了 CoAP 协议设备和 MQTT 协议设备的整合。

作为一款强大的开源分布式云原生物联网消息服务器，EMQX 不仅完整支持 MQTT 协议，同时支持 CoAP、LwM2M 协议，为各类终端设备的接入提供便利。

关于 EMQX 的详细使用，可参考 ​​EMQX 企业版文档​​。也可访问 EMQX GitHub 项目地址：https://github.com/emqx/emqx 关注 EMQX 开源项目最新进展。

版权声明： 本文为 EMQ 原创，转载请注明出处。

原文链接：​​https://www.emqx.com/zh/blog/connecting-coap-devices-to-emqx​​