【AllJoyn专题】基于AllJoyn和Yeelink的传感器数据上传与指令下行的研究

笔者接触高通物联网框架AllJoyn不太久,但确是被深深地吸引了。在我看来,促进我深入学习的原因有三点:一、AllJoyn开源,对开源的软硬件总会有种莫名的喜爱,尽管也许不会都深入下去;二、顺应潮流,物联网虽远未普及,但已是大势所趋,高通公司在领域布局,致力于打造舒适高效的智能家居场景,推出AllJoyn软件框架,适应了发展趋势;三、文档丰富,开源软件的使用,特别是框架,若没有文档相助,相信没有多少开发者愿意尝试,AllJoyn在这方面做得不错,日后还需做得更好。当然啦,也有些额外原因,包括高通的大力推广,个人对C++的喜爱等等。

最近,笔者根据之前所学,利用AllJoyn和国内受人欢迎的Yeelink物联网平台完成了一个简单的Web of Things的小系统。我们知道随着因特网的蓬勃发展和物联网在全球的兴起,一个新的运行模式也在悄然诞生,即Web of Things,简称为WoT。它可被理解为是IoT的一部分,集中实现以Web方式来控制和管理物联网中的资源,包括各种网关及网关上的传感器,其主旨是提倡通过REST Web
API的形式直接对智能终端与网关上的资源进行开放,用户可以通过访问互联网的方式来访问终端的数据资源,这就是典型的互联网模式。而Yeelink平台恰好能提供这样的功能需求,所以我选择了它作为应用层;而在网络层可以细分为两种,一种是公网传输,即借助目前成熟的互联网,二种是局域网传输,AllJoyn与生俱来的局域传输能力就在这里得到了体现;最下面为感知层,即Arduino终端作为网关接各种感知设备。结构示意图如图0所示:

目前系统实现的两大功能如下:

1、上传温度传感器采集的温度值至Yeelink平台,在平台上以易读方式显示;

2、通过点击平台上的虚拟开关向感知层的Arduino终端发出命令,控制LED灯的亮灭;

1 工具和开发环境

AllJoyn

关于AllJoyn的介绍,我相信维基百科和官方文档会比我说得详细得多,可参考后文的链接。按照我目前的理解就是用它可以实现邻近设备间的互联互通,不管是什么设备,只要支持alljoyn,通过wifi、蓝牙都可快速连接,实现信息共享和及时通信。它的好处之一就在于支持多编程语言和多平台,非常方便开发者的使用

Yeelink

Yeelink是一个国内开放的的物联网平台,每个注册用户都可免费添加设备及传感器,利用平台提供的Restful接口,实现对各个传感器的代码访问,从而可以实现传感器数据上传和控制终端等多种功能。有这样一个免费平台,相信对开发者来说是一大福音!

 

软件环境

我目前服务端是在windows 7系统下做此实验,如若在linux环境下运行,需修改部分平台相关代码。集成开发环境是Visual Studio 2012,很强大的IDE,在x86平台下用scons命令生成的samples文件夹下同样都是VS项目文件。客户端的实现则是用开源硬件流行的IDE——arduino-1.5.6-r2,它支持arduino due开发板,用它可进行文件的编辑与烧写。

 

硬件环境

除了x86 PC,大点的就只是arduino due开发板了。日前智能硬件的盛行也促进了开源硬件领域的发展,用arduino等相关成熟硬件可快速做系统原型,大量节约成本,在适当情况下是个很好的技术解决方案。令开发者欣慰的是,开源硬件社区非常流行,所以有很好的问题解决资源。

有arduino板,但无传感器可不行。为方便起见,我目前所展示的就只是温度传感器DS18B20一种。由于具体的传感器数据获取与alljoyn并无关联,所以就以温感为例阐述基于alljoyn的数据传输,其它传感器数据就与之类似了。另外,为了配合控制指令下传,配备了一个发光二极管,当然这是arduino due板上已有的,在13号引脚上。

