JetLinks 开源物联网平台
JetLinks 基于Java8,Spring Boot 2.x,WebFlux,Netty,Vert.x,Reactor等开发, 是一个开箱即用,可二次开发的企业级物联网基础平台。平台实现了物联网相关的众多基础功能, 能帮助你快速建立物联网相关业务系统。
核心特性
完全开源(社区版免费),基于事件驱动,拓展性强.
支持统一物模型管理,多种设备,多种厂家,多种报文,统一管理。
统一设备连接管理,多协议适配(TCP,MQTT,UDP,CoAP,HTTP等),屏蔽网络编程复杂性,灵活接入不同厂家不同协议的设备。
灵活的规则引擎,设备告警,消息通知,数据转发,场景联动.
强大的ReactorQL引擎,使用SQL来处理实时数据.可拓展自定义函数.
地理位置:统一管理地理位置信息,支持区域搜索.
灵活的非侵入多租户数据权限控制.
在线演示地址: http://demo.jetlinks.cn 用户名:test 密码: test123456.
技术栈
- Spring Boot 2.3.x
- Spring WebFlux 响应式Web支持
- R2DBC 响应式关系型数据库驱动
- Project Reactor 响应式编程框架
- Netty ,Vert.x 高性能网络编程框架
- ElasticSearch 全文检索，日志，时序数据存储
- Redis,设备配置,状态管理,缓存.
- PostgreSQL 业务功能数据管理
- hsweb framework 4 业务功能基础框架
架构
![]()
设备接入流程
![]()
1.10-RELEASE
更新时间: 2021-08-02
代码分支: 1.10
- 增加批量下发设备指令功能,支持查看下发记录,自动重试等(Pro)
- 上报属性和读取属性回复增加
属性源时间和属性状态;行式存储时,会使用源时间当作时间戳进行存储.
- GB28181视频接入支持预置位、看守位指令。(Pro)
- ClickHouse增加指定存储策略,支持集群轮询写,分布式读。(Pro)
- HTTP消息增加文件上传支持
HttpExchangeMessage.multiPart()。(Pro)
- JetLinks后端接口国际化支持(jsr303,枚举(
I18nEnumDict),异常(I18nSupportException))。查看说明
- 提供对游标分页查询支持,部分数据库可能不支持offset方式分页,当分页结果中
scoll为true时,表示游标分页,此时不支持使用pageIndex进行分页,下一页查询时需要在动态查询条件中指定上一页返回的scrollId:"context":{"scrollId":"上一页的ID"},并且查询条件变化后,需要重置页码以及scrollId.
- 设备数据存储策略增加
cassandra支持,可将设备数据写入到cassandra中(Pro).
- 增加数据源管理,统一管理各种数据源(RabbitMQ,Kafka)等(Pro).
- 增加RabbitMQ数据源实现,支持
创建生产者,消费者,RabbitMQ管理功能(添加用户,权限等)(Pro).
- 规则引擎中增加RabbitMQ,Kafka转发节点(Pro).
- 规则引擎节点增加权限控制支持,可通过
rule.engine.executor-filter进行相关配置(Pro).
- 规则引擎
ReactorQL节点支持租户权限控制,rule.engine.task-executor.reactor-ql.enable-tenant=true开启.(Pro)
- 规则引擎设备指令节点发送指令发生异常时,将返回转为消息回复,而不是抛出异常.
- 规则引擎在启动时，自动启动全部规则中符合调度策略的任务，实现添加新的集群节点自动启动任务.(Pro)
- 子设备自动注册时,同时绑定设备资产到网关所在到租户用户下(Pro).
- 优化设备会话状态,如果同一个设备在不同的集群节点连接,以最后连接的为准,之前的会断开(Pro).
MQTT Broker方式接入设备支持设置QoS.- 增加
FileQueue工具类,可将队列数据持久化到本地文件.
- 增加
ParallelIntervalHelper工具类,可对并行操作进行延迟来实现并行转串行的效果.
DeviceDataManager接口增加getTags方法,可在协议包中通过此方式来获取设备标签.- 在TCP网络组件中的粘拆包处理方式脚本中增加
parser.newBuffer()方法,使用方法.
Bug修复:
- 修复关闭权限验证时，可能无法使用
POST动态查询问题
- 修复CoAP停止后无法重启的问题
- 修复部分网络组件未配置线程数则无法启动的问题
- 修复集群下,设备历史在线统计可能不准确的问题
