[嵌入式开发模块]Coap开源库libnyoci移植及简单使用(基于wiz/W5500官方io库)

ゞ 浴缸里的玫瑰 2021-12-05 01:43 695阅读 0赞

文章目录

  • 前言
  • 工程环境配置
    • 配置文件
      • config.h
      • nyoci-config.h
  • 平台移植
    • nyoci-plat-net.h
    • nyoci-plat-net-internal.h
    • nyoci-plat-net.c
    • 简要说明
  • 使用示例
    • 示例代码
    • 简要说明
    • 测试
  • 总结

前言

最近研究了下实现coap协议，几个纯C开源库看下来感觉还是libnyoci移植起来靠谱点，其他库要不然对POSIX的API强耦合，要不反正就是不知道怎么搞。

折腾好久起码现在能够实现一个正常的Coap服务器了，发上来供需要的人参考。

因为这个库依赖了大量相对高级版本的标准库函数以及(如果要完整移植的话)要求实现很多应用层网络功能，如DNS、TSL什么的，所以着实折腾了好久才成功编译。

这里只讲到要实现一个基于UDP的Coap服务器所需要移植的部分。

工程环境配置

首先，先去全球最大的同性交友网站下载好libnyoci的源文件，完不成的话点击下右上角的×

然后libnyoci\src\libnyoci中的.c和.h文件全扔进工程中，基本都会用到。
libnyoci\src\libnyociextra中的文件则根据需要放进工程中，取决于你使用这个库的方法。

然后我们需要加入配置文件，在这之前先打开编译器选项，加入宏定义HAVE_CONFIG_H=1

在我的CodeWarrior上是这样子实现的：
watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70
不同的IDE找各自的方法。

配置文件

这样子nyoci就知道了你会包含一个叫做config.h的配置文件；以及默认会有的nyoci-config.h配置文件。这两个文件如下：

