即时查询处理模块设计
发布时间:2012/4/9 20:12:26 访问次数:1020
DisWare系统的即时查询处理的步骤如下。
①根据查询请求的参数解析查询任务，并生成 TIP35CW相应的“查询Agent”代码段。
②调用DisWare平台的Agent插入机制将“查询Agent”插入到网络中的目标节点上。
③节点端的查询处理体现在Agent的代码段中（.ma文件编辑），根据前面的系统结构和功能定义该查询“Agent”的处理过程主要为：周期性抽样提取感知数据，然后将感知数据保存在“感知元组”中，调用元组远程插入操作（即发送“元组插入消息”）将元组返回给基站。
④基站即时查询模块查询元组空间，提取“感知元组”，并判断所获元组数据所属的查询请求号，然后对数据进行进一步处理。
从上面的查询处理过程可见，即时查询的处理关键在于由查询参数构造“查询Agent”的处理过程和“感知元组”的接收处理。下面对这两个处理子模块分别进行详细设计。
(1)“查询Agent”的构造模块
该模块主要对用户输人的查询参数进行解析，首先根据相应的查询参数选项或值构造查询Agent的相应代码段，形成完整的查询Agent程序源代码；然后调用MeshIDE DisWare对该源代码进行编译；最后生成二进制的Agent指令代码。
(2)即时查询结果的接收处理
即时查询分析处理模块在执行即时查询请求并向传感器网络中发送“查询Agent”的同时，调用查询结果的接收处理模块。该模块根据查询任务设定“结果元组”的查询模板( template)，并执行In (template)元组空间操作，该操作将到元组空间中搜索是否有与模板匹配的元组，如果有则将该元组提取出来，返回并显示该元组信息。另一方面查询结果接收处理模块调用MeshIDE DisWare的网络消息监听模块，实时监听传感器网络通信接口，收到来自传感器网络的消息后判断消息类型是否为元组请求消息( TupleResMsg)，如果是则提取远程元组操作请求的内容，然后调用远程元组操作请求处理模块将接收到的元组插入到元组空间中，查询结果接收模块调用模板从元组空间中搜索到匹配的元组后将结果显示出来。
①根据查询请求的参数解析查询任务，并生成 TIP35CW相应的“查询Agent”代码段。
②调用DisWare平台的Agent插入机制将“查询Agent”插入到网络中的目标节点上。
③节点端的查询处理体现在Agent的代码段中（.ma文件编辑），根据前面的系统结构和功能定义该查询“Agent”的处理过程主要为：周期性抽样提取感知数据，然后将感知数据保存在“感知元组”中，调用元组远程插入操作（即发送“元组插入消息”）将元组返回给基站。
④基站即时查询模块查询元组空间，提取“感知元组”，并判断所获元组数据所属的查询请求号，然后对数据进行进一步处理。
从上面的查询处理过程可见，即时查询的处理关键在于由查询参数构造“查询Agent”的处理过程和“感知元组”的接收处理。下面对这两个处理子模块分别进行详细设计。
(1)“查询Agent”的构造模块
该模块主要对用户输人的查询参数进行解析，首先根据相应的查询参数选项或值构造查询Agent的相应代码段，形成完整的查询Agent程序源代码；然后调用MeshIDE DisWare对该源代码进行编译；最后生成二进制的Agent指令代码。
(2)即时查询结果的接收处理
即时查询分析处理模块在执行即时查询请求并向传感器网络中发送“查询Agent”的同时，调用查询结果的接收处理模块。该模块根据查询任务设定“结果元组”的查询模板( template)，并执行In (template)元组空间操作，该操作将到元组空间中搜索是否有与模板匹配的元组，如果有则将该元组提取出来，返回并显示该元组信息。另一方面查询结果接收处理模块调用MeshIDE DisWare的网络消息监听模块，实时监听传感器网络通信接口，收到来自传感器网络的消息后判断消息类型是否为元组请求消息( TupleResMsg)，如果是则提取远程元组操作请求的内容，然后调用远程元组操作请求处理模块将接收到的元组插入到元组空间中，查询结果接收模块调用模板从元组空间中搜索到匹配的元组后将结果显示出来。
DisWare系统的即时查询处理的步骤如下。
①根据查询请求的参数解析查询任务，并生成 TIP35CW相应的“查询Agent”代码段。
②调用DisWare平台的Agent插入机制将“查询Agent”插入到网络中的目标节点上。
③节点端的查询处理体现在Agent的代码段中（.ma文件编辑），根据前面的系统结构和功能定义该查询“Agent”的处理过程主要为：周期性抽样提取感知数据，然后将感知数据保存在“感知元组”中，调用元组远程插入操作（即发送“元组插入消息”）将元组返回给基站。
④基站即时查询模块查询元组空间，提取“感知元组”，并判断所获元组数据所属的查询请求号，然后对数据进行进一步处理。
从上面的查询处理过程可见，即时查询的处理关键在于由查询参数构造“查询Agent”的处理过程和“感知元组”的接收处理。下面对这两个处理子模块分别进行详细设计。
(1)“查询Agent”的构造模块
该模块主要对用户输人的查询参数进行解析，首先根据相应的查询参数选项或值构造查询Agent的相应代码段，形成完整的查询Agent程序源代码；然后调用MeshIDE DisWare对该源代码进行编译；最后生成二进制的Agent指令代码。
(2)即时查询结果的接收处理
即时查询分析处理模块在执行即时查询请求并向传感器网络中发送“查询Agent”的同时，调用查询结果的接收处理模块。该模块根据查询任务设定“结果元组”的查询模板( template)，并执行In (template)元组空间操作，该操作将到元组空间中搜索是否有与模板匹配的元组，如果有则将该元组提取出来，返回并显示该元组信息。另一方面查询结果接收处理模块调用MeshIDE DisWare的网络消息监听模块，实时监听传感器网络通信接口，收到来自传感器网络的消息后判断消息类型是否为元组请求消息( TupleResMsg)，如果是则提取远程元组操作请求的内容，然后调用远程元组操作请求处理模块将接收到的元组插入到元组空间中，查询结果接收模块调用模板从元组空间中搜索到匹配的元组后将结果显示出来。
①根据查询请求的参数解析查询任务，并生成 TIP35CW相应的“查询Agent”代码段。
②调用DisWare平台的Agent插入机制将“查询Agent”插入到网络中的目标节点上。
③节点端的查询处理体现在Agent的代码段中（.ma文件编辑），根据前面的系统结构和功能定义该查询“Agent”的处理过程主要为：周期性抽样提取感知数据，然后将感知数据保存在“感知元组”中，调用元组远程插入操作（即发送“元组插入消息”）将元组返回给基站。
④基站即时查询模块查询元组空间，提取“感知元组”，并判断所获元组数据所属的查询请求号，然后对数据进行进一步处理。
从上面的查询处理过程可见，即时查询的处理关键在于由查询参数构造“查询Agent”的处理过程和“感知元组”的接收处理。下面对这两个处理子模块分别进行详细设计。
(1)“查询Agent”的构造模块
该模块主要对用户输人的查询参数进行解析，首先根据相应的查询参数选项或值构造查询Agent的相应代码段，形成完整的查询Agent程序源代码；然后调用MeshIDE DisWare对该源代码进行编译；最后生成二进制的Agent指令代码。
(2)即时查询结果的接收处理
即时查询分析处理模块在执行即时查询请求并向传感器网络中发送“查询Agent”的同时，调用查询结果的接收处理模块。该模块根据查询任务设定“结果元组”的查询模板( template)，并执行In (template)元组空间操作，该操作将到元组空间中搜索是否有与模板匹配的元组，如果有则将该元组提取出来，返回并显示该元组信息。另一方面查询结果接收处理模块调用MeshIDE DisWare的网络消息监听模块，实时监听传感器网络通信接口，收到来自传感器网络的消息后判断消息类型是否为元组请求消息( TupleResMsg)，如果是则提取远程元组操作请求的内容，然后调用远程元组操作请求处理模块将接收到的元组插入到元组空间中，查询结果接收模块调用模板从元组空间中搜索到匹配的元组后将结果显示出来。
上一篇：基站查询服务系统模块结构
相关技术资料- 3-13电阻的分类
- 4-9即时查询处理模块设计
公网安备44030402000607
