資料庫
我使用的是 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：
查看資料表，里面就有資料了：
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/274678.html
標籤：其他
下一篇：Java物件的創建程序