博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
流数据接入之WebSocket
阅读量:4162 次
发布时间:2019-05-26

本文共 1183 字,大约阅读时间需要 3 分钟。

作者:doremi

之前我们已经讲述了流处理流模型的web界面配置介绍https://blog.csdn.net/supermapsupport/article/details/94003055,本篇文章将介绍接入websocket数据的具体配置使用

接收器配置

在流处理模型编辑中,将websocket接收器拖拽出来,点击模块进行编辑接收器配置

在这里插入图片描述
选择接收数据格式,接收数据格式有三种可以选择,CSVFormatter,JsonFormatter,GeoJsonFormatter。因为我这里的数据是从CSV读出来的,所以我这里选择了CSVFormatter

元数据选择StreamingMetadata,进行元数据的结构配置

epsg:数据投影的epsgcode
id字段名:数据对象的唯一标识
接收的数据类型选择,目前流处理模型只支point类型
时间格式:可选,如果带了时间字段,可以设置对应的时间格式

在这里插入图片描述

字段信息:字段映射设置,字段名称,当前流数据中的字段名;字段来源,源数据中对应的字段,如果是CSV那就是对应的列数;字段类型选择
在这里插入图片描述
最后填写上源websocket的服务地址

过滤器、转换器(可选)

过滤器和转换器是属于可选配置,可以根据自己的需要进行相应的配置

这里我们选择一个字段添加转换器作为示例
字段添加位置:即字段插入的位置
添加字段名称:插入的字段名称
添加字段类型
运算表达式:字段值是根据运算表达式运算结果得出的
在这里插入图片描述

发送器配置

根据需要将对应的发送器拖拽到中间,我们这里选择的是websocket发送器

结果信息格式选择,这里也有三中格式供选择SVFormatter,JsonFormatter,GeoJsonFormatter

websocket服务地址,可以选择将数据推送到其他的websocket服务上,也可以选择推送到iServer的流数据服务中,这里我们选择填写我们事先发布的流数据服务地址(流服务可以在快速发布中选择进行发布),注意的是,需要是服务地址后面加上token

在这里插入图片描述
最后将节点正确的连接上,在上方填写上服务名,选择发布
在这里插入图片描述

验证

我们可以在发布的流数据服务的订阅页面,点击订阅进行验证是否成功

在这里插入图片描述
可以看到我们接受到的数据,包括我们插入的字段XX也在其中。

{"type":"Feature","properties":{"XX":106.67124,"destinationLabel":"CDG","originLabel":"AUH","x":53.33562,"y":25.71172,"id":"ETD37"},"geometry":{"type":"Point","coordinates":[53.33562,25.71172]}}

以上就是流数据接入Websocket的配置内容。后面我们还将介绍更多的流数据接入数据格式

你可能感兴趣的文章
线程池的状态分析
查看>>
SQL关闭的语句
查看>>
Meta http-equiv属性详解(转)
查看>>
kettle国内镜像下载
查看>>
Jsp生成页面验证码的方法[附代码]
查看>>
使用axis2构建webservice(项目中正好用到了)
查看>>
数据库存储过程的一点积累
查看>>
加密算法在Java
查看>>
javascript/jquery获取地址栏url参数的方法
查看>>
值传递与引用传递
查看>>
getParameter()和getAttribute()的区别
查看>>
Oracle11g安装教程图解
查看>>
Java学习记录随笔(一)
查看>>
Java代码获取时间
查看>>
Oracle中如何获取系统当前时间
查看>>
JSP写Java代码举例
查看>>
Oracle随手简记(1)
查看>>
[Tomcat]org.apache.catalina.loader.WebappClassLoader validateJarFile
查看>>
MVC简介——一篇非常简单易懂的介绍
查看>>
Ext加载页面时对元素取值进行判断的写法
查看>>