config.h

  1. /* src/config.h.  Generated from config.h.in by configure.  */
  2. /* src/config.h.in.  Generated from configure.ac by autoheader.  */
  4. /* rl_completion_entry_function has the wrong return type */
  5. #define HAS_LIBEDIT_COMPLETION_ENTRY_BUG 1
  7. /* Define to 1 if you have the `alloca' function. */
  8. /* #undef HAVE_ALLOCA */
  10. /* Define to 1 if you have the <alloca.h> header file. */
  11. #define HAVE_ALLOCA_H 0
  13. /* Define to 1 if you have the <dlfcn.h> header file. */
  14. #define HAVE_DLFCN_H 0
  16. /* Define to 1 if you have the <errno.h> header file. */
  17. #define HAVE_ERRNO_H 1
  19. /* Define to 1 if you have the `fprintf' function. */
  20. #define HAVE_FPRINTF 0
  22. /* Define to 1 if the system has the `deprecated' function attribute */
  23. #define HAVE_FUNC_ATTRIBUTE_DEPRECATED 0
  25. /* Define to 1 if the system has the `pure' function attribute */
  26. #define HAVE_FUNC_ATTRIBUTE_PURE 0
  28. /* Define to 1 if you have the `getline' function. */
  29. #define HAVE_GETLINE 0
  31. /* Define to 1 if you have the `getloadavg' function. */
  32. #define HAVE_GETLOADAVG 0
  34. /* Define to 1 if you have the `gettimeofday' function. */
  35. #define HAVE_GETTIMEOFDAY 0
  37. /* Define to 1 if you have the <inttypes.h> header file. */
  38. #define HAVE_INTTYPES_H 0
  40. /* Define to 1 if you have the `readline' library (-lreadline). */
  41. #define HAVE_LIBREADLINE 0
  43. /* Define to 1 if you have the `malloc' function. */
  44. #define HAVE_MALLOC 1
  46. /* Define to 1 if you have the `memcmp' function. */
  47. #define HAVE_MEMCMP 1
  49. /* Define to 1 if you have the <memory.h> header file. */
  50. #define HAVE_MEMORY_H 0
  52. /* Define to 1 if you have the `memset' function. */
  53. #define HAVE_MEMSET 1
  55. /* Set if OpenSSL is present */
  56. /* #undef HAVE_OPENSSL */
  58. /* Set if OpenSSL has DTLSv1_method() */
  59. /* #undef HAVE_OPENSSL_DTLSV1_METHOD */
  61. /* Set if OpenSSL has DTLS_method() */
  62. /* #undef HAVE_OPENSSL_DTLS_METHOD */
  64. /* Set if OpenSSL has SSL_CONF_CTX_new() */
  65. /* #undef HAVE_OPENSSL_SSL_CONF_CTX_NEW */
  67. /* Set if OpenSSL has SSL_CONF_finish() */
  68. /* #undef HAVE_OPENSSL_SSL_CONF_FINISH */
  70. /* Define to 1 if you have the `printf' function. */
  71. #define HAVE_PRINTF 1
  73. /* Define if you have POSIX threads libraries and header files. */
  74. #define HAVE_PTHREAD 0
  76. /* Have PTHREAD_PRIO_INHERIT. */
  77. #define HAVE_PTHREAD_PRIO_INHERIT 0
  79. /* Define to 1 if you have the `rl_set_prompt' function. */
  80. #define HAVE_RL_SET_PROMPT 0
  82. /* Define to 1 if you have the `setenv' function. */
  83. #define HAVE_SETENV 0
  85. /* Define to 1 if you have the `snprintf' function. */
  86. #define HAVE_SNPRINTF 1
  88. /* Define to 1 if you have the `sprintf' function. */
  89. #define HAVE_SPRINTF 1
  91. /* Define to 1 if you have the <stdarg.h> header file. */
  92. #define HAVE_STDARG_H 1
  94. /* Define to 1 if you have the <stdbool.h> header file. */
  95. #define HAVE_STDBOOL_H 1
  97. /* Define to 1 if you have the <stddef.h> header file. */
  98. #define HAVE_STDDEF_H 1
  100. /* Define to 1 if you have the <stdint.h> header file. */
  101. #define HAVE_STDINT_H 1
  103. /* Define to 1 if you have the <stdio.h> header file. */
  104. #define HAVE_STDIO_H 1
  106. /* Define to 1 if you have the <stdlib.h> header file. */
  107. #define HAVE_STDLIB_H 1
  109. /* Define to 1 if you have the `stpncpy' function. */
  110. #define HAVE_STPNCPY 1
  112. /* Define to 1 if you have the `strchr' function. */
  113. #define HAVE_STRCHR 1
  115. /* Define to 1 if you have the `strdup' function. */
  116. #define HAVE_STRDUP 0
  118. #define HAVE_STRSEP 0
  120. /* Define to 1 if you have the `strerror' function. */
  121. #define HAVE_STRERROR 0
  123. /* Define to 1 if you have the <strings.h> header file. */
  124. #define HAVE_STRINGS_H 0
  126. /* Define to 1 if you have the <string.h> header file. */
  127. #define HAVE_STRING_H 1
  129. /* Define to 1 if you have the `strlcat' function. */
  130. #define HAVE_STRLCAT 1
  132. /* Define to 1 if you have the `strlcpy' function. */
  133. #define HAVE_STRLCPY 0
  135. /* Define to 1 if you have the `strndup' function. */
  136. #define HAVE_STRNDUP 0
  138. /* Define to 1 if you have the `strstr' function. */
  139. #define HAVE_STRSTR 1
  141. /* Define to 1 if you have the `strtol' function. */
  142. #define HAVE_STRTOL 1
  144. /* Define to 1 if you have the <sys/stat.h> header file. */
  145. #define HAVE_SYS_STAT_H 0
  147. /* Define to 1 if you have the <sys/types.h> header file. */
  148. #define HAVE_SYS_TYPES_H 0
  150. /* Define to 1 if you have the <unistd.h> header file. */
  151. #define HAVE_UNISTD_H 0
  153. /* Define to 1 if you have the `vsnprintf' function. */
  154. #define HAVE_VSNPRINTF 0
  156. /* Define to 1 if you have the `vsprintf' function. */
  157. #define HAVE_VSPRINTF 0
  159. #define HAVE_C99_VLA 0
  161. /* Define to the sub-directory where libtool stores uninstalled libraries. */
  162. //#define LT_OBJDIR ".libs/"
  164. /* . */
  165. //#define NYOCI_API_EXTERN  extern
  167. /* . */
  168. /* #undef NYOCI_AVOID_MALLOC */
  170. /* . */
  171. /* #undef NYOCI_AVOID_PRINTF */
  173. /* . */
  174. /* #undef NYOCI_CONF_NODE_ROUTER */
  176. /* . */
  177. /* #undef NYOCI_CONF_TRANS_ENABLE_BLOCK2 */
  179. /* . */
  180. /* #undef NYOCI_CONF_TRANS_ENABLE_OBSERVING */
  182. /* . */
  183. /* #undef NYOCI_EMBEDDED */
  185. /* . */
  186. //#define NYOCI_INTERNAL_EXTERN extern
  188. /* . */
  189. /* #undef NYOCI_MAX_OBSERVERS */
  191. /* . */
  192. /* #undef NYOCI_MAX_VHOSTS */
  194. /* LibNyoci network abstraction */
  195. //#define NYOCI_PLAT_NET posix
  197. /* . */
  198. /* #undef NYOCI_PLAT_NET_POSIX_FAMILY */
  200. /* LibNyoci TLS abstraction */
  201. /* #undef NYOCI_PLAT_TLS */
  203. /* . */
  204. /* #undef NYOCI_SINGLETON */
  206. /* . */
  207. /* #undef NYOCI_USE_CASCADE_COUNT */
  209. /* Name of package */
  210. #define PACKAGE "libnyoci"
  212. /* Define to the address where bug reports for this package should be sent. */
  213. #define PACKAGE_BUGREPORT "https://github.com/darconeous/libnyoci/"
  215. /* Define to the full name of this package. */
  216. #define PACKAGE_NAME "LibNyoci"
  218. /* Define to the full name and version of this package. */
  219. #define PACKAGE_STRING "LibNyoci 0.07.00rc1"
  221. /* Define to the one symbol short name of this package. */
  222. #define PACKAGE_TARNAME "libnyoci"
  224. /* Define to the home page for this package. */
  225. #define PACKAGE_URL "http://libnyoci.org/"
  227. /* Define to the version of this package. */
  228. #define PACKAGE_VERSION "0.07.00rc1"
  230. /* Define to necessary symbol if this constant uses a non-standard name on
  231.    your system. */
  232. /* #undef PTHREAD_CREATE_JOINABLE */
  234. /* Source version */
  235. #define SOURCE_VERSION "0.07.00rc1-6-g5ad1f3d"
  237. /* Define to 1 if you have the ANSI C header files. */
  238. #define STDC_HEADERS 1
  240. /* Define to 1 if you can safely include both <sys/time.h> and <time.h>. */
  241. #define TIME_WITH_SYS_TIME 0
  243. /* Enable extensions on AIX 3, Interix.  */
  244. //#ifndef _ALL_SOURCE
  245. // #define _ALL_SOURCE 1
  246. //#endif
  247. /* Enable GNU extensions on systems that have them.  */
  248. //#ifndef _GNU_SOURCE
  249. //# define _GNU_SOURCE 1
  250. //#endif
  251. /* Enable threading extensions on Solaris.  */
  252. //#ifndef _POSIX_PTHREAD_SEMANTICS
  253. //# define _POSIX_PTHREAD_SEMANTICS 1
  254. //#endif
  255. /* Enable extensions on HP NonStop.  */
  256. //#ifndef _TANDEM_SOURCE
  257. //# define _TANDEM_SOURCE 1
  258. //#endif
  259. /* Enable general extensions on Solaris.  */
  260. //#ifndef __EXTENSIONS__
  261. //# define __EXTENSIONS__ 1
  262. //#endif
  263. #define DEBUG 1
  264. #define VERBOSE_DEBUG 1
  265. #define __ORDER_BIG_ENDIAN__ 1
  266. #define __BYTE_ORDER__  0
  268. /* Version number of package */
  269. #define VERSION "0.07.00rc1"
  271. /* Define to 1 if on MINIX. */
  272. /* #undef _MINIX */
  274. /* Define to 2 if the system does not provide POSIX.1 features except with
  275.    this defined. */
  276. /* #undef _POSIX_1_SOURCE */
  278. /* Define to 1 if you need to in order for `stat' and other things to work. */
  279. /* #undef _POSIX_SOURCE */
  281. /* Define to empty if `const' does not conform to ANSI C. */
  282. /* #undef const */
  284. /* Define to `__inline__' or `__inline' if that's what the C compiler
  285.    calls it, or to nothing if 'inline' is not supported under any name.  */
  286. #ifndef __cplusplus
  287. /* #undef inline */
  288. #endif
  290. /* Define to `unsigned int' if <sys/types.h> does not define. */
  291. /* #undef size_t */
  293. /* Define to `int' if <sys/types.h> does not define. */
  294. /* #undef ssize_t */
  296. /* Define to empty if the keyword `volatile' does not work. Warning: valid
  297.    code using `volatile' can become incorrect without. Disable with care. */
  298. /* #undef volatile */

