如何做自动网站,课件ppt模板免费下载网站,wordpress 模板制作,网站概念设计TTIoT云端物联网组件;面向JAVA;以事件为驱动;为设备提供安全可靠的连接通信能力TTIoT简介TTIOT的Broker采用MQTT协议与设备进行交互,可以应用在数据采集、能源监控、智能生活、智能工业、农业水利等场景;向下提供连接海量设备服务#xff0c;支撑设备数据采集上云#xff0c;…TTIoT云端物联网组件;面向JAVA;以事件为驱动;为设备提供安全可靠的连接通信能力TTIoT简介TTIOT的Broker采用MQTT协议与设备进行交互,可以应用在数据采集、能源监控、智能生活、智能工业、农业水利等场景;向下提供连接海量设备服务支撑设备数据采集上云支持M2M无侵入集成第三方服务端提供事件API,实现远程控制设备;此外TTIOT将会持续开源物联网套件如多协议引擎、设备管理、规则引擎、数据分析等插件为各类IoT场景和行业开发者赋能。Broker组件,TTIot把TCP/IP协议族上的协议都转换成了事件池开发者只需要面向事件编程即可。2.1版本重要更新增加SSL加密功能同时支持https\wss\tls协议在配置文件添加ssl:enabled: truecertificateType: PKCS12certificatePath: /Users/shijun/Desktop/TTIOT/ca/server/3938.pfxcertificatePassword: 5J7HDiJM2.0版本重要更新多协议转换引擎-一个端口支持三种协议HTTP/WEBSOCKET/TCP上层协议使用的依然是MQTT支持使用这三种不同协议的客户端相互通信(详见使用说明.10)使用HTTP协议向设备投递消息,URI:/mqtt,请求体如下Headers:userName //设备帐号tenantId //租户编号password //设备密码Body:{mqttQos: 1, //消息质量payload: { //消息体rule: chat,content: hello},retain: false, //是否为retain消息topic: /m //推送的话题}支持消息路由引擎Ruler-给消息定义规则(详见使用说明.12)功能认证授权(auth)TTIoT的容器对发布的事件都会自动检查登陆状态对未授权的设备进行自动拦截只要在相关的类添加Eventor(auth true)即可Eventor(value AppProtocalMqttConstant.PINGREQ,auth true)public class MqttPingEvent extends MqttApplicationEvent {public MqttPingEvent(MqttMessage msg, ChannelHandlerContext context) {super(msg, context);}}多租户(saas)TTIot的设备归属为租户其devName与topic对每个租户唯一clientId构成为tenantId-devName-xxxx(保留字段)并且提供接口将设备进行录入例如dbHelper.saveTenant(tenant);dbHelper.saveDev(device);控制反转(IOC)TTOT放弃第三方框架IOC框架内部维护了一个轻量的容器在项目启动时对所有的Listener扫描并且接管消息的订阅与发布(Qos)(1)支持Qos(Quality of Service)TTIot提供mqtt三种消息质量模型即Qos0最多一次的传输Qos1至少一次的传输Qos2只有一次的传输该方案适应任何网络场景特别是网络较差的场景(2)通配符与消息降级TTIot提供主题层级分隔符/,单层通配符,多层通配符#设备实现灵活订阅心跳检测(Idle)TTIot 提供两种测活机制(1)服务端定义TTiot:heartbeatTimeout: 10(2)客户端通过设置可变头里面的keepAliveTimeSeconds定义保留消息与消息遗嘱(1)Topic只有唯一的retain消息Broker会保存每个Topic的最后一条retain消息每个Client订阅Topic后会立即读取到retain消息不必要等待发送。订阅Topic时可以使用通配符就会收到匹配的每个Topic的retain消息发布消息时把retain设置为true即为保留信息。(2)MQTT本身就是为信号不稳定的网络设计的所以难免一些客户端会无故的和Broker断开连接当客户端连接到Broker时可以指定LWTBroker会定期检测客户端是否有异常当客户端异常掉线时Broker就往连接时指定的topic里推送当时指定的LWT消息。使用说明配置文件配置文件延续了yaml风格默认命名为TTIotBootstrap.yml在自己模块resources目录下添加TTIotBootstrap.yml文件即可TTiot:port: 8726 #端口heartbeatTimeout: 10 #心跳间隔时间netty:bossGroupCount: -1 #-1代表线程数量取决于cpuworkerGroupCount: -1 #-1代表线程数量取决于cpu,此参数决定了netty的worker线程与TTIot内置的核心线程redis: #redis相关项目启动new ServerLauncher().launch();自定义数据源(1) 实现DbHelper接口(2) 添加数据源插件Broker提供默认的redis实现new ServerLauncher().dbHelper(new RedisDbHelper(new RedisSourceProvider())).launch();自定义统一异常处理器(1) 继承ExceptionHandlerAdapter或者实现 Thread.UncaughtExceptionHandler 接口(2) 添加异常处理插件Broker提供默认的ExceptionHandlerAdapter实现new ServerLauncher().exceptionHandler(new ExceptionHandlerDemo()).launch();依赖注入由于Listener是由TTIot接管的在Listener内部系统提供了两种级别的注入方式选择需要注入的对象添加Inject注解即可(1)service 注入Listener(asynchronous true)public class LoginLogListener extends MqttApplicationListener {Injectprivate SessionService sessionService;}(20 dao 注入public class DeviceService{Injectprivate DbHelper dbHelper;}自定义消息处理器TTIot 提供Listener 注解来处理具体的事件信息在Listener里面有两个参数replace 为true时替换该事件的默认处理器为false时对该事件新增一个处理器asynchronous 为true时申明该处理器为一个异步处理器由TTIot内置的线程池进行接管线程池大小由TTiot:netty:bossGroupCount 决定为false时由netty 的EventLoopGroup 接管处理器可以用来实现额外的功能并且跟默认业务解耦例如异步的设备登陆日志Listener(asynchronous true)public class LoginLogListener extends MqttApplicationListener {Overridepublic void onApplicationEvent(MqttConnectEvent mqttConnectEvent) {DbDemo.saveLogin(mqttConnectEvent.getTimestamp(), mqttConnectEvent.getDevName(), mqttConnectEvent.getTenantId());}}无侵入设计如果开发者想自定义事件的默认处理逻辑无需修改源码只需要加上如下注解上即可TTot则会更换默认的处理逻辑开发者也可以利用TTot的事件驱动自定义事件Listener(replace true)事件发布TTIot 提供多种默认的事件供开发者使用给topic推送消息例如Context.me().publishEvent(new MqttPublishTopicEvent(String topic,MqttQoS mqttQoS,byte[] bytes,String tenantId,boolean isRetain);例如给device单独推送消息Context.me().publishEvent(new MqttPublishDevEvent(String clientId, String topic, byte[] byteBuf, MqttQoS qoS,String tenantId);docker-compose首先需要安装git与dockergit clone https://gitee.com/cloudSj/TTIot.gitcd 到项目根目录mvn clean installmvn clean install package -Dmaven.test.skipdocker-compose up -dwebSocket接入TTIOT内置了webSocket协议转换器开发者只需要关注业务逻辑无需关注协议处理、转换层面的相关问题。HTTP接入及设备控制TTIOT目前只接受POST类型的请求格式如下:URI:/mqttHeaders:userName //设备帐号tenantId //租户编号password //设备密码Body:{mqttQos: 1, //消息质量payload: { //消息体rule: chat,content: hello},retain: false, //是否为retain消息topic: /m //推送的话题}HTTP由于协议本身的特性只支持QOS类型为1或2规则路由Ruler如果消息的内容符合{rule: chat,content: hello}消息格式TTIOT将自动触发规则路由器将消息自动投递到与rule值对应的处理器上如Ruler(name chat)public class ChatRuleHandler implements RuleHandler {Overridepublic void handler(MqttPayloadVo mqttPayloadVo) {System.out.println(mqttPayloadVo);}}因此开发者可以自定义业务处理逻辑TTIoT 开源计划docker部署组件HTTP组件以及控制设备HTTPAPI物模型组件网关\集群与分布式扩展组件安卓端组件规则引擎组件(后续将会持续更新)SSL加密传输另外作者诚邀开发人员提交下位机例如PLC/单片机/安卓相关代码如有计划者可以通过邮箱跟作者取得联系联系作者关注公众号:(不定期推送关于IoT的干货以及源码解析)感谢lombok、netty、hutool 提供的工具以及源码参与贡献Fork项目到自己的repoclone到本地修改代码(dev分支)commit后push到自己的库(dev分支)pull request等待作者合并