分享

ONENET 中移物联网平台 TCP透传功能初探

 书虫2045 2017-07-08
文章转自官方论坛
近期OneNET上线了TCP透传功能,该功能旨在尽量弱化终端测软件为了适配协议而做的修改,将协议的解析功能放在了平台测,为的是更加方便用户的终端(特别是DTU)的接入。下面我们将以网络助手为例,做一个简单的接入示例,该示例内容如下:

1、模拟终端(TCP网络助手)能够连接上平台;
2、使用脚本实现周期性下发数据
3、使用脚本实现,平台接收到模拟终端上传数据,即刻回复消息
4、使用脚本实现,平台将接收到的二进制数据字符串的形式保存,并能够在平台数据流中查看;

本示例中用到的脚本如下:文件下载: sample-save-str.rar (3.21 KB, 下载次数: 11108)

  1. -----------------------------------------------------------------------
  2. -- 使用说明:                                                        --
  3. -- V1.3                                                              --
  4. -- 用户需要自行完成一下2个函数的实现                                 --
  5. -- 1、定时下发数据任务初始化函数:device_timer_init(dev)【可选】     --
  6. -- 2、对设备上传数据进行解析(包括心跳等):device_data_analyze(dev) --
  7. -----------------------------------------------------------------------

  8. -------------------------------------------------------------------------------
  9. -- 注册C函数                                                                 --
  10. -- u2f 将32位整型内存数据转换为浮点数(不同于值转换)                        --
  11. -- 类似C代码 *(float*)(&u)                                                   --
  12. -- function u2f(u)                                                           --
  13. -- @param   u   number   整数值                                              --
  14. -- @return  成功返回浮点数值,否则返回nil                                    --
  15. -- @example local u = 123                                                    --
  16. --          local f = u2f( 123 )                                             --
  17. --                                                                           --
  18. -- time 获取时间戳,距离(00:00:00 UTC, January 1, 1970)的毫秒数            --
  19. -- function time()                                                           --
  20. -- @return  返回当前时间戳                                                   --
  21. -- @example local t = time()                                                 --
  22. --                                                                           --
  23. -- year 获取年(year-1900)                                                  --
  24. -- function year(t)                                                          --
  25. -- @param   t   number   时间戳,距离(00:00:00 UTC, January 1, 1970)的秒数 --
  26. -- @return  返回年                                                           --
  27. -- @example local y = year( t )                                              --
  28. --                                                                           --
  29. -- month 获取月(0-11)                                                      --
  30. -- function month(t)                                                         --
  31. -- @param   t   number   时间戳,距离(00:00:00 UTC, January 1, 1970)的秒数 --
  32. -- @return  返回月                                                           --
  33. -- @example local m = month( t )                                             --
  34. --                                                                           --
  35. -- day 获取日(1-31)                                                        --
  36. -- function day(t)                                                           --
  37. -- @param   t   number   时间戳,距离(00:00:00 UTC, January 1, 1970)的秒数 --
  38. -- @return  返回月                                                           --
  39. -- @example local d = day( t )                                               --
  40. --                                                                           --
  41. -- hour 获取时(0-23)                                                       --
  42. -- function hour(t)                                                          --
  43. -- @param   t   number   时间戳,距离(00:00:00 UTC, January 1, 1970)的秒数 --
  44. -- @return  返回时                                                           --
  45. -- @example local h = hour( t )                                              --
  46. --                                                                           --
  47. -- minute 获取分(0-59)                                                     --
  48. -- function minute(t)                                                        --
  49. -- @param   t   number   时间戳,距离(00:00:00 UTC, January 1, 1970)的秒数 --
  50. -- @return  返回分                                                           --
  51. -- @example local m = minute( t )                                            --
  52. --                                                                           --
  53. -- second 获取秒(0-59)                                                     --
  54. -- function second(t)                                                        --
  55. -- @param   t   number   时间戳,距离(00:00:00 UTC, January 1, 1970)的秒数 --
  56. -- @return  返回秒                                                           --
  57. -- @example local m = second( t )                                            --
  58. -------------------------------------------------------------------------------

  59. --------------------------------------------------------
  60. -- 将bytes string转换hex string                       --
  61. -- @param   s   string   bytes string                 --
  62. -- @return  返回hex string,类似"0A0B0C0D..."         --
  63. -- @example local hex = to_hex("\2\2\0\150\0\37\206") --
  64. --------------------------------------------------------
  65. function to_hex(s)
  66.         local i
  67.         local t

  68.         t={s:byte(1,s:len())}
  69.         for i=1,#t do
  70.                 t[i]=string.format('%02X',t[i])
  71.         end

  72.         return table.concat(t)
  73. end

  74. -----------------------------------------------
  75. -- 将object序列化成字符串                    --
  76. -- @param   o   boolean|number|string|table  --
  77. -- @return  返回序列化string                 --
  78. -- @example local str = to_str({x=100})      --
  79. -----------------------------------------------
  80. function to_str(o)
  81.         local i=1
  82.         local t={}
  83.         local f

  84.         f=function(x)
  85.                 local y=type(x)
  86.                 if y=="number" then
  87.                         t[i]=x
  88.                         i=i+1
  89.                 elseif y=="boolean" then
  90.                         t[i]=tostring(x)
  91.                         i=i+1
  92.                 elseif y=="string" then
  93.                         t[i]="\""
  94.                         t[i+1]=x
  95.                         t[i+2]="\""
  96.                         i=i+3
  97.                 elseif y=="table" then
  98.                         t[i]="{"
  99.                         i=i+1

  100.                         local z=true
  101.                         for k,v in pairs(x) do
  102.                                 if z then
  103.                                         z=false
  104.                                         t[i]="\""
  105.                                         t[i+1]=k
  106.                                         t[i+2]="\""
  107.                                         t[i+3]=":"
  108.                                         i=i+4
  109.                                         f(v)
  110.                                 else
  111.                                         t[i]=","
  112.                                         t[i+1]="\""
  113.                                         t[i+2]=k
  114.                                         t[i+3]="\""
  115.                                         t[i+4]=":"
  116.                                         i=i+5
  117.                                         f(v)
  118.                                 end
  119.                         end

  120.                         t[i]="}"
  121.                         i=i+1
  122.                 else
  123.                         t[i]="nil"
  124.                         i=i+1
  125.                 end
  126.         end
  127.         f(o)

  128.         return table.concat(t)
  129. end

  130. ----------------------------------------------------------------------------------------------------------
  131. -- 添加值数据点到table中                                                                                --
  132. -- @param   t   table                                                                                   --
  133. --          i   string                      数据流或数据流模板名称                                      --
  134. --          a   number                      毫秒级时间戳,距离(00:00:00 UTC, January 1, 1970)的毫秒; --
  135. --                                          如果值为0,表示使用当前时间                                 --
  136. --          v   boolean|number|string|table 布尔值、数值、字符串、json                                  --
  137. --          c   string                      用于标识数据点归属(设备AuthCode,可选)                       --
  138. --                                          如果值为“”或nil,表示数据点归属建立TCP连接的设备            --
  139. -- @return  成功返回true,否则返回false                                                                 --
  140. -- @example local ok = add_val(t,"dsname",0,100)                                                        --
  141. ----------------------------------------------------------------------------------------------------------
  142. function add_val(t, i, a, v, c)
  143.         if type(t)~="table" then
  144.                 return false
  145.         elseif type(i)~="string" then
  146.                 return false
  147.         elseif type(a)~="number" then
  148.                 return false
  149.         else
  150.                 local o = type(v)
  151.                 if o~="boolean" and o~="number" and o~="string" and o~="table" then
  152.                         return false
  153.                 end

  154.                 local n = {i=i,v=to_hex(v)}
  155. --                n.v = n.v .. "("..o..")"
  156.                 if a~=0 and a~=nil then
  157.                         n["a"]=a
  158.                 end
  159.                 if c~=nil then
  160.                         n["c"]=c
  161.                 end

  162.                 -- list push_back --
  163.                 if t.h==nil then
  164.                         t.h={nil,n}
  165.                         t.t=t.h
  166.                 else
  167.                         t.t[1]={nil,n}
  168.                         t.t=t.t[1]
  169.                 end
  170.         end

  171.         return true
  172. end

  173. --------------------------------------------------------------
  174. -- 将table序列化成json字符串                                --
  175. -- @param   t   table   通过add_val、add_bin构建起来的table --
  176. -- @return  返回序列化json字符串                            --
  177. -- @example local json = to_json(t)                         --
  178. --------------------------------------------------------------
  179. function to_json(t)
  180.         local i=1
  181.         local o={}
  182.         local n

  183.         o[i]="["
  184.         i=i+1
  185.         n=t.h
  186.         while n~=nil do
  187.                 if n[2]~=nil then
  188.                         o[i]=to_str(n[2])
  189.                         i=i+1
  190.                 end

  191.                 n=n[1]
  192.                 if n~=nil then
  193.                         o[i]=","
  194.                         i=i+1
  195.                 end
  196.         end
  197.         o[i]="]"

  198.         return table.concat(o)
  199. end

  200. ------------------------------------
  201. -- begin-添加用户自定义值或函数等 --

  202. -- end-添加用户自定义值或函数等   --
  203. ------------------------------------

  204. ------------------------------------------------------------------------------------------
  205. -- 设置定时下发设备的数据(可选)                                                       --
  206. -- @param  dev    user_data   设备管理器                                                --
  207. -- @return 无                                                                           --
  208. -- @notice 此函数为回调函数,不可在脚本内调用                                           --
  209. -- @readme dev提供一下几个函数:                                                        --
  210. --         dev:add(interval,name,data)添加定时下发数据                                  --
  211. --           @param   interval   number   数据下发的时间间隔(秒)                      --
  212. --                    name       string   名称(须保证唯一性)                          --
  213. --                    data       string   数据(二进制数据),使用lua转义字符串         --
  214. --           @return  成功返回true,否则返回false                                       --
  215. --           @notice  定时数据下发的平均频率不超过1,及1/interval_1+...+1/interval_n<=1 --
  216. --           @example local ok = dev:add(10,"test","\1\1\0\150\0\37\253\29")            --
  217. --         dev:timeout(sec)设置下发数据的设备响应超时时间(秒)                         --
  218. --           @param   sec        int      响应超时时间(秒)                            --
  219. --                                        如果值为0,表示不检测设备响应超时             --
  220. --           @return  无                                                                --
  221. --           @example dev:timeout(3)                                                    --
  222. --         dev:response()设备响应成功                                                   --
  223. --           @param   无                                                                --
  224. --           @return  无                                                                --
  225. --           @example dev:response()                                                    --
  226. --         dev:send(data)下发数据到设备                                                 --
  227. --           @param   data   string   数据(二进制数据),使用lua转义字符串             --
  228. --           @return  无                                                                --
  229. --           @example dev:send("\2\2\0\150\0\37\206\89")                                --
  230. ------------------------------------------------------------------------------------------
  231. function device_timer_init(dev)
  232.         -- 添加用户自定义代码 --
  233.         -- 例如: --
  234.         dev:timeout(3)
  235.         dev:add(10,"dev1","hello")    --每10秒下发一包数据,内容为hello
  236. end

  237. -----------------------------------------------------------------------------------------------------------
  238. -- 解析设备上传数据                                                                                      --
  239. -- @param  dev    user_data   设备管理器                                                                 --
  240. -- @return size表示已解析设备上传数据的字节数,json表示解析后的数据点集合,格式如下:                    --
  241. --         [                                                                                             --
  242. --           {                                                                                           --
  243. --             "i" : "dsname1",          // 数据流或数据流模板名称1                                      --
  244. --             "a" : 1234567890,         // 毫秒级时间戳,距离(00:00:00 UTC, January 1, 1970)的毫秒    --
  245. --                                       // 如果值为0,表示使用当前时间                                  --
  246. --             "v" : 123 | "123" | {...} // 布尔值、数值、字符串、json                                   --
  247. --             "b" : "0A0B0C0D..."       // 二进制数据(16进制字符串),与v互斥,不同时存在              --
  248. --             "d" : xxx | "xxx" | {...} // 用于描述b(可选);布尔值、数值、字符串、json                --
  249. --             "c" : "authcode1"         // 用于标识数据点归属(设备AuthCode,可选)                        --
  250. --                                       // 如果为“”或不存在,表示数据点归属建立TCP连接的设备            --
  251. --           }                                                                                           --
  252. --           ...                                                                                         --
  253. --           {                                                                                           --
  254. --             "i" : "dsnamen",          // 数据流或数据流模板名称1                                      --
  255. --             "a" : 1234567890,         // 毫秒级时间戳,距离(00:00:00 UTC, January 1, 1970)的毫秒    --
  256. --                                       // 如果值为0,表示使用当前时间                                  --
  257. --             "v" : 123 | "123" | {...} // 布尔值、数值、字符串、json                                   --
  258. --             "b" : "0A0B0C0D..."       // 二进制数据(16进制字符串),与v互斥,不同时存在              --
  259. --             "d" : xxx | "xxx" | {...} // 用于描述b(可选);布尔值、数值、字符串、json                --
  260. --             "c" : "authcoden"         // 用于标识数据点归属(设备AuthCode,可选)                        --
  261. --                                       // 如果为“”或不存在,表示数据点归属建立TCP连接的设备            --
  262. --           }                                                                                           --
  263. --         ]                                                                                             --
  264. -- @notice 此函数为回调函数,不可在脚本内调用                                                            --
  265. -- @readme dev提供一下几个函数:                                                                         --
  266. --         dev:add(interval,name,data)添加定时下发数据                                                   --
  267. --           @param   interval number   数据下发的时间间隔(秒)                                         --
  268. --                    name     string   名称(须保证唯一性)                                             --
  269. --                    data     string   数据(二进制数据),使用lua转义字符串                            --
  270. --           @return  成功返回true,否则返回false                                                        --
  271. --           @notice  定时数据下发的平均频率不超过1,及1/interval_1+...+1/interval_n<=1                  --
  272. --           @example local ok = dev:add(10,"test","\1\1\0\150\0\37\253\29")                             --
  273. --         dev:timeout(sec)设置下发数据的设备响应超时时间(秒)                                          --
  274. --           @param   sec      int      响应超时时间(秒)                                               --
  275. --                                      如果值为0,表示不检测设备响应超时                                --
  276. --           @return  无                                                                                 --
  277. --           @example dev:timeout(3)                                                                     --
  278. --         dev:response()设备响应成功                                                                    --
  279. --           @param   无                                                                                 --
  280. --           @return  无                                                                                 --
  281. --           @example dev:response()                                                                     --
  282. --         dev:send(data)下发数据到设备                                                                  --
  283. --           @param   data   string   数据(二进制数据),使用lua转义字符串                              --
  284. --           @return  无                                                                                 --
  285. --           @example dev:send("\2\2\0\150\0\37\206\89")                                                 --
  286. --         dev:size()获取设备数据大小(字节数)                                                          --
  287. --           @param   无                                                                                 --
  288. --           @return  返回设备数据大小(字节数)                                                         --
  289. --           @example local sz = dev:size()                                                              --
  290. --         dev:byte(pos)获取pos对应位置的设备数据(字节)                                                --
  291. --           @param   pos   number   指定的获取位置,取值范围[1,dev:size()+1)                            --
  292. --           @return  成功返回设备数据(int),否则返回nil                                               --
  293. --           @example local data = dev:byte(1)                                                           --
  294. --         dev:bytes(pos,count)获取从pos开始,count个设备数据                                            --
  295. --           @param   pos   number   指定的获取起始位置,取值范围[1,dev:size()+1)                        --
  296. --                    count number   指定的获取数据总数,取值范围[0,dev:size()+1-pos]                    --
  297. --           @return  成功返回设备数据(string),否则返回nil                                            --
  298. --           @example local datas = dev:bytes(1,dev:size())                                              --
  299. -----------------------------------------------------------------------------------------------------------
  300. function device_data_analyze(dev)
  301.         local t = {}
  302.         local a = 0

  303.         -- 添加用户自定义代码 --
  304.         -- 例如: --
  305.         local s = dev:size()    --获取上行数据长度
  306.         add_val(t,"ds_test",0,dev:bytes(1,s))

  307.         dev:response()
  308.         dev:send("received")  --发送应答

  309.         -- return $1,$2 --
  310.         -- 例如: --
  311.         return s,to_json(t)    --保存该数据
  312. end