这个文件主要是用于告知nyoci你的开发环境有没有包含某个函数以配置代码，上面是我目前的配置。请参照自己的开发环境按注释配置好其中未注释掉的部分，以减少编译链接时一堆报警。。

要注意的是

  1. #define __ORDER_BIG_ENDIAN__ 1
  2. #define __BYTE_ORDER__  0

这里两个其实并不是让你回答机器是大端还是小端的。它的功能就是帮助nyoci确定位序以确定：

  1. struct coap_header_s {
  3. #if __BYTE_ORDER__ == __ORDER_BIG_ENDIAN__
  4.     uint8_t
  5.         version:2,
  6.         tt:2,
  7.         token_len:4;
  8. #else
  9.     uint8_t
  10.         token_len:4,
  11.         tt:2,
  12.         version:2;
  13. #endif
  14. ……
  15. };

这个结构体中到底应该按什么顺序排这三个字段。这个可能和单片机与编译器都有关，不见得大端字节序的就一定大端位序。反正就是两个值相等和两个值不等的都试一下，用成功通讯的那个就好。

nyoci-config.h

  1. /*!    @file nyoci-config.h
  2. **    @author Robert Quattlebaum <darco@deepdarc.com>
  3. **    @brief LibNyoci Build Options
  4. **
  5. **    Copyright (C) 2017 Robert Quattlebaum
  6. **
  7. **    Permission is hereby granted, free of charge, to any person
  8. **    obtaining a copy of this software and associated
  9. **    documentation files (the "Software"), to deal in the
  10. **    Software without restriction, including without limitation
  11. **    the rights to use, copy, modify, merge, publish, distribute,
  12. **    sublicense, and/or sell copies of the Software, and to
  13. **    permit persons to whom the Software is furnished to do so,
  14. **    subject to the following conditions:
  15. **
  16. **    The above copyright notice and this permission notice shall
  17. **    be included in all copies or substantial portions of the
  18. **    Software.
  19. **
  20. **    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY
  21. **    KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE
  22. **    WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
  23. **    PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS
  24. **    OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
  25. **    OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
  26. **    OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
  27. **    SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  28. */
  29. // 1/0
  30. #define NYOCI_EMBEDDED 1
  31. // 1/0
  32. #define NYOCI_SINGLETON 0
  34. #undef NYOCI_PLAT_NET_POSIX_FAMILY
  36. #undef NYOCI_PLAT_NET
  38. // define/undef
  39. #undef NYOCI_PLAT_TLS
  41. #undef NYOCI_AVOID_MALLOC
  43. #undef NYOCI_AVOID_PRINTF
  45. #undef NYOCI_DEFAULT_PORT
  47. #undef NYOCI_CONF_DUPE_BUFFER_SIZE
  49. #undef NYOCI_CONF_ENABLE_VHOSTS
  51. #define NYOCI_CONF_MAX_ALLOCED_NODES 2
  53. #undef NYOCI_CONF_MAX_GROUPS
  55. #undef NYOCI_CONF_MAX_OBSERVERS
  57. #undef NYOCI_CONF_MAX_PAIRINGS
  59. #undef NYOCI_CONF_MAX_TIMEOUT
  61. #define NYOCI_CONF_NODE_ROUTER
  63. #undef NYOCI_CONF_TRANS_ENABLE_BLOCK2
  65. #undef NYOCI_CONF_TRANS_ENABLE_OBSERVING
  67. // 0/1
  68. #define NYOCI_CONF_USE_DNS  0
  70. #undef NYOCI_ADD_NEWLINES_TO_LIST_OUTPUT
  72. #undef NYOCI_ASYNC_RESPONSE_MAX_LENGTH 50
  74. #undef NYOCI_DEBUG_INBOUND_DROP_PERCENT
  76. #undef NYOCI_DEBUG_OUTBOUND_DROP_PERCENT
  78. #undef NYOCI_MAX_CASCADE_COUNT
  80. #define NYOCI_MAX_CONTENT_LENGTH  50
  82. #undef NYOCI_MAX_OBSERVERS
  84. #undef NYOCI_MAX_PACKET_LENGTH
  86. #undef NYOCI_MAX_PATH_LENGTH
  88. #undef NYOCI_MAX_URI_LENGTH
  90. #undef NYOCI_MAX_VHOSTS
  92. #undef NYOCI_TRANSACTION_BURST_COUNT
  94. #undef NYOCI_TRANSACTION_BURST_TIMEOUT_MAX
  96. #undef NYOCI_TRANSACTION_BURST_TIMEOUT_MIN
  98. #undef NYOCI_THREAD_SAFE
  100. #undef NYOCI_NODE_ROUTER_USE_BTREE
  102. #undef NYOCI_OBSERVATION_DEFAULT_MAX_AGE
  104. #undef NYOCI_OBSERVATION_KEEPALIVE_INTERVAL
  106. #undef NYOCI_OBSERVER_CON_EVENT_EXPIRATION
  108. #undef NYOCI_OBSERVER_NON_EVENT_EXPIRATION
  110. #undef NYOCI_TRANSACTIONS_USE_BTREE
  112. #undef NYOCI_TRANSACTION_BURST_COUNT
  114. #undef NYOCI_TRANSACTION_POOL_SIZE
  116. #undef NYOCI_USE_CASCADE_COUNT
  118. #undef NYOCI_VARIABLE_MAX_KEY_LENGTH
  120. #undef NYOCI_VARIABLE_MAX_VALUE_LENGTH
  122. #undef NYOCI_INTERNAL_EXTERN
  124. #undef NYOCI_API_EXTERN
  126. #undef NYOCI_DEPRECATED