---------------------------------------------------------------------------------------------------- --------------

友情建议:建议初学者学习x86平台下的alljoyn时,先可直接在VS下进行编辑生成,毕竟有比较好的代码提示功能,熟练后再可用notepad等工具。如若刚学就在notepad上写代码,会很让人无奈,因为一大堆函数和参数你都不知道,不容易发现错误。

---------------------------------------------------------------------------------------------------- --------------

2 结构框架

本系统共有两个Arduino Due开发板作客户端,由于是瘦客户端,所以需要标准客户端提供Daemon才可连接,这一点在官方文档中讲得很明白,不再赘述;Windows 7 PC端作为服务端,发布服务供瘦客户端连接,也许有朋友注意到了这与官方例子ledctrl和AJ_LedService不太一样,客户与服务的角色颠倒了,瘦客户端不再作为服务而是客户了;另外一方面,PC服务端通过互联网与Yeelink平台进行交互,实现数据上传与接收指令,接收到的指令又通过AllJoyn总线控制瘦客户端,从而实现了Yeelink平台下基于AllJoyn的数据传输与控制功能。其结构框图如图1所示:

3 各子系统详解

3.1 Yeelink平台

要想利用Yeelink资源,就须在官网注册一个唯一帐号,在用户中心进行设备和传感器添加。如下图所示,我添加了arduino设备

接下来在“我的设备”项,添加温度传感器和控制开关,系统会为每一个设备生成唯一的URL,通过URL就可以访问特定传感器了。具体操作文档可参考这里:http://www.yeelink.net/develop/api

3.2 PC服务端

在讲到接下来的服务和客户实现时,我会就核心代码作详细解析,而不会写上完整代码,望读者理解

服务端主流程如下图所示:

上图是主线程的流程,由于在PC上是多线程运行,所在在监听对象、总线对象上都有额外的线程运行,它们是异步的,也就意味着当事件发生时,可以迅速得到响应,比如当服务端收到温感瘦客户端传来看温度时,总线对象就调用其方法处理函数向Yeelink平台上传。下面就重点细节来谈谈如何设计服务端

首先创建总线对象,然后给总线对象添加接口。接口中有一个sendTemp方法,带一个字符串输入参数,有一个ledSwitch信号,带一个uint8_t型参数。最后激活接口和启动总线

接下来创建监听和总线对象,分别给总线注册监听和总线对象实例,最后总线实例开始连接本地router

在监听类中,我们重新实现了几个虚函数,包括

bool AcceptSessionJoiner(SessionPortsessionPort, const char* joiner, const SessionOpts& opts)

void SessionJoined(SessionPort sessionPort,SessionId id, const char* joiner)

void NameOwnerChanged(const char* name,const char* previousOwner, const char* newOwner)

前两个是服务端特有的,当有客户接入时,会自动被调用;最后一个服务和客户都可调用,当有服务或客户进入或退出时,总线上会发生名称改变,从而它被调用,有时不止一次。这三个虚函数的实现基本是常规写法,就不在此讲解了

在总线对象实例的构造中,我是这样做的:

首先给总线添加已经设置的接口,为sendTemp方法添加方法处理函数,同时给私有成员ledSwitchMember设置值

在方法处理函数中,获取传过来的温度值,字符串形式,就往yeelink平台上传:

我需要强调的是,在makeString方法中,若要正确拼装成http post请求,有几条属性不能少,于是定义了四个全局数组:

char yeelink_server[] = "api.yeelink.net";

char temp_path[] = "/v1.0/device/9966/sensor/19877/datapoints";

char switch_path[] = "/v1.0/device/9966/sensor/22595/datapoints";

char apikey[] = "d3d565a5923afdd82105e0e5a";

对应着post请求中的以下项:

POST /v1.0/device/9966/sensor/19877/datapoints HTTP/1.1

Host: api.yeelink.net

U-ApiKey: d3d565a5923afdd82105e0e5a

host和path共同组成了传感器的URL,详细说明可参见yeelink文档