复制代码

其中

device_data_analyze(dev)  为终端上行数据解析函数每一包数据都会经过其处理
device_timer_init(dev)  为定时器初始化函数,用于指定周期性的数据下发操作;


STEP 1
创建产品,创建设备(略)



STEP 2
上传Lua脚本


这里需要注意的是,
脚本名称很重要,在设备登陆的时候需要用做参数




STEP 3

设备登陆
设备登陆报文是在建立TCP连接之后,用于告知OneNET平台,该终端/DTU对应的是平台上的哪一个设备,数据用何种方式进行解析;
格式为  *PID#AuthCode#ParserName*  
其中:
PID  为    产品ID
AuthCode 为  鉴权信息(创建设备的时候所指定)
ParserName  为  脚本名称(上传Lua脚本的时候所指定)


本例中
PID为83901



AuthCode为0001



脚本名称为sample(见STEP 2)



故登陆报文为
*83901#0001#sample*


建立TCP连接(地址为 183.230.40.40 :1811),并发送登陆报文,可以查看到设备的在线状态:



STEP 4 观察平台周期性下发数据
在本例中,脚本中的device_timer_init(dev)函数如下:
  1. function device_timer_init(dev)
  2.         -- 添加用户自定义代码 --
  3.         -- 例如: --
  4.         dev:timeout(3)
  5.         dev:add(10,"dev1","hello")    --每10秒下发一包数据,内容为hello
  6. end