这个配置文件主要用于配置NYOCI本身。反正看名字大概也能猜出大概每个配置变量是干嘛用的，自己瞅一眼大概设设就是。要设置的话就把#undef改成#define然后设置值，不设置的话基本都会在nyoci-defaults.h文件里有默认值。上面也是我目前根据我的环境设的值。

把这两个配置文件创建好后放在自己的工程目录下，然后扔进工程里就好。

平台移植

libnyoci和(网络栈)平台相关的代码被组织在libnyoci\src\plat-net目录下。目前，只支持posix和uip。

我们要为wiz的io库做一个移植，然后因为我用的RTOS是uCOS-II，所以还会有些uCOS-II的相关代码。首先，把uip那个文件夹复制然后黏贴，改个名字叫wiz。就像这样：
watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70 1watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70 2
然后我直接给出我目前移植好的文件：

nyoci-plat-net.h

  1. #ifndef NYOCI_nyoci_plat_wiz_h
  2. #define NYOCI_nyoci_plat_wiz_h
  4. #if !defined(NYOCI_INCLUDED_FROM_LIBNYOCI_H) && !defined(BUILDING_LIBNYOCI)
  5. #error "Do not include this header directly, include <libnyoci/libnyoci.h> instead"
  6. #endif
  8. NYOCI_BEGIN_C_DECLS
  10. typedef uint8_t nyoci_addr_t[4];
  12. typedef struct {
  14.     nyoci_addr_t nyoci_addr;
  15.     uint16_t nyoci_port;
  16. } nyoci_sockaddr_t;
  18. NYOCI_API_EXTERN uint8_t nyoci_plat_get_socketnumber(nyoci_t self);
  19. NYOCI_API_EXTERN void nyoci_plat_set_socketnumber(nyoci_t self, uint8_t sn);
  21. NYOCI_BEGIN_C_DECLS
  23. #include "nyoci-plat-net-func.h"
  25. #endif

nyoci-plat-net-internal.h

  1. #ifndef NYOCI_nyoci_plat_wiz_internal_h
  2. #define NYOCI_nyoci_plat_wiz_internal_h
  4. #ifndef wiz_is_addr_mcast
  5. #define wiz_is_addr_mcast(addrptr)        (*(const uint8_t*)(addrptr)==224)
  6. #endif
  8. #ifndef wiz_is_addr_unspecified
  9. #define wiz_is_addr_unspecified(addrptr)        (*(addrptr)==0)
  10. #endif
  12. #ifndef wiz_is_addr_loopback
  13. #define wiz_is_addr_loopback(addrptr)        (*(const uint8_t*)(addrptr)==127)
  14. #endif
  16. #define NYOCI_IS_ADDR_MULTICAST wiz_is_addr_mcast
  17. #define NYOCI_IS_ADDR_UNSPECIFIED wiz_is_addr_unspecified
  18. #define NYOCI_IS_ADDR_LOOPBACK wiz_is_addr_loopback
  20. NYOCI_BEGIN_C_DECLS
  22. struct nyoci_plat_s {
  24.     nyoci_sockaddr_t    sockaddr_local;
  25.     nyoci_sockaddr_t    sockaddr_remote;
  26.     nyoci_session_type_t session_type;
  27.   uint8_t socketNum;
  28.     uint8_t outbound_packet_bytes[NYOCI_MAX_PACKET_LENGTH+1];
  29.     uint8_t inbound_packet_bytes[NYOCI_MAX_PACKET_LENGTH+1];
  30. };
  32. NYOCI_END_C_DECLS
  34. #endif