至于在初使化windows socket函数中,也需用到yeelink_server,填入相关结构的域,如下所示:

这部分是与平台相关的,若移植到linux平台,需要修改

在总线对象类中,还有一个成员函数emitLedSwitchSignal用于主线程发射信号给led瘦客户端

将发来的参数封装成message参数,和信号一起发送出去,注意sessionid为led客户端id

我们回到主线程main中,Connect之后就开始发布服务了,三步曲:Request,CreateSession,Advertise

最后进入循环,轮询我在yeelink中添加的控制开关状态:

在这里我采取的是被动轮询开关状态的方式,其实不是最佳的,最好是开关状态一改变,就像硬件中断似的,立刻通知CPU,而在此之前CPU完全可以去做其它事。但这需要yeelink平台的主动发送,貌似不太好办,所以就隔断时间轮询状态了。时间间隔也要选好,大了,LED灯变化有延迟;小了,请求太频繁又被yeelink拒绝。那么如何轮询呢?其实与上传温度差不多,还是组装(不过现在是GET请求)、初使化socket,不过在接收中我是这么做的:

相关注意点已在注释中说明。之所以待状态改变后才发射信号,也是为了性能着想,没有必要在状态未改变时也发射。最后返回的值是一个uint8_t型,取值为0或1,0表示熄灭LED灯,1表示点亮LED灯。只要开关状态改变,就把此信息发送给LED瘦客户端

3.3 温感瘦客户端

写客户端代码之前,首先建立文件夹,起名需和.ino文件的主名保持一致,这是arduino环境默认的习惯。我将着重讲述温感数据的发送过程,至于获取温度值,读者可参考arduino中文社区的这个帖子:http://www.arduino.cn/thread-1345-1-1.html,同时下载四个源文件:

DallasTemperature.cpp,DallasTemperature.h,OneWire.cpp,OneWire.h,这属于获取温度的库,全部和ino文件放在一起

另外创建另外一个cpp文件,为alljoyn相关的核心文件,传输温度值。下面着重讲述这个文件

首先要重视以下几个数据结构的书写:

服务名、路径、端口、接口名务必和服务端保持一致,接口中必须要有sendTemp方法,携带一个字符串参数,其它的和Dummy作用一样,作填充;SEND_TEMP表示为AJ_PRX_MESSAGE_ID型

在AJ_Main中,首先做如下工作:

成功连上服务后,StartClient才会返回

接下来才是核心动作,获取温度、方法调用、睡眠,再循环:

由于我不关心后面的解消息过程,所以重点就是前几句,方法调用如下:

首先marshal方法,然后marshal参数,即温度值,最后deliver。这样,就会导致服务端的方法回调函数被调用

3.4 LED瘦客户端

这一端与温感有些地方类似,不过文件就只有2个,一个ino,一个以alljoyn为主的cpp

主要修改在于在sampleInterface中,添加ledSwitch信号"!ledSwitch instr>y",再预定义#define LED_SWITCH  AJ_PRX_MESSAGE_ID(0, 0, 2)

开始阶段当然就与温感类似了,StartClient成功后,就开始解消息,因为服务端的信号要过来了:

当信号过来后,检验消息ID,发现是LED_SWITCH,就解参数,获取开关状态。如果为1,则点亮LED;为0则熄灭之。另外在这个客户端就不用睡眠了,因为是被动接收服务端的信号

4 演示验证

待服务、两个客户端代码实现后,服务端生成exe文件,连接好硬件,客户端分别烧入两个arduino due开发板。粗略图如下图:

那个红色板上面就有DS18B20温度传感器,三个引脚号接入到了其中一个arduino板的引脚上。两个板子都与主机PC通过路由器同处一个局域网内部。还得强调一点,若要使PC服务端能与板子通信,必须启动瘦客户端SDK bin下的SampleDaemon.exe程序,因为服务端并没有绑定的Daemon,它就是来提供Daemon给瘦客户端使用的,其源码可以\alljoyn-14.02.00-src\alljoyn_core\samples\SampleDaemon找到

