數(shu)(shu)(shu)據(ju)(ju)(ju)訂(ding)閱(yue)是一種(zhong)數(shu)(shu)(shu)據(ju)(ju)(ju)查詢(xun)(xun)(xun)方式(shi)(shi)，其(qi)特(te)點(dian)為：客戶端執行一個查詢(xun)(xun)(xun)語句后，可(ke)以增量(liang)形式(shi)(shi)，不斷(duan)收到新到達服務端的、符合(he)查詢(xun)(xun)(xun)條件的數(shu)(shu)(shu)據(ju)(ju)(ju)。相比普通查詢(xun)(xun)(xun)，訂(ding)閱(yue)能(neng)夠持續(xu)地、低延遲地將新寫(xie)入(ru)的數(shu)(shu)(shu)據(ju)(ju)(ju)返回客戶端。

什么時候需要數據訂閱？

訂閱是一種低成本地、實時獲取 TDengine 時序數據庫(Time Series DataBase)最新數(shu)(shu)(shu)(shu)據的(de)方法。客(ke)(ke)(ke)戶端(duan)(duan)(duan)(duan)程序與數(shu)(shu)(shu)(shu)據庫(ku)的(de)交互，通常是由客(ke)(ke)(ke)戶端(duan)(duan)(duan)(duan)發(fa)起查詢(xun)(xun)(xun)，再由數(shu)(shu)(shu)(shu)據庫(ku)返回數(shu)(shu)(shu)(shu)據。假設每當數(shu)(shu)(shu)(shu)據庫(ku)有(you)數(shu)(shu)(shu)(shu)據寫(xie)入時(shi)，都需要立(li)即將新的(de)寫(xie)入結果發(fa)送給某客(ke)(ke)(ke)戶端(duan)(duan)(duan)(duan)，如果用查詢(xun)(xun)(xun)的(de)方式實現，則需要由客(ke)(ke)(ke)戶端(duan)(duan)(duan)(duan)定(ding)時(shi)發(fa)起輪(lun)詢(xun)(xun)(xun)。而大量的(de)發(fa)起查詢(xun)(xun)(xun)，會增加客(ke)(ke)(ke)戶端(duan)(duan)(duan)(duan)與服(fu)務(wu)器的(de)資源(yuan)消(xiao)耗(hao)；且(qie)根據輪(lun)詢(xun)(xun)(xun)的(de)頻率，獲取最新數(shu)(shu)(shu)(shu)據會有(you)一定(ding)的(de)延遲。我們可以將訂閱看作是持續不斷(duan)的(de)長查詢(xun)(xun)(xun)，一旦數(shu)(shu)(shu)(shu)據更新（包括新插(cha)入），則會立(li)即被推(tui)送至(zhi)客(ke)(ke)(ke)戶端(duan)(duan)(duan)(duan)，當數(shu)(shu)(shu)(shu)據沒有(you)更新時(shi)，不會有(you)額外的(de)資源(yuan)消(xiao)耗(hao)。

TDengine 時序數據庫的訂(ding)閱可(ke)以在服務端過濾數(shu)據，從而降(jiang)低了資源消耗(hao)，并且簡(jian)化了應(ying)用層實現。

很多分布式實時數據庫需要(yao)集成(cheng)消(xiao)息隊列(lie)(lie)產品(pin)來實現數(shu)據訂(ding)閱功能(neng)。而 TDengine 提供了類似消(xiao)息隊列(lie)(lie)產品(pin)的數(shu)據訂(ding)閱、消(xiao)費接(jie)口，用(yong)戶(hu)無需再集成(cheng)其他(ta)產品(pin)，從而簡化系統設計的復雜度，降低運維成(cheng)本(ben)。

那么，TDengine 時序數據庫（TSDB） 是如何實現訂(ding)閱功能的(de)？如何通過訂(ding)閱功能獲取數據？

TDengine 研發工程(cheng)師劉繼(ji)聰為大家(jia)分(fen)享《分(fen)布式數據庫(ku)訂閱功能的原理及實現》。

內容大綱：

• 訂閱功能及其基本使用
• 分布式訂閱、消費者與消費者組
• 通過訂閱獲取 TSDB 數據以及 WAL 數據
• 通過訂閱進行 DB 的實時備份