nyoci-plat-net.c

  1. #if HAVE_CONFIG_H
  2. #include <config.h>
  3. #endif
  5. #ifndef VERBOSE_DEBUG
  6. #define VERBOSE_DEBUG 0
  7. #endif
  9. #ifndef DEBUG
  10. #define DEBUG VERBOSE_DEBUG
  11. #endif
  13. #define NYOCI_COAP_MULTICAST_ALLDEVICES_ADDR COAP_MULTICAST_STR_ALLDEVICES
  15. #include <stdio.h>
  16. #include "assert-macros.h"
  18. #include "libnyoci.h"
  19. #include "nyoci-internal.h"
  20. #include "nyoci-logging.h"
  22. #include "lib_lite.h"
  23. #include "Network.h"
  24. #include "ucos_ii.h"
  25. #include "os_cfg.h"
  26. #include "socket.h"
  28. uint8_t nyoci_plat_get_socketnumber(nyoci_t self) {
  30.   return self->plat.socketNum;
  31. };
  33. void nyoci_plat_set_socketnumber(nyoci_t self, uint8_t sn){
  35.   self->plat.socketNum = sn;
  36. }
  38. nyoci_status_t
  39. nyoci_plat_join_standard_groups(nyoci_t self, int interface)
  40. {
  42.     NYOCI_SINGLETON_SELF_HOOK;
  43.     // TODO: Implement me!
  44.     return NYOCI_STATUS_NOT_IMPLEMENTED;
  45. }
  47. nyoci_t
  48. nyoci_plat_init(nyoci_t self) {
  50.     NYOCI_SINGLETON_SELF_HOOK;
  51.     self->plat.socketNum = -1;
  52.     return self;
  53. }
  55. nyoci_status_t
  56. nyoci_plat_bind_to_port(
  57.     nyoci_t self,
  58.     nyoci_session_type_t type,
  59.     uint16_t port
  60. ) {
  62.     nyoci_status_t ret = NYOCI_STATUS_FAILURE;
  63.     NYOCI_SINGLETON_SELF_HOOK;
  65.     switch(type) {
  67.     case NYOCI_SESSION_TYPE_UDP:
  68. //#if NYOCI_DTLS
  69. //    case NYOCI_SESSION_TYPE_DTLS:
  70. //#endif
  71. //#if NYOCI_TCP
  72. //    case NYOCI_SESSION_TYPE_TCP:
  73. //#endif
  74. //#if NYOCI_TLS
  75. //    case NYOCI_SESSION_TYPE_TLS:
  76. //#endif
  77.         break;
  79.     default:
  80.         ret = NYOCI_STATUS_NOT_IMPLEMENTED;
  81.         // Unsupported session type.
  82.         goto bail;
  83.     }
  84.     self->plat.session_type = type;
  85.     self->plat.sockaddr_local.nyoci_port = port;
  86.     ret = NYOCI_STATUS_OK;
  87. bail:
  88.     return ret;
  89. }
  91. void
  92. nyoci_plat_finalize(nyoci_t self) {
  94.     NYOCI_SINGLETON_SELF_HOOK;
  95.     close(self->plat.socketNum);
  96. }
  98. nyoci_status_t
  99. nyoci_plat_set_remote_hostname_and_port(const char* hostname, uint16_t port)
  100. {
  102.     nyoci_status_t ret;
  103.     NYOCI_NON_RECURSIVE nyoci_sockaddr_t saddr;
  105.     DEBUG_PRINTF("Outbound: Dest host [%s]:%d",hostname,port);
  107. #if NYOCI_DTLS
  108.     nyoci_plat_tls_set_remote_hostname(hostname);
  109. #endif
  111.     // Check to see if this host is a group we know about.
  112.     if (strcasecmp(hostname, COAP_MULTICAST_STR_ALLDEVICES) == 0) {
  114.         hostname = NYOCI_COAP_MULTICAST_ALLDEVICES_ADDR;
  115.     }
  117.     ret = nyoci_plat_lookup_hostname(hostname, &saddr, NYOCI_LOOKUP_HOSTNAME_FLAG_DEFAULT);
  118.     require_noerr(ret, bail);
  120.     saddr.nyoci_port = port;
  122.     nyoci_plat_set_remote_sockaddr(&saddr);
  124. bail:
  125.     return ret;
  126. }
  129. void
  130. nyoci_plat_set_remote_sockaddr(const nyoci_sockaddr_t* addr)
  131. {
  133.     nyoci_t const self = nyoci_get_current_instance();
  135.     if (addr) {
  137.         self->plat.sockaddr_remote = *addr;
  138.     } else {
  140.         memset(&self->plat.sockaddr_remote,0,sizeof(self->plat.sockaddr_remote));
  141.     }
  142. }
  144. void
  145. nyoci_plat_set_local_sockaddr(const nyoci_sockaddr_t* addr)
  146. {
  148.     nyoci_t const self = nyoci_get_current_instance();
  150.     if (addr) {
  152.         self->plat.sockaddr_local = *addr;
  153.     } else {
  155.         memset(&self->plat.sockaddr_local,0,sizeof(self->plat.sockaddr_local));
  156.     }
  157. }
  159. void
  160. nyoci_plat_set_session_type(nyoci_session_type_t type)
  161. {
  163.     nyoci_t const self = nyoci_get_current_instance();
  165.     self->plat.session_type = type;
  166. }
  169. const nyoci_sockaddr_t*
  170. nyoci_plat_get_remote_sockaddr(void)
  171. {
  173.     return &nyoci_get_current_instance()->plat.sockaddr_remote;
  174. }
  176. const nyoci_sockaddr_t*
  177. nyoci_plat_get_local_sockaddr(void)
  178. {
  180.     return &nyoci_get_current_instance()->plat.sockaddr_local;
  181. }
  183. nyoci_session_type_t
  184. nyoci_plat_get_session_type(void)
  185. {
  187.     return nyoci_get_current_instance()->plat.session_type;
  188. }
  190. uint16_t
  191. nyoci_plat_get_port(nyoci_t self) {
  193.     NYOCI_SINGLETON_SELF_HOOK;
  194.     return self->plat.sockaddr_local.nyoci_port;
  195. }
  197. nyoci_status_t
  198. nyoci_plat_outbound_start(nyoci_t self, uint8_t** data_ptr, coap_size_t *data_len)
  199. {
  201.     NYOCI_SINGLETON_SELF_HOOK;
  202.     if (data_ptr) {
  204.         *data_ptr = (uint8_t*)self->plat.outbound_packet_bytes;
  205.     }
  206.     if (data_len) {
  208.         *data_len = sizeof(self->plat.outbound_packet_bytes);
  209.     }
  210.     self->outbound.packet = (struct coap_header_s*)self->plat.outbound_packet_bytes;
  211.     return NYOCI_STATUS_OK;
  212. }
  214. // 
  215. nyoci_status_t
  216. nyoci_plat_outbound_finish(nyoci_t self,const uint8_t* data_ptr, coap_size_t data_len, int flags)
  217. {
  219.     nyoci_status_t ret = NYOCI_STATUS_FAILURE;
  220.     int32_t sent_bytes = -1;
  221.     int sn;
  222.     NYOCI_SINGLETON_SELF_HOOK;
  223. #if NYOCI_DTLS
  224.     if (nyoci_plat_get_session_type() == NYOCI_SESSION_TYPE_DTLS) {
  226.         ret = nyoci_plat_tls_outbound_packet_process(self, data_ptr, data_len);
  227.     } else
  228. #endif
  229.     if (nyoci_plat_get_session_type() == NYOCI_SESSION_TYPE_UDP) {
  231.         sn = nyoci_get_current_instance()->plat.socketNum;
  233.         assert(sn < 8);
  235.         require(data_len > 0, bail);
  237. #if VERBOSE_DEBUG
  238.         {
  240.             char addr_str[30] = "???";
  241.             uint16_t port = nyoci_plat_get_remote_sockaddr()->nyoci_port;
  242.             IPToStr(nyoci_plat_get_remote_sockaddr()->nyoci_addr,addr_str);
  243.             DEBUG_PRINTF("nyoci(%p): Outbound packet to [%s]:%u", self,addr_str,port);
  244.             coap_dump_header(
  245.                 NYOCI_DEBUG_OUT_FILE,
  246.                 "Outbound:\t",
  247.                 (struct coap_header_s*)data_ptr,
  248.                 (coap_size_t)data_len
  249.             );
  250.         }
  251. #endif
  253.         sent_bytes = sendto(
  254.             sn,
  255.             data_ptr,
  256.             data_len,
  257.             self->plat.sockaddr_remote.nyoci_addr,
  258.             self->plat.sockaddr_remote.nyoci_port
  259.         );
  261.         require_action_string(
  262.             (sent_bytes >= 0),
  263.             bail, ret = NYOCI_STATUS_ERRNO, "sendto() fail"
  264.         );
  266.         require_action_string(
  267.             (sent_bytes == data_len),
  268.             bail, ret = NYOCI_STATUS_FAILURE, "sendto() returned less than len"
  269.         );
  271.         ret = NYOCI_STATUS_OK;
  273.     } else {
  275.         ret = NYOCI_STATUS_NOT_IMPLEMENTED;
  276.     }
  277. bail:
  278.     return ret;
  279. }
  281. // MARK: -
  283. nyoci_status_t
  284. nyoci_plat_wait(
  285.     nyoci_t self, nyoci_cms_t cms
  286. ) {
  288. #ifdef OS_uCOS_II_H
  289.   OSTimeDly(cms * OS_TICKS_PER_SEC / MSEC_PER_SEC);
  290.     return NYOCI_STATUS_OK;
  291. #else
  292.   return NYOCI_STATUS_NOT_IMPLEMENTED;
  293. #endif
  294. }
  296. nyoci_status_t
  297. nyoci_plat_process(nyoci_t self) {
  299.     uint8_t sn;
  300.     int32_t bytesCnt;
  301.     nyoci_status_t ret = NYOCI_STATUS_FAILURE;
  302.     NYOCI_SINGLETON_SELF_HOOK;
  303.     require_action(self != NULL, bail, ret = NYOCI_STATUS_INVALID_ARGUMENT);
  304.     sn = self->plat.socketNum;
  305.     if(!Network_hasReady()){
  307. #ifdef OS_uCOS_II_H
  308.       OSTimeDlyHMSM(0, 0, 3, 0);
  309. #endif
  310.         goto bail;
  311.     }
  313.     require(sn < 8,bail);
  315.     if(getSn_SR(sn) != SOCK_UDP){
  317.       if(socket(sn,Sn_MR_UDP,self->plat.sockaddr_local.nyoci_port,0x00) != sn){
  319.         DEBUG_PRINTF("nyoci init fail");
  320. #ifdef OS_uCOS_II_H
  321.         OSTimeDlyHMSM(0, 0, 3, 0);
  322. #endif
  323.         goto bail;
  324.       }else{
  326.         DEBUG_PRINTF("nyoci process on socket %d", (int)sn);
  327.       }
  328.     }
  329.     if(getSn_RX_RSR(sn)>0){
  331.       bytesCnt = recvfrom(sn, self->plat.inbound_packet_bytes, sizeof(self->plat.inbound_packet_bytes), 
  332.       self->plat.sockaddr_remote.nyoci_addr, &self->plat.sockaddr_remote.nyoci_port);
  333. #if VERBOSE_DEBUG
  334.         {
  336.             char addr_str[30] = "???";
  337.             uint16_t port = self->plat.sockaddr_remote.nyoci_port;
  338.             IPToStr(self->plat.sockaddr_remote.nyoci_addr,addr_str);
  339.             DEBUG_PRINTF("nyoci received data from %s:%u  len:%d", addr_str, port, (int)bytesCnt);
  340.         }
  341. #endif
  342.     require(bytesCnt >= 0, bail);
  343.       nyoci_plat_set_session_type(NYOCI_SESSION_TYPE_UDP);
  344.       nyoci_inbound_packet_process(self, self->plat.inbound_packet_bytes, bytesCnt, 0);
  345.     }
  346.     nyoci_handle_timers(self);
  347.     ret = NYOCI_STATUS_OK;
  349. bail:
  350.     nyoci_set_current_instance(NULL);
  351.     self->is_responding = false;
  353.     return ret;
  354. }
  356. nyoci_status_t
  357. nyoci_plat_lookup_hostname(const char* hostname, nyoci_sockaddr_t* saddr, int flags)
  358. {
  360. /*    nyoci_status_t ret;
  361.     memset(saddr, 0, sizeof(*saddr));
  363.     ret = StrToIP(hostname,    (uint8_t *)&saddr->nyoci_addr) ? NYOCI_STATUS_OK : NYOCI_STATUS_HOST_LOOKUP_FAILURE;
  365. #if NYOCI_CONF_USE_DNS
  366. #if CONTIKI
  367.     if(ret) {
  368.         NYOCI_NON_RECURSIVE uip_ipaddr_t *temp = NULL;
  369.         switch(resolv_lookup(hostname,&temp)) {
  370.             case RESOLV_STATUS_CACHED:
  371.                 memcpy(&saddr->nyoci_addr, temp, sizeof(uip_ipaddr_t));
  372.                 ret = NYOCI_STATUS_OK;
  373.                 break;
  374.             case RESOLV_STATUS_UNCACHED:
  375.             case RESOLV_STATUS_EXPIRED:
  376.                 resolv_query(hostname);
  377.             case RESOLV_STATUS_RESOLVING:
  378.                 ret = NYOCI_STATUS_WAIT_FOR_DNS;
  379.                 break;
  380.             default:
  381.             case RESOLV_STATUS_ERROR:
  382.             case RESOLV_STATUS_NOT_FOUND:
  383.                 ret = NYOCI_STATUS_HOST_LOOKUP_FAILURE;
  384.                 break;
  385.         }
  386.     }
  387. #else // CONTIKI
  388. #warning NYOCI_CONF_USE_DNS was set, but no DNS lookup mechamism is known!
  389. #endif
  390. #endif // NYOCI_CONF_USE_DNS
  392.     require_noerr(ret,bail);
  394. bail:
  395.     return ret; //*/
  397.     // TODO: Implement me!
  398.     return NYOCI_STATUS_NOT_IMPLEMENTED;
  399. }
  401. #if defined(CONTIKI)
  402. nyoci_timestamp_t
  403. nyoci_plat_cms_to_timestamp(
  404.     nyoci_cms_t cms
  405. ) {
  407.     return clock_time() + cms*CLOCK_SECOND/MSEC_PER_SEC;
  408. }
  409. nyoci_cms_t
  410. nyoci_plat_timestamp_diff(nyoci_timestamp_t lhs, nyoci_timestamp_t rhs) {
  412.     return (lhs - rhs)*MSEC_PER_SEC/CLOCK_SECOND;
  413. }
  414. nyoci_cms_t
  415. nyoci_plat_timestamp_to_cms(nyoci_timestamp_t ts) {
  417.     return nyoci_plat_timestamp_diff(ts, clock_time());
  418. }
  420. #elif defined(OS_uCOS_II_H)
  421. nyoci_timestamp_t
  422. nyoci_plat_cms_to_timestamp(
  423.     nyoci_cms_t cms
  424. ) {
  426.     return OSTimeGet() + cms * ((double)OS_TICKS_PER_SEC / MSEC_PER_SEC);
  427. }
  428. nyoci_cms_t
  429. nyoci_plat_timestamp_diff(nyoci_timestamp_t lhs, nyoci_timestamp_t rhs) {
  431.     return (lhs - rhs) * ((double)MSEC_PER_SEC / OS_TICKS_PER_SEC);
  432. }
  433. nyoci_cms_t
  434. nyoci_plat_timestamp_to_cms(nyoci_timestamp_t ts) {
  436.     return nyoci_plat_timestamp_diff(ts, OSTimeGet());
  437. }
  438. #endif

