java连接MQTT服务器,然后订阅主题获取所有设备数据,
然后通过Druid连接池把数据写入MySQL数据库....,不需要配置环境变量)
安装完以后不需要配置环境变量,只需要在软件中设置JDK路径
2,修改为自己的数据库信息和MQTT服务器信息
3,根据自己的设备数据修改解析格式
如果设备的数据格式和我的不一样...,用户根据自己的数据格式修改
我的设备上报数据的格式是 {"data":"sensor","type":"th","temperature":45,"humidity":23}
4,启动
5,可以在控制台看到监控的所有设备的数据...4.连接MQTT,订阅主题
5.获取MQTT数据,从连接池获取链接对象,把数据写到数据库
注意事项1
1,正常情况下java软件也是放到服务器上的, 所以MQTT连接地址应该写为
tcp://localhost...:1883
2,使用 localhost 连接MQTT服务器, 获取MQTT设备的所有数据可以直接订阅 #
3,同样的数据库连接地址也改为localhost , 数据库用户名和密码应该改为 root