一文解决 CoAP 协议设备与外部网络沟通难题物联网iotmqtt开源

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 两种，具体区别将会在下文详细介绍。
【一文解决 CoAP 协议设备与外部网络沟通难题】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 GitHub 项目地址：https://github.com/emqx/emqx 关注 EMQX 开源项目最新进展。