简要说明

这里大概说一下一些移植会出问题的地方。

首先看一下include
#include “lib_lite.h”
这个文件是我自己加的，用到的里头的函数就一个IPtoStr，在打印调试信息时用到的，不是很重要，自己可以根据需要实现一个或直接不管。
#include “Network.h”
这个也是我自己写的基于W5500的网络管理模块的头文件，主要就是提供nyoci_plat_process这个函数里头的Network_hasReady这一个判断，自己根据需要进行修改即可。
#include “os_cfg.h”
这个文件是uCOS-II的配置文件名，用于引入uCOS-II接口的。

nyoci_plat_set_remote_hostname_and_port和nyoci_plat_lookup_hostname顾名思义，用于通过字符串设置和DNS查询对方主机。这个不是必要的接口，我也没有实现它，主要是io库也没有提供好用的DNS接口，但我保留了实现的框架，如有需要可以照着实现它。

这里头最容易让人困惑的是时间戳里的cms到底是什么鬼。经过我辛苦的钻研，得出结论：这个变量代表的意思是相对时间，单位ms。
nyoci中同时使用平台特定的时间戳和单位为ms的相对时间戳。
nyoci_plat_cms_to_timestamp
就是要你返回相对当前时间cms毫秒(正代表未来，负代表过去)对应的平台时间戳。
nyoci_plat_timestamp_diff
返回两个平台时间戳之间差多少ms。
nyoci_plat_timestamp_to_cms
返回给定平台时间戳与当前时间差多少ms。
nyoci_plat_wait
也就是sleep多少毫秒的意思。

