事件驱动

在jetlinks中大量使用到事件驱动,使用事件总线(EventBus)基于topic来进行数据传递.

Topic

采用树结构来定义topic如:/device/id/message/type . topic支持路径通配符,如:/device/** 或者/device/*/message/*.

TIP

通配符**表示匹配多层路径,*表示匹配单层路径. 不支持前后匹配,如: /device/id-*/message. 发布和订阅均支持通配符,发布时使用通配符时则进行广播.

使用

订阅消息:

  2. @Subscribe("/device/**")
  3. public Mono<Void> handleDeviceMessage(DeviceMessage message){
  4.     return publishDeviecMessageToKafka(message);
  5. }

发布消息:

  2. @Autowired
  3. private EventBus eventBus;
  5. public Mono<Void> saveUser(UserEntity entity){
  6.     return service.saveUser(entity)
  7.             .then(eventBus.publish("/user/"+entity.getId()+"/saved",entity))
  8.             .then();
  9. }

topic列表

设备消息

点击查看

设备告警

在配置了设备告警规则,设备发生告警时,会发送消息到消息总线.

  1. `/rule-engine/device/alarm/{productId}/{deviceId}/{ruleId}`
  3. {
  4.   "productId":"",
  5.   "alarmId":"",
  6.   "alarmName":"",
  7.   "deviceId":"",
  8.   "deviceName":"",
  9.   "...":"其他从规则中获取到到信息"
  10. }

系统日志

topic格式: /logging/system/{logger名称,.替换为/}/{level}.

  1. `/logging/system/org/jetlinks/pro/TestService/{level}`
  3. {
  4. "name":"org.jetlinks.pro.TestService", //logger名称
  5. "threadName":"线程名称",
  6. "level":"日志级别",
  7. "className":"产生日志的类名",
  8. "methodName":"产生日志的方法名",
  9. "lineNumber"：32,//行号
  10. "message":"日志内容",
  11. "exceptionStack":"异常栈信息",
  12. "createTime":"日志时间",
  13. "context":{} //上下文信息
  14. }