文章目录
- 前言
- 一、平台注册
- 二、引入源码库
- 1.libcoap仓库编译
- 2.分析网络报文
- 3.案例代码
- 4.编译&运行
- 总结
前言
通过libcoap3开源代码库对接华为云平台,本文章将讨论加密与不加密的方式对接华为云平台。
一、平台注册
首先,你需要在华为云平台上创建一个coap协议的设备,并制定好数据格式,这个自行百度。
二、引入源码库
1.libcoap仓库编译
步骤如下(linux环境):
#参考https://raw.githubusercontent.com/obgm/libcoap/develop/BUILDING
git clone https://github.com/obgm/libcoap.git
cd libcoap
cd ext
# v0.9-rc1 这个版本的加密库没啥问题,其它版本没试
git clone --branch v0.9-rc1 --single-branch https://github.com/eclipse/tinydtls.git
cd ..
#这一步要做,不然报错
cp autogen.sh ext/tinydtls/
cmake -E remove_directory build
cmake -E make_directory build
cd build
cmake --build . -- install
cp lib/libtinydtls.so /usr/local/lib/
2.分析网络报文
(1)连接报文
注意这几个选项,在下面的案例代码将体现
(2)服务端资源请求报文
重点关注这个token,后面主动上传全靠它
(3)数据上传报文
3.案例代码
先找到设备标识码
#include <threads.h>
#include <coap3/coap.h>
#include <ctype.h>
#include <stdio.h>
#define COAP_CLIENT_URI "coap://015f8fcbf7.iot-coaps.cn-north-4.myhuaweicloud.com"
#define COAP_USE_PSK_ID "561342" //修改这个地方的标识码
#define RD_ROOT_STR "t/d"
typedef unsigned char method_t;
unsigned char msgtype = COAP_MESSAGE_NON;
static coap_context_t *main_coap_context = NULL;
static int quit = 0;
static int is_mcast = 0;
uint8_t sensor_data[2]={0x00,0x33};
unsigned int wait_seconds = 5; /* default timeout in seconds */
static unsigned char _token_data[24]={0x31,0x32,0x33,0x34,0x35,0x36,0x37,0x38}; /* With support for RFC8974 */
coap_binary_t the_token = { 8, _token_data };
static void handle_observe_request(coap_resource_t *resource COAP_UNUSED,
coap_session_t *session,
const coap_pdu_t *request,
const coap_string_t *query COAP_UNUSED,
coap_pdu_t *response) {
unsigned char observe_op=0;
coap_log_info("handle_observe_request \n");
/* 打印服务端的报文信息 */
coap_show_pdu(COAP_LOG_INFO, request);
coap_pdu_set_code(response, COAP_RESPONSE_CODE_CHANGED);
/* 存储服务端发来的token ,后面数据上传需要这个token */
coap_bin_const_t token = coap_pdu_get_token(request);
memcpy(the_token.s,token.s,token.length);
the_token.length = token.length;
coap_add_option(response,
COAP_OPTION_OBSERVE,
1,
&observe_op);
}
static void
free_xmit_data(coap_session_t *session COAP_UNUSED, void *app_ptr) {
coap_free(app_ptr);
return;
}
/* 上报设备信息 */
static int
coap_report(coap_context_t *ctx,
coap_session_t *session,
method_t m,
unsigned char *data,
size_t length) {
coap_pdu_t *pdu;
(void)ctx;
coap_log_debug("sending CoAP request\n");
if (!(pdu = coap_new_pdu(COAP_MESSAGE_NON, m, session))) {
free_xmit_data(session, data);
return 1;
}
if (!coap_add_token(pdu, the_token.length,the_token.s)) {
coap_log_debug("cannot add token to request\n");
}
if (!length) {
return 1;
}
coap_add_data( pdu, length, data);
if (coap_send(session, pdu) == COAP_INVALID_MID) {
coap_log_err("cannot send CoAP pdu\n");
return 1;
}
return 0;
}
static coap_response_t
message_handler(coap_session_t *session COAP_UNUSED,
const coap_pdu_t *sent,
const coap_pdu_t *received,
const coap_mid_t id COAP_UNUSED) {
coap_opt_t *block_opt;
coap_opt_iterator_t opt_iter;
size_t len;
const uint8_t *databuf;
size_t offset;
size_t total;
coap_pdu_code_t rcv_code = coap_pdu_get_code(received);
coap_pdu_type_t rcv_type = coap_pdu_get_type(received);
coap_bin_const_t token = coap_pdu_get_token(received);
coap_string_t *query = coap_get_query(received);
coap_log_debug("** process incoming %d.%02d response:\n",
COAP_RESPONSE_CLASS(rcv_code), rcv_code & 0x1F);
coap_show_pdu(COAP_LOG_INFO, received);
return COAP_RESPONSE_OK;
}
static void init_resources(coap_context_t * ctx)
{
coap_resource_t *r;
/* 创建设备资源,后面服务器要访问这个资源 */
r = coap_resource_init(coap_make_str_const(RD_ROOT_STR), 0);
/* 绑定get 方法,这个是通过抓包发现的 */
coap_register_request_handler(r, COAP_REQUEST_GET, handle_observe_request);
coap_add_resource(ctx, r);
}
static int
resolve_address(const char *host, const char *service, coap_address_t *dst,
int scheme_hint_bits)
{
uint16_t port = service ? atoi(service) : 0;
int ret = 0;
coap_str_const_t str_host;
coap_addr_info_t *addr_info;
str_host.s = (const uint8_t *)host;
str_host.length = strlen(host);
addr_info = coap_resolve_address_info(&str_host, port, port, port, port,
AF_UNSPEC, scheme_hint_bits,
COAP_RESOLVE_TYPE_REMOTE);
if (addr_info)
{
ret = 1;
*dst = addr_info->addr;
is_mcast = coap_is_mcast(dst);
}
coap_free_address_info(addr_info);
return ret;
}
void client_coap_init(void)
{
coap_session_t *session = NULL;
coap_pdu_t *pdu;
coap_address_t dst;
coap_mid_t mid;
int len;
coap_uri_t uri;
char portbuf[8];
char uri_query_op[20]={0};
unsigned int wait_ms = 0;
int result = -1;
#define BUFSIZE 100
unsigned char buf[BUFSIZE];
int res;
const char *coap_uri = COAP_CLIENT_URI;
/* Initialize libcoap library */
coap_startup();
coap_set_log_level(COAP_MAX_LOGGING_LEVEL);
/* Parse the URI */
len = coap_split_uri((const unsigned char *)coap_uri, strlen(coap_uri), &uri);
if (len != 0)
{
coap_log_warn("Failed to parse uri %s\n", coap_uri);
goto fail;
}
snprintf(portbuf, sizeof(portbuf), "%d", uri.port);
snprintf((char *)buf, sizeof(buf), "%*.*s", (int)uri.host.length,
(int)uri.host.length, (const char *)uri.host.s);
/* resolve destination address where packet should be sent */
len = resolve_address((const char *)buf, portbuf, &dst, 1 << uri.scheme);
if (len <= 0)
{
coap_log_warn("Failed to resolve address %*.*s\n", (int)uri.host.length,
(int)uri.host.length, (const char *)uri.host.s);
goto fail;
}
main_coap_context = coap_new_context(NULL);
if (!main_coap_context)
{
coap_log_warn("Failed to initialize context\n");
goto fail;
}
init_resources(main_coap_context);
coap_context_set_block_mode(main_coap_context, COAP_BLOCK_USE_LIBCOAP);
coap_context_set_keepalive(main_coap_context, 60);
session = coap_new_client_session(main_coap_context, NULL, &dst,
COAP_PROTO_UDP);
coap_session_init_token(session, the_token.length, the_token.s);
coap_register_response_handler(main_coap_context, message_handler);
/* construct CoAP message */
pdu = coap_pdu_init(COAP_MESSAGE_CON,
COAP_REQUEST_CODE_POST,
coap_new_message_id(session),
coap_session_max_pdu_size(session));
if (!pdu) {
coap_log_warn("Failed to create PDU\n");
goto fail;
}
if (!coap_add_token(pdu, the_token.length, the_token.s)) {
coap_log_debug("cannot add token to request\n");
}
coap_add_option(pdu, COAP_OPTION_URI_PATH, 1, "t");
coap_add_option(pdu, COAP_OPTION_URI_PATH, 1, "r");
unsigned char opbuf[40];
coap_add_option(pdu, COAP_OPTION_CONTENT_FORMAT,
coap_encode_var_safe(opbuf, sizeof(opbuf),
COAP_MEDIATYPE_APPLICATION_OCTET_STREAM),
opbuf);
sprintf(uri_query_op,"ep=%s",COAP_USE_PSK_ID);
coap_add_option(pdu, COAP_OPTION_URI_QUERY, strlen(uri_query_op), uri_query_op);
if (is_mcast)
{
wait_seconds = coap_session_get_default_leisure(session).integer_part + 1;
}
wait_ms = wait_seconds * 1000;
/* and send the PDU */
mid = coap_send(session, pdu);
if (mid == COAP_INVALID_MID)
{
coap_log_warn("Failed to send PDU\n");
goto fail;
}
while (!quit || is_mcast)
{
result = coap_io_process(main_coap_context, 1000);
coap_log_info("result %d wait_ms %d\n",result,wait_ms);
if (result >= 0)
{
if (wait_ms > 0)
{
if ((unsigned)result >= wait_ms)
{
//产生一个随机值
sensor_data[1] = wait_ms/100+result-wait_ms;
if ( 1 == coap_report(main_coap_context, session, COAP_RESPONSE_CODE_CONTENT,
sensor_data, 2)) {
goto fail;
}
wait_ms = wait_seconds * 1000;
}
else
{
wait_ms -= result;
}
}
}
}
fail:
/* Clean up library usage so client can be run again */
quit = 0;
coap_session_release(session);
session = NULL;
coap_free_context(main_coap_context);
main_coap_context = NULL;
coap_cleanup();
}
int main()
{
client_coap_init();
}
4.编译&运行
(1)编译
gcc -o test_coap_nodtls test_coap_nodtls.c -I/usr/local/include/coap3/ -lcoap-3 -ltinydtls -I/usr/local/include/tinydtls/
(2)运行
总结
加密对接的代码就不放出来,这个先参考着搞吧。