上面我加进去了在uCOS-II下的实现，如果你用的是其他操作系统的话则根据具体OS进行修改。

使用示例

这里只简单示例下这个移植后的代码的其中一种用法，其他用法请参照examples里的几个示例。

示例代码

以下是Coap服务器任务/线程的示例

  1. ……
  2. #include <libnyoci/libnyoci.h>
  3. #include <libnyociextra/nyoci-node-router.h>
  4. ……
  5. #define OBSERVABLE_KEY  35
  6. static nyoci_t CoapInstance = NULL;
  7. static struct nyoci_observable_s observable = {
  8.      0 };
  9. static char sensordata[] = "30.32Cel";
  10. ……
  11. static nyoci_status_t
  12. request_handler(void* context)
  13. {
  15.   nyoci_observable_t observable = context;
  16.   const uint8_t* opt;
  17.   coap_size_t len;
  19.   if (!nyoci_inbound_is_fake()) {
  21.     printf("Got a request!\n");
  22.   }
  24.   // Only handle GET requests for now.
  25.   if (nyoci_inbound_get_code() != COAP_METHOD_GET) {
  27.     return NYOCI_STATUS_NOT_IMPLEMENTED;
  28.   }
  30.   // Begin describing the response.
  31.   nyoci_outbound_begin_response(COAP_RESULT_205_CONTENT);
  33.   // This is the key line to making a resource observable.
  34.   // It must be placed after nyoci_outbound_begin_response()
  35.   // and before nyoci_outbound_send(). When this resource changes,
  36.   // a simple call to nyoci_observable_trigger() with the given
  37.   // nyoci_observable object and observable key will trigger the
  38.   // observers to be updated. Really --- that's it...!
  39.   nyoci_observable_update(observable, OBSERVABLE_KEY);
  41.   nyoci_outbound_add_option_uint(
  42.     COAP_OPTION_CONTENT_TYPE,
  43.     COAP_CONTENT_TYPE_TEXT_PLAIN
  44.   );
  46.   nyoci_outbound_append_content(sensordata, sizeof(sensordata) - 1);
  48.   return nyoci_outbound_send();
  49. }
  51. static void CoapTask(void *p_arg){
  53.   nyoci_node_t root_node, hello_node;
  55.   NYOCI_LIBRARY_VERSION_CHECK();
  57.   while(!CoapInstance){
  59.     CoapInstance = nyoci_create();
  60.     if (!CoapInstance) {
  62.       printf("Unable to create LibNyoci instance");
  63.       OSTimeDlyHMSM(0, 0, 5, 0);
  64.     }
  65.   }
  67.   nyoci_plat_set_socketnumber(CoapInstance, COAP_SOCKET);
  68.   nyoci_plat_bind_to_port(CoapInstance, NYOCI_SESSION_TYPE_UDP, COAP_DEFAULT_PORT);
  70.   root_node = nyoci_node_init(NULL, NULL, NULL);
  72.   nyoci_set_default_request_handler(
  73.     CoapInstance,
  74.     &nyoci_node_router_handler,
  75.     (void*)root_node
  76.   );
  78.   hello_node = nyoci_node_init(NULL,root_node,"sData");
  79.   hello_node->request_handler = &request_handler;
  80.   hello_node->context = &observable;
  82.   printf("Listening on port %d\n", nyoci_plat_get_port(CoapInstance));
  84.   while (1) {
  86.     MyOS_DlyHMSM(0, 0, 0, 30);
  87.     //nyoci_plat_wait(CoapInstance, INTERVAL_PER_TICK);
  88.     nyoci_plat_process(CoapInstance);
  89.   }
  91.   nyoci_release(CoapInstance);
  92. }