下面首先看温度传感器的验证

连接好硬件上电,打开yeelink平台的温度传感器的显示页面,方便随时刷新;点击arduino IDE,按shift+ctrl+M打开串口终端,有如下显示:

如若没有SampleDaemon,是不会有最后一句输出的;接下来在命令行执行服务端程序:

正如上图所示,服务端一启动,就发现了客户接入,接入成功之后开始会话。由于我的开关初使状态是开着的,程序默认为关,所以状态改变就发射了一次信号;同时收到了温感一端发来的温度值;串口终端的打印也表明传送温度成功,字符‘f‘的输出是我的输出函数的小问题,暂不管它。几秒钟之后,成了这样:

咦?为什么温度上升了呢?呵呵,那是因为我把手指放在DS18B20上了!它当然温度升高啦。此时我们再来看yeelink上温感的反应:

不负所望,在14年9月13日 12:26:34分显示了最初的温度值26.6,前面的为之前的数据了。这也就实现了在线监控温度的功能了

在另外一客户端,打开串口窗口:

服务端收到了另外一客户的接入,NameOwnerChanged被调用了好几次,倘若我接下来在用鼠标点击yeelink的控制开关,即下图所示:

服务和瘦客户端的反应是:

由结果可知,我是开了一次开关,又关了一次开关,导致客户端先后接到1,0,过程中观察LED灯的反应就是一亮一灭,同时温度值也可在下图中收到:

上面应该是传输错误才出现了a字符

到此为止,整个预先设想功能基本实现了

5 值得改进

1、可以添入更多传感器,从而让功能更加丰富

2、可以让第三个瘦客户端充当服务,比如用arduino板,移动手机等等,如果处理能力满足条件的话。因为作为多个客户的服务端,数据处理能力应该要强些,如果只是单线程,像arduino板,能否处理值得验证

3、可以给温度传感器设定阈值,一旦温度超过给定值就采取报警,鸣响蜂鸣器之类的设备

6 参考链接

AllJoyn官方1:https://allseenalliance.org/

AllJoyn官方2:https://www.alljoyn.org/

Yeelink官网:http://www.yeelink.net/

Arduino Due介绍:http://www.arduino.cc/en/Main/ArduinoBoardDue

Arduino 中文社区:http://www.arduino.cn/

时间: 2024-10-05 11:05:49

【AllJoyn专题】基于AllJoyn和Yeelink的传感器数据上传与指令下行的研究的相关文章

云上树莓派(2):将传感器数据上传到 AWS IoT 并利用Kibana进行展示

