node.js - node.js 中的 OneM2M coap 客户端

Question

我必须开发一个可以与另一个oneM2M服务器交互的node.js 应用程序。特别是 node.js 应用程序需要使用CoaP协议交换数据，但我不知道如何以符合 oneM2M 的方式进行。

我使用这个模块开始了我的node.js项目： https ://github.com/mcollina/node-coap 但我需要一些支持才能使用 oneM2M 协议创建 CoaP 客户端。

代码示例非常感谢。

Answer 1

如果您想从您的应用程序与 oneM2M CSE 进行通信，那么您应该实现Mca接口。这是 CSE 和您的应用程序之间的接口，技术上称为应用程序实体或 AE。

最简单的方法是使用 REST 绑定。您可以在http://www.onem2m.org/application-developer-guide上查看 oneM2M 的开发人员指南。

您可能还想阅读以下规范：

• TS-0001：功能规范，是oneM2M的核心规范文件。这里定义了基本概念以及所有资源类型。
• TS-0004：服务层核心协议，以获取有关资源的实际编码和表示的更多详细信息。
• TS-0008：CoAP 协议绑定
• TS-0009：HTTP 协议绑定

您可以在此处找到这些和其他规范的最新版本：http ://www.onem2m.org/technical/published-documents

Answer 2

根据TS-0008: CoAP Protocol Binding章节6.2.1 Header有以下一个 M2M 操作与 CoAP 方法的映射：

Operation      CoAP Method
CREATE         POST
RETRIEVE       GET
UPDATE         PUT
DELETE         DELETE
NOTIFY         POST 

然后在第6.2.2.4 章新选项的定义中介绍了一组新的 CoAP 选项，映射一个 M2M 标头参数。这里列出了主要的 HTTP 标头变量以及 CoAP 选项等效项：

Header HTTP variable   CoAP Option
X-M2M-Origin           256
X-M2M-RI               257
oneM2M-TY              267

所以这里有一个最小的 node.js 脚本来做一个GET 操作，即用路径检索容器资源中的最新 contentInstance /<cseBase>/<AE>/<Container>：

var coap = require('coap');

var options = {
    host : '<hostname>',
    port : 5683,
    pathname : "/<cseBase>/<AE>/<Container>/la",
    method : 'get',
    confirmable : 'true',
    options : {
        'Accept' : 'application/json'
    }
};
var bodyString = '';    // void string for GET operation
var responseBody = '';

var req = coap.request(options);
req.setOption("256", new Buffer("<origin>"));   // X-M2M-Origin (mandatory)
req.setOption("257", new Buffer('123456'));     // X-M2M-RI (mandatory)

req.on('response', function (res) {
    res.on('data', function () {
        responseBody += res.payload.toString();
    });
    res.on('end', function () {
        if (res.code == '2.05') {
            console.log('[coap] coap ready, request OK');
            var obj = JSON.parse(responseBody);
            console.log('[coap] responseBody', obj);
        } else {
            console.log('[coap] coap res.code='+res.code);
        }
    });
});
req.write(bodyString);
req.end();

这是一个最小的POST 操作示例，即在具有路径的容器资源中创建一个 contentInstance /<cseBase>/<AE>/<Container>：

var coap = require('coap');

var options = {
    host : '<hostname>',
    port : 5683,
    pathname : "/<cseBase>/<AE>/<Container>",
    method : 'post',
    confirmable : 'true',

    options : {
        'Content-Format' : 'application/json'
    }
};
var bodyString = new Buffer('{"m2m:cin":{ "con":{"temperature":33}}}');
var responseBody = '';

var req = coap.request(options);
req.setOption("256", new Buffer("<origin>"));   // X-M2M-Origin (mandatory)
req.setOption("257", new Buffer('123456'));     // X-M2M-RI (mandatory)
req.setOption("267", new Buffer([4]));          // ty = 4, ContentInstance resource type

req.on('response', function (res) {
    res.on('data', function () {
        responseBody += res.payload.toString();
    });
    res.on('end', function () {
        if (res.code == '2.05') {
            console.log('[coap] coap ready, request OK');
            var obj = JSON.parse(responseBody);
            console.log('[coap] responseBody', obj);
        } else {
            console.log('[coap] coap res.code='+res.code);
        }
    });
});
req.write(bodyString);
req.end();