RabbitMQ 入门 (Go) - 7. 数据持久化(下)【完】
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了RabbitMQ 入门 (Go) - 7. 数据持久化(下)【完】,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1083字,纯文字阅读大概需要2分钟。
内容图文
![RabbitMQ 入门 (Go) - 7. 数据持久化(下)【完】](/upload/InfoBanner/zyjiaocheng/1015/4c06bf3056334b8c99f7f90cbf3a3fd7.jpg)
数据库
我使用的是 PostgreSQL。
使用的驱动是 github.com/lib/pq
这个网址 https://pkg.go.dev/github.com/lib/pq 是官方文档。
创建数据表
打开 PostgreSQL 的管理工具 pgAdmin 4(web 版),创建一个数据库:
数据库名叫 distributed:
创建数据表
首先创建 sensor 表,里面存放传感器信息:
列如下,其中id 是自增主键:
里面需要有传感器的数据,名称要和批处理文件中传感器的名称要一致。
另一个表是 sensor_reading,里面存放传感器的数值:
安装驱动
在项目的根目录使用命令:go get -u github.com/lib/pq 进行安装。
然后建立 datamanager 包,里面的文件如下:
获得数据库连接
先看 db.go:
这里就是获得一个数据库连接存放在 db 变量里,它是包内可访问的。
存储数据
再看 sensorreader.go,它的作用是将传感器的数值存入到数据库:
这个逻辑很简单,就不介绍了。
最后在 exec 包中建立 main.go:
-
首先获得 RabbitMQ 的连接和 Channel,然后通过 Channel 从持久化 Queue 获得数据。
-
对数据进行解码,存储到数据库中
-
如果没有错误,最后使用 Ack 方法来通知 Queue 消息已经被妥善的处理了,可以将它从 Queue 里面移除了。
运行测试
运行之前的批处理文件,还要运行 datamanager:
查看数据表,里面就有数据了:
内容总结
以上是互联网集市为您收集整理的RabbitMQ 入门 (Go) - 7. 数据持久化(下)【完】全部内容,希望文章能够帮你解决RabbitMQ 入门 (Go) - 7. 数据持久化(下)【完】所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。