描述文件与 mqtt 的消息中间件 iot-mqtt-bridge

Apache
未知
2019-09-05
shifeng1983

【年终提升】2019尾声,来 OSC·年终盛典收割技术干货,get新技能!>>>

iot-mqtt-bridge

feature:

  • [x] 解析简单 mqtt 消息存到 mysql
  • [ ] 解析简单 mqtt 消息存到 kafka
  • [ ] 解析复杂消息
  • [ ] 批处理存储数据
  • [ ] 自定义各种 handler

你只需要在 model.json 里定义一个描述文件,具体以含义看注释,

然后配置 mqtt ,mysql 连接信息在 bridge.yml,

运行 release/bin/server  启动项目

就可以自动根据描述文件解析mqtt消息并存进数据库内。

[
  {
    "name": "user", //"动态生成的类名”
    "topic": "user_topic",
    "clientId": "user_client",
    "cleanSession": true,
    "qos": 1,
    "storeType": "mysql",
    "fields": [{
        "name": "id",
        "type": "long", //"存数据库字段的类型"
        "index": 1,
        "lenght": 8, //"截取多少个字节"
        "offset": 2,
        "idType": "auto" //”如果是auto就是用数据库的自增,否则是截取到的数据“
    },
    {
        "name": "loginLength",
        "type": "int",
        "index": 2,
        "lenght": 2,
        "isTransient": true //"不持久化到数据库内"
    },
    {
        "name": "login",
        "type": "byte[]",
        "index": 3,
        "dependsOn": 2 //"根据指定index的字段的值作为长度“
    }

]
spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/mqtt_test
    username:
    password:
jdbc:
  template:
    prefix: t_
    suffix: _test
    insertGetId: false   
logging:
  config: logback.xml
bridge:
  modelPath: model.json
  mqtts:
    - url: tcp://localhost:1883
      username:
      password:
      keepAlive: 20
      retained: false
      reconnectAttemptsMax: -1
      reconnectDelay: 10
      models:
        - user

的码云指数为
超过 的项目
加载中

评论(2)

OSCHINA傻13真多
OSCHINA傻13真多
看工程名还以为是rocketMQ的扩展iot-bridge
s
shifeng1983 软件作者
理论上可以做到存到任何mq,数据库里面,因为会把byte数组解析生成java对象,所以后面的事就是把这个对象存一下

暂无资讯

暂无问答

干货 | 设备快速上云,轻松搞定设备与云端通信

本文主要讲解如何使用京东云物联网引擎产品,快速创建产品及设备,并通过SDK将设备安全地连接至云端,实现设备的数据上报与订阅,让刚接触该产品的用户能够对京东云物联网平台有个初步的认识...

2019/09/29 11:20
21
0
设备上报数据规则流转FC推送钉钉群

1.IoT云端开发 开通物联网套件 https://www.aliyun.com/product/iot =>产品管理>创建产品 =>产品管理>产品详情>设备管理>添加设备 =>产品管理>产品详情>设备管理>添加自定义属性 tag,imei ...

2018/06/27 15:58
41
0
MQTT协议应用指南 兼容产品简介

在工业通信领域,MQTT越来越多地被客户了解与应用。在物联网应用需求交流与项目分析中,经常有客户问佰马售前支持工程师:“你们的DTU、4G路由器或边缘计算网关支持MQTT吗?” MQTT在工业物联...

2019/10/29 14:42
164
0
10分钟虚拟设备接入阿里云IoT平台实战

1. 准备工作 1.1 注册阿里云账号 使用个人淘宝账号或手机号,开通阿里云账号,并通过实名认证(可以用支付宝认证) 1.2 免费开通IoT物联网套件 产品官网 https://www.aliyun.com/product/iot 1...

2018/06/27 15:50
143
0
EMQ 解决方案之云平台物联网消息队列解决方案

随着物联网技术的发展与普及,越来越多的智能设备具备了网络连接与数据传输能力。由于物联网场景复杂多样,设备端硬件条件、网络稳定性、流量限制、设备功耗以及设备连接数量等多方面因素造成...

2019/08/03 14:06
46
0
又一个操作系统开源

9月18日,腾讯宣布开源自主研发的轻量级物联网实时操作系统 TencentOS tiny。TencentOS tiny是腾讯面向物联网领域开发的实时操作系统,具有低功耗,低资源占用,模块化,安全可靠等特点,可有...

2019/11/19 09:26
63
0
AWS物联网解决方案之:如何将设备安全地接入AWS IoT

1 简介 AWS IoT解决方案是一个全托管的云平台,使互联设备可以轻松安全地与云应用程序及其他设备交互。AWS IoT可以支持数十亿太设备和数万亿条消息,并且可以对这些消息进行处理并将其安全可...

2019/10/31 13:29
7
0
各大云平台物联网相关产品对比分析

概述 本文主要对阿里云、腾讯云、百度云和华为云提供的相关物联网产品进行对比,用于分析各大云平台在物联网方面的布局和实现。 硬件开发及组网 对比项 阿里云 腾讯云 百度云 华为云 嵌入式O...

2019/02/13 14:33
1.4K
0
轻量级边缘计算 EMQ X Kuiper 与 Azure IoT Hub 集成方案

背景 本文以一个常见的物联网使用场景为案例,介绍了如何利用边缘计算来实现对业务的快速、低成本和有效地处理。 在各类物联网项目中,比如智能楼宇项目,需要将楼宇的数据(比如电梯、燃气、...

2019/11/21 14:22
24
0
消息服务实时消费设备状态变化和数据

0.准备工作 0.1 注册阿里云账号 使用个人淘宝账号或手机号,开通阿里云账号,并通过实名认证(可以用支付宝认证) 0.2 免费开通IoT物联网套件 IoT套件产品官网 https://www.aliyun.com/product...

2018/06/27 15:54
130
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部