在1.3版本中增加了将设备消息转发到rabbitMQ或者kafka的功能.

转发到RabbitMQ

修改配置文件application.yml:

  1. spring: 
  2.   rabbitmq: # rabbitMQ配置
  3.     host: localhost
  4.     port: 5672
  5.     username: admin
  6.     password: jetlinks
  7. device:
  8.   message:
  9.     writer:
  10.       time-series:
  11.         enabled: true # 直接写出设备消息数据到时序数据库
  12.       rabbitmq:
  13.         enabled: true  # 推送设备消息到rabbitMQ
  14.         consumer: false  # 从rabbitMQ订阅消息并写入到时序数据库,与time-series.enabled不能同时为true
  15.         thread-size: 4 # 消费线程数
  16.         auto-ack: true  # 自定应答,为true可能导致数据丢失,但是性能最高。
  17.         topic-name: device.message  # rabbitMQ exchange名称
  18.         #ignore-message-types: INVOKE_FUNCTION,READ_PROPERTY # 忽略转发消息类型
  19.         #include-message-types: EVENT    # 只转发指定的消息类型

转发到Kafka

修改配置文件application.yml:

  1. spring:
  2.   kafka:
  3.     consumer:
  4.       client-id: ${spring.application.name}-consumer:${server.port}
  5.       group-id: ${spring.application.name}
  6.       max-poll-records: 1000
  7.     producer:
  8.       client-id: ${spring.application.name}-producer:${server.port}
  9.       acks: 1
  10.       retries: 3
  11.     bootstrap-servers: ["127.0.0.1:9092"]
  12. device:
  13.   message:
  14.     writer:
  15.       time-series:
  16.         enabled: true # 直接写出设备消息数据到时序数据库
  17.       kafka:
  18.         enabled: true  # 推送设备消息到kafka
  19.         consumer: false  # 从kafka订阅消息并写入到时序数据库,与time-series.enabled不能同时为true
  20.         topic-name: device.message  # kafka topic名称
  21.         #ignore-message-types: INVOKE_FUNCTION,READ_PROPERTY # 忽略转发消息类型
  22.         #include-message-types: EVENT    # 只转发指定的消息类型