复制代码

其中   dev:add(10,"dev1","hello")    定义了每10秒下发一包数据,内容为hello
所以在发送连接报文之后,每10秒中会收到平台下发的消息,hello

hello.gif (0 Bytes, 下载次数: 1824)

下载附件

2017-4-7 16:42 上传




STEP 5 上传16进制数据,观察平台应答以及平台数据



在本例中,脚本中的device_timer_init(dev)函数如下:
  1. function device_data_analyze(dev)
  2.         local t = {}
  3.         local a = 0

  4.         -- 添加用户自定义代码 --
  5.         -- 例如: --
  6.         local s = dev:size()    --获取上行数据长度
  7.         add_val(t,"ds_test",0,dev:bytes(1,s))    --ds_test 为自定义数据流名称

  8.         dev:response()
  9.         dev:send("received")  --发送应答

  10.         -- return $1,$2 --
  11.         -- 例如: --
  12.         return s,to_json(t)    --保存该数据
  13. end

复制代码

其中   dev:send("received")  决定了,每收到一包上行数据,平台会响应一包应答,received
所以在发送连接报文之后,每发送一包数据,会收到平台的received作为应答


另外,模拟终端上传16进制的  0xa1 0xb2 0xc3 0xd4 ,被脚本转化为字符串形式的"A1B2C3D4"存储在ds_test 数据流中

使用有人DTU,利用TCP透传协议连接OneNET并上传数据的实例


(完)

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多