云上树莓派(1):环境准备 云上树莓派(2):将传感器数据上传到AWS IoT 并利用Kibana进行展示 1. 传感器安装及配置 1.1 DHT22 安装 DHT22 是一款温度与湿度传感器,它有3个针脚,左边的第一个引脚(#1)为3-5V电源,第二个引脚(#2)连接到数据输入引脚,最右边的引脚(#4)接地. 而树莓派3B 一共有40个针脚(GPIO,General Purpose I/O Ports,通用输入/输出端口),只需要将传感器的3个引脚接入板子上的合适引脚即可.我的连接是 1 -

信息提示板RS232,RS485传感器数据上传到服务器

方案需求 为了解决日益严重的交通拥挤情况,并减缓地面交通对环境的影响,城市已经建立先进的交通管理中心来整合通讯网络,道路可变信息板(CMS)就是其中之一.道路可变信息板是一种智能交通系统,可以提供各种交通信息,例如意外事故.封路.建设延误.限速,以及其他相关交通信息.CMS的通信接口可以是串口或以 太网,如果将所有的CMS用有线的方式整合进一个庞大的交通网络中,并进行安装和维护,是需要大量的成本消耗和时间消耗. 系统部署 由于现有的网络已经就位,交通部门需要一个可以满足以下要求的解决方案: ★

UI标签库专题四:JEECG智能开发平台 Upload(上传标签)

?? 1. Upload(上传标签) 1.1.  参数 属性名 类型 描述 是否必须 默认值 id string 上传控件唯一标示 是 null name string 控件name 是 null formData string 上传文件提交后台的其他表单参数取ID 否 null uploader string 上传提交路径 是 null extend string 上传文件扩展名(可选类型组1,pic[*.jpg;*,jpeg;*.png;*.gif;*.bmp;*.ico;*.tif],2,

基于jQuery很牛X的批量上传插件

上传功能应该是每个网站必备的工具之一,因此出现了出现了很多各式各样的上传插件! 本文基于个人经验和使用从插件的:交互体验,易用性,文档,美观度出发,为大家推荐三款很NX的批量上传插件! 下面三款插件的特点:1.简单易配置,2.带进度条上传,3.可批量上传自定义格式文件 1.jQuery File Upload 官网:http://blueimp.github.com/jQuery-File-Upload/ 在线示例:http://blueimp.github.com/jQuery-File-Up

(转载)基于Bash命令行的百度云上传下载工具

原文链接:http://hi.baidu.com/meoow/item/aef5814bbd5be3e1bcf451e9 这是我根据百度云PCS的API写的一个基于bash的命令行工具, 使用了curl, awk, sed, xxd, bash,没有使用任何其他的语言解释器做辅助 目前,上传下载,文件列表,文件信息,创建文件夹,删除文件都没问题 复制和移动总是返回参数错误,实在找不出来哪里跟API不一致了,暂时放弃. 另外离线下载相关的API也都添加了,但是因为现在百度云不能申请,我是用的是by

基于H5+ API手机相册图片压缩上传

// 母函数 function App(){} /** * 图片压缩,默认同比例压缩 * @param {Object} path * pc端传入的路径可以为相对路径,但是在移动端上必须传入的路径是照相图片储存的绝对路径 * @param {Object} obj * obj 对象 有 width, height, quality(0-1) * @param {Object} callback * 回调函数有一个参数,base64的字符串数据 */ App.prototype.dealImage

基于 WebSocket 的聊天和大文件上传(有进度提示)完美实现

大家好,好久没有写文章了,当然不是不想写,主要是工作太忙,公司有没有网络环境,不让上网,所以写的就少了.今天是2019年的最后一天,明天就要开始新的一年,当然也希望自己有一个新的开始.在2019年的最后一天,写点东西,作为这一年的总结吧!写点啥呢?最近有时间,由于公司的需要,需要实现一个自己的.Web版本的聊天工具,当然也要能传输文件.经过两个星期的无网络.艰苦的学习,终于写出了一个最初的版本.在公司里面里面已经生成正式版本了,很多类型都进行了抽象化,支持注册,头像,私信,群聊,传输大文件,类似

基于Http原理实现Android的图片上传和表单提交

版权声明:本文由张坤  原创文章,转载请注明出处: 文章原文链接:https://www.qcloud.com/community/article/794875001483009140 来源:腾云阁 https://www.qcloud.com/community 现在服务器主要是Web居多,客户端一般通过http上传文件到web服务器,最开始的设想很简单,直接将图片转化为字节流,写入到http的outstream,随后发送出去即可. 但当这种方法出现问题,服务器根据文件名这个表单中的字段来判定

基于腾讯云点播的视频上传和转码功能

在之前的文章中提到过腾讯云储存上传大文件的各种不方便,比如不能转码(要转码得先把mp4文件从云存储上下载下来,然后通过服务器执行ffmpeg操作,最后再把切割的ts文件上传到腾讯云,过程复杂且容易出错),不能获取实时的上传进度等等,所以就发现腾讯云点播这项技术.相对来说通过云点播既能实现上传进度的获取,而且还能上传完成后自动转码,比如自动把mp4转换为m3u8格式的清单文件来进行分片加载,这样子既能大大加快加载速度,还能保护视频链接的url,所以就记录一下这种技术的使用原理. 云点播视频上传Js