[TOC] ## RethinkDB RethinkDB 是一款專為實時應用設計的開源分布式 NoSQL 數據庫系統，以高效處理 JSON 文檔、實時推送變更通知以及易于擴展為特色。 - a. JSON 數據模型 RethinkDB 支持存儲 JSON 格式的文檔，這使得它非常適合與現代 web 和移動應用程序的開發需求相契合，因為這些應用常常使用 JSON 作為數據交換格式。每個文檔都有一個唯一的主鍵，并且可以包含任意復雜的嵌套結構。 - b. 實時查詢與變更推送 RethinkDB 最顯著的特點是其實時查詢能力。用戶可以在查詢中訂閱表或特定查詢的結果，當底層數據發生變化時，RethinkDB 會自動將更新推送到客戶端。這種機制極大地簡化了構建實時應用的過程，無需輪詢或額外的復雜邏輯來檢測和傳播數據變化。 - c. ReQL 查詢語言 ReQL（RethinkDB Query Language）是一種強大且易用的查詢語言，支持鏈式表達式、函數式編程風格以及豐富的操作符。ReQL 允許開發者以直觀的方式對數據進行篩選、排序、分組、聯接、聚合等操作，同時還能處理數組、對象和時間序列數據。 - d. 分布式架構 RethinkDB 可輕松擴展至多個節點形成集群，提供水平擴展能力。數據自動在集群中進行分片和復制，確保高可用性和容錯性。客戶端無需關心數據分布細節，ReQL 查詢會被透明地編譯成分布式計劃并在整個集群上執行。 - e. 管理與監控 RethinkDB 提供了一個直觀的 Web 界面（RethinkDB Admin UI），用于數據庫管理、查詢調試、性能監控以及集群配置。通過這個界面，管理員可以查看實時統計信息、調整分片和副本設置、執行備份與恢復操作等 ## 示例 ### 實時訂閱 (go示例) ``` package main import ( "fmt" "log" r "gopkg.in/rethinkdb/rethinkdb-go.v6" ) func main() { // 連接到 RethinkDB session, err := r.Connect(r.ConnectOpts{ Address: "localhost:28015", // RethinkDB 的地址和端口 }) if err != nil { log.Fatalln(err) } defer session.Close() // 選擇數據庫和表 db := r.DB("test") table := db.Table("example") // 訂閱表的變更 cursor, err := table.Changes().Run(session) if err != nil { log.Fatalln(err) } defer cursor.Close() fmt.Println("Subscribed to changes...") // 處理變更流 var change map[string]interface{} for cursor.Next(&change) { fmt.Println("Change detected:", change) } if err := cursor.Err(); err != nil { log.Fatalln(err) } } ```