+-----+ +-----+
|cli-n| |dev-n|
+-----+ +-----+
+-----+ ^ +-----+ |
|cli-2| | |dev-2| |
+--+--+ | +--+--+ |
^ | | |
+-----+ | | +-----+ | |
|cli-0| | | |dev-0| | |
+--+--+ | | +--+--+ | |
^ | | | | |
| | | | | |
V v V V V V
+----+-----+----+--------+ +-------------------------+
| | | | | | | |
|ch-0| |ch-2| |ch-n| | |
| | | | | | | |
|----+-----+----+--------| | |
| ^ ^ ^ | | |
| | | | | | |
|========================| | |
| | RealTime Data | |
| Push Engine Layer |<----------------------------------| |
|========================| | |
| | RestFul Api | |
intoyun-enterprise-demo-go|<--------------------------------->| IntoYunCloud|
+------------------------+ +-------------------------+
- 设备 dev-x 直接接入 IntoYun Cloud
- 用户客户端 cli-x 通过 app 或 web 前端网页登陆第三方企业实现的后台服务器 intoyun-enterprise-demo-go, websocket 连接用来接收设备端的实时数据， http连接用来实现自己的业务逻辑以及通 过 IntoYun Cloud 提供的 企业api 接口， 获取 IntoYun 平台的数据以及控制设备。
- 设备端的实时数据会通过 IntoYun Cloud 直接转发到 intoyun-enterprise-demo-go 服务器中的 PushEngine， PushEnging 会根据 intoyun-enterprise-demo-go 实现的推送策略， 将这些实时数据推送到对应的 cli-x。
- 整个 intoyun-enterprise-demo-go 由 http 服务 + websocket 服务 两部分组成， http 服务完成 web功能， websocket服务完成实时数据推送。
- http 服务没有依赖开源web框架， 直接基于go 自带的库来实现。
- intoyun-enterprise-demo-go 的 push engine layyer 完成了数据的aes 解密， 然后封装成自定义协议 Proto（参考代码)推送到客户端cli-x, 客户端cli-x 解析之后即可获得设备端上报的实时原始数据。
- 用户可以很快扩展自定义协议（libs/proto/proto.go)
- 用户可以快速重写业务逻辑部分实现自定义业务逻辑(operator.go)。
-
Windows系统用户请按Win+R运行cmd，输入
systeminfo后回车，稍等片刻，会出现一些系统信息。 在“系统类型”一行中，若显示“x64-based PC”，即为64位系统；若显示“X86-based PC”，则为32位系统。 -
访问 golang.org 如果访问不了请访问 golang中国 下载 msi 安装包 32 位请选择名称中包含 windows-386 的 msi 安装包，64 位请选择名称中包含 windows-amd64 的 msi 安装包。 下载好后运行安装，不要修改默认安装目录 C:\Go\，若安装到其他位置会导致不能执行自己所编写的 Go 代码。
-
Go 语言需要配置 GOROOT 和 PATH 两个环境变量 安装完成后默认会在环境变量 Path 后添加 Go 安装目录下的 bin 目录
C:\Go\bin\，并添加环境变量 GOROOT，值为 Go 安装根目录C:\Go\。 无须再对其进行手工设置, 如果你第一步没有使用默认安装目录，那么需要对上述两个变量进行手工配置 -
Go 工作目录 GOPATH 环境变量：可以随意指定， 用于存放Go语言Package的目录，这个目录不能在Go的安装目录中 GOPATH：D:\go\
-
验证是否安装成功 在运行中输入
cmd打开命令行工具，在提示符下输入go，检查是否能看到 Usage 信息。输入cd %GOROOT%，看是否能进入 Go 安装目录。若都成功，说明安装成功。 -
在 GOPATH 的目录下创建 src， bin 两个目录
下载 intoyun-enterprise-demo-go 源码到上面创建的src目录中(如果不是用 git clone 下载来的， 请手动解压缩， 并将文件夹的名字改为 intoyun-enterprise-demo-go)
-
http 监听端口
[base] http.addrs [email protected]:8081
-
websocket 监听端口
[websocket] bind 0.0.0.0:8082
-
服务器授权信息
- appid your-app-id
- appsecret you-app-secret
-
kafka配置参数
- topic device-data-${appid}
- group ${appid}
- kafka.list dps.intoyun.com:9092
- sasl.enable true
- sasl.user ${appid}
- sasl.password ${appsecret}
-
log 参数配置
- windows: 修改配置文件 intoyun-enterprise-demo-go.conf, 使用配置文件 intoyun-enterprise-demo-go-log-win.xml
- macos, linux 修改配置文件 intoyun-enterprise-demo-go.conf, 使用配置文件 intoyun-enterprise-demo-go-log.xml
- cd intoyun-enterprise-demo-go
- go build
- ./intoyun-enterprise-demo-go
- cd intoyun-enterprise-demo-go/client
- go build
- ./client
测试程序默认会每10毫秒创建一个 websocket 连接, 创建两个, 可以修改main.go 来设置个数。 客户端通过认证之后， 每隔 30s 发一次心跳包, 目前服务器对客户端websocket连接的认 证没只是简单的直接按照 key-{0, 1}, 顺序创建订阅的key, 这样设备的实时数据转发到 intoyun-enterprise-demo-go 之后就可以根据 推送策略（目前全部推送到key-0 对应的cli-0) 完成实时数据的推送。
step1. 获取 token
curl -X POST http://localhost:8081/v1/token
6a08820093e15327cfe5ee13cd31d74f
step2. 获取企业所有的product
curl --header "X-IntoYun-SrvToken:6a08820093e15327cfe5ee13cd31d74f" http://localhost:8081/v1/product
step3. 获取企业的某个product信息
curl --header "X-IntoYun-SrvToken:6a08820093e15327cfe5ee13cd31d74f" http://localhost:8081/v1/product/${productId}
step4. 获取企业某个product产品下面的所有设备
curl --header "X-IntoYun-SrvToken:6a08820093e15327cfe5ee13cd31d74f" http://localhost:8081/v1/device?productId=${productId}&page=1&size=20
step5. 控制某个设备
curl -X POST --header "X-IntoYun-SrvToken:6a08820093e15327cfe5ee13cd31d74f" --header "Content-Type: application/json" -d '[{"dpId": 1, "type": "enum", "value": 0}]' http://localhost:8081/v1/control?productId=${productId}&deviceId=b
step5. 获取某个设备的历史数据
curl --header "X-IntoYun-SrvToken:6a08820093e15327cfe5ee13cd31d74f" http://localhost:8081/v1/sensordata?productId=${productId}&start=1232555&end=2351233&deviceId=${devceid}&dpId=0&interval=10s
在 client 中， 对于数据点的解析， 尤其针对 number 数据点类型的解析.