如果要触发publish的话，则在某处调用nyoci_observable_trigger：

  1. if(++sensordata[1] > '9')
  2.   sensordata[1] = '0';
  3. (void)printf("%d observers registered\n", nyoci_observable_observer_count(&observable, OBSERVABLE_KEY));
  4. nyoci_observable_trigger(&observable, OBSERVABLE_KEY ,0);

简要说明

由于我这个示例使用的是多实例，所以一开始要create一个nyoci实例。
然后通过nyoci_plat_set_socketnumber设置其socket号，对应W5500的socket号。
然后用nyoci_plat_bind_to_port绑定这个Coap服务的端口为默认端口号，使用UDP，这个移植也只实现了UDP。

这个代码里头使用了router，这种方式使用链表(可选B树)来管理资源，收到请求时会在所有注册的资源中寻找匹配的资源，如果存在，则调用对应的request_handler，否则404。这里我们添加了一个叫sData的资源，又给他设置了一个observable使其可以被订阅。

然后就开始不断地用nyoci_plat_process驱动服务器实例的运行了，这个方法的含义是进行一次无阻塞的处理。

还有些其他方式，请自行探索，或者等我研究透了再出篇博文来讲。

测试

这里我通过Chrome浏览器插件Copper来进行测试。
http://element-ui.cn/news\_show\_33612.shtml
我目前配置的设备主机名为SIA5300.local，所以资源的地址为：
SIA5300.local/sData
watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70 3然后我们使用Get方法获取资源：
watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70 4获取资源成功。
然后来试一下Observe即发布订阅方式：
watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70 5watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbl9zdHJvbmc_size_16_color_FFFFFF_t_70 6主动推送消息成功。

总结

这篇文章讲了移植libnyoci到wiz io库以实现一个简单的UDP Coap服务器所需要的主要事项，但是实际移植的时候由于开发环境不同等原因估摸还是会遇到很多问题，语法不支持、缺少库什么的一堆问题。如果实在搞不定，下面留言。

发表评论

表情：
评论列表 （有 0 条评论，695人围观）

还没有评论，来说两句吧...

相关阅读