Spring Boot中使用时序数据库InfluxDB
除了最常用的关系数据库和缓存之外,之前我们已经介绍了在Spring Boot中如何配置和使用MongoDB、LDAP这些存储的案例。接下来,我们继续介绍另一种特殊的数据库:时序数据库InfluxDB在Spring Boot中的使用。
InfluxDB简介
什么是时序数据库?全称为时间序列数据库。时间序列数据库主要用于指处理带时间标签(按照时间的顺序变化,即时间序列化)的数据,带时间标签的数据也称为时间序列数据。时间序列数据主要由电力行业、化工行业等各类型实时监测、检查与分析设备所采集、产生的数据,这些工业数据的典型特点是:产生频率快(每一个监测点一秒钟内可产生多条数据)、严重依赖于采集时间(每一条数据均要求对应唯一的时间)、测点多信息量大(常规的实时监测系统均有成千上万的监测点,监测点每秒钟都产生数据,每天产生几十GB的数据量)。虽然关系型数据库也可以存储基于时间序列的数据,但由于存储结构上的劣势,使得这些数据无法高效的实现高频存储和查询统计,因此就诞生了一种专门针对时间序列来做存储和优化的数据库,以满足更高的效率要求。(参考:百度百科:时序数据库https://baike.baidu.com/item/%E6%97%B6%E5%BA%8F%E6%95%B0%E6%8D%AE%E5%BA%93/922671)
InfluxDB就是目前比较流行的开源时序数据库(官网地址:https://www.influxdata.com/),我们比较常见的使用场景就是一些与时间相关的高频的数据记录和统计需要,比如:监控数据的存储和查询。
在进行下面的动手环节之前,先了解一下InfluxDB中的几个重要名词:
database:数据库
measurement:类似于关系数据库中的table(表)
points:类似于关系数据库中的row(一行数据)
其中,一个Point由三个部分组成:
time:时间戳
fields:记录的值
tags:索引的属性
动手试试
在了解了什么是时序数据库以及InfluxDB一些基础概念之后,下面我们通过一个简单的定时上报监控数据的小案例,进一步理解InfluxDB的基础配置、数据组织和写入操作!
第一步:创建一个基础的Spring Boot项目(如果您还不会,可以参考这篇文章:快速入门(https://blog.didispace.com/spring-boot-learning-21-1-1/)
第二步:在pom.xml
中引入influx的官方SDK
<dependency><groupId>org.influxdb</groupId><artifactId>influxdb-java</artifactId>
</dependency>
注意:这里因为Spring Boot 2.x版本的parent中有维护InfluxDB的SDK版本,所以不需要手工指明版本信息。如果使用的Spring Boot版本比较老,那么可能会缺少version信息,就需要手工写了。
第三步:配置要连接的influxdb信息
spring.influx.url=http://localhost:8086
spring.influx.user=admin
spring.influx.password=
三个属性分别代表:连接地址、用户名、密码。到这一步,基础配置就完成了。
注意:虽然没有spring data的支持,但spring boot 2.x版本中也实现了InfluxDB的自动化配置,所以只需要写好配置信息,就可以使用了。具体配置属性可以查看源码:org.springframework.boot.autoconfigure.influx.InfluxDbProperties
。
第四步:创建定时任务,模拟上报数据,并写入InfluxDB
@Service
@AllArgsConstructor
@Slf4j
public class Monitor {private InfluxDB influxDB;@Scheduled(fixedRate = 5000)public void writeQPS() {// 模拟要上报的统计数据int count = (int) (Math.random() * 100);Point point = Point.measurement("ApiQPS") // ApiQPS表.tag("url", "/hello") // url字段.addField("count", count) // 统计数据.time(System.currentTimeMillis(), TimeUnit.MILLISECONDS) // 时间.build();// 往test库写数据influxDB.write("test", "autogen", point);log.info("上报统计数据:" + count);}}
测试验证
第一步:启动InfluxDB,并通过命令行准备好要使用的数据库,主要涉及的命令如下;
进入InfluxDB:
$ influx
查询当前存在的数据库:
> show databases
创建数据库(注意数据库名称与上面Java代码中write的第一个参数一致):
> create database "test"
第二步:启动Spring Boot应用,在定时任务的作用下,我们会看到类似下面的日志:
2021-08-03 01:52:47.732 INFO 94110 --- [ main] c.d.chapter63.Chapter63Application : Started Chapter63Application in 2.326 seconds (JVM running for 3.027)
2021-08-03 01:52:47.764 INFO 94110 --- [ scheduling-1] com.didispace.chapter63.Monitor : 上报统计数据:25
2021-08-03 01:52:52.736 INFO 94110 --- [ scheduling-1] com.didispace.chapter63.Monitor : 上报统计数据:30
2021-08-03 01:52:57.737 INFO 94110 --- [ scheduling-1] com.didispace.chapter63.Monitor : 上报统计数据:38
2021-08-03 01:53:02.739 INFO 94110 --- [ scheduling-1] com.didispace.chapter63.Monitor : 上报统计数据:51
2021-08-03 01:53:07.739 INFO 94110 --- [ scheduling-1] com.didispace.chapter63.Monitor : 上报统计数据:31
第三步:通过命令,查看一下InfluxDB中是否已经存在这些数据
> select * from ApiQPS order by time desc;name: ApiQPS
time count url
---- ----- ---
1627926787730000000 31 /hello
1627926782730000000 51 /hello
1627926777729000000 38 /hello
1627926772727000000 30 /hello
1627926767728000000 25 /hello
可以看到,已经存在与日志中一样的数据了。
好了,今天的教程到这里结束了,记得自己动手试试哦!记得关注我,学习不迷路!后面我们还会再继续介绍,如何去展示这些时序数据!
代码示例
本文的完整工程可以查看下面仓库中2.x目录下的chapter6-3
:
Github:https://github.com/dyc87112/SpringBoot-Learning/
Gitee:https://gitee.com/didispace/SpringBoot-Learning/
如果您觉得本文不错,欢迎Star
支持,您的关注是我坚持的动力!
学习过程中如遇困难,加入Spring技术交流群,参与讨论
关注我回复「加群」,加入Spring技术交流群
《Spring Boot 2.x系列教程》
http://blog.didispace.com/spring-boot-learning-2x/
欢迎收藏与转发!
Spring Boot中使用时序数据库InfluxDB相关推荐
- Spring Boot中使用PostgreSQL数据库
在如今的关系型数据库中,有两个开源产品是你必须知道的.其中一个是MySQL,相信关注我的小伙伴们一定都不陌生,因为之前的Spring Boot关于关系型数据库的所有例子都是对MySQL来介绍的.而今天 ...
- Spring Boot中使用MongoDB数据库
MongoDB简介 MongoDB是一个基于分布式文件存储的数据库,它是一个介于关系数据库和非关系数据库之间的产品,其主要目标是在键/值存储方式(提供了高性能和高度伸缩性)和传统的RDBMS系统(具有 ...
- Spring Boot中使用Redis数据库
Spring Boot中除了对常用的关系型数据库提供了优秀的自动化支持之外,对于很多NoSQL数据库一样提供了自动化配置的支持,包括:Redis, MongoDB, Elasticsearch, So ...
- Spring Boot中声明式数据库事务使用与理解
JDBC的数据库事务 传统JDBC的数据库事务的一个示例如下代码所示,该示例仅为一个insertUser方法的数据库事务过程.可以看到,如果还存在很多其他的数据库事务需要,则需要编写很多类似于如下的代 ...
- Spring Boot中使用多数据库
开发企业应用时我们常常遇到要同时访问多种不同数据库的问题,有时是必须把数据归档到某种数据仓库中,有时是要把数据变更推送到第三方数据库中.使用Spring框架时,使用单一数据库是非常容易的,但如果要同时 ...
- Spring Boot学习总结(27)—— Spring Boot中两个数据库迁移工具Liquibase和Flyway的比较
前言 当您需要使用Java创建Web应用程序或API时,可以使用RESTful,SOAP或GraphQL.无论您是查看同步HTTP,异步还是反应式,队列中的消息或来自Kafka的事件,都很难超越Spr ...
- spring mysql mongdb_Spring Boot中使用MongoDB数据库的方法
MongoDB数据库简介 简介 MongoDB是一个高性能,开源,无模式的,基于分布式文件存储的文档型数据库,由C++语言编写,其名称来源取自"humongous",是一种开源的文 ...
- Spring Boot中使用Flyway来管理数据库版本
久违了的Spring Boot系列,今天抽空更新一篇.之前写过很多篇关于数据访问的文章了,比如下面这些: 使用JdbcTemplate 使用Spring-data-jpa简化数据访问层(推荐) 多数据 ...
- springboot mysql事物_在Spring Boot中使用数据库事务
关于数据库访问还有一个核心操作那就是事务的处理了,前面两篇博客小伙伴们已经见识到Spring Boot带给我们的巨大便利了,其实不用猜,我们也知道Spring Boot在数据库事务处理问题上也给我们带 ...
最新文章
- 伺服驱动器生产文件_在速度控制和力矩控制方面伺服驱动器与变频器的较量
- c++和c语言中的函数相互调用的问题
- 【附赠PPT】 KubeMeet 成都站回顾:让云原生应用交付和管理变得更简单
- 【Java后台】Java执行Python代码的3类5种情况测试【Java源码+Python源码举例】
- MySQL高级 - 锁 - InnoDB行锁 - 总结
- 如何成为一位杰出的程序员
- 疑问:当流量被封禁之后(论资本之力):防流量被恶意盗挖(抛砖篇)
- VMware Linux VDI 安装步骤
- 解析几何 —— 椭圆
- 中国为什么不能成为国际数据中心枢纽
- 三极管饱和状态的判断
- 智能配电房综合监控系统的探讨
- 数商云:浅析数字化供应链的现状跟未来
- 用四叉树加速碰撞检测
- 基于深度学习的以图搜图
- NetBeans的下载与安装
- 企业纯内网二进制完美部署Docker(20.10.7版本)
- 多种方式带你玩转 javascript 实现关闭浏览器页签
- 全国二级计算机考试准考证打印官网
- uniapp云开发微信小程序 云函数配置
热门文章
- 保护 ASP.NET 会话状态
- tomcat主目录(ROOT.xml)和虚拟目录
- 系统指纹 中间指纹 web指纹 识别简介
- docker strace ptrace 报错 Operation not permitted 解决方法
- hexo 博客框架 可用作知识库
- linux c 内核 ISO C90 forbids mixed declarations and code 警告
- python 同时给多个变量赋值
- SetTimer的使用问题
- GetMessage和PeekMessage的区别
- 计算机课上机课安排表,周—一学期(南山校区)计算机优秀教学上机课程表.doc