Firebase 是 Google 公司的一项云服务，提供实时数据库、存储、认证等功能，其中实时数据库能够帮助前端开发者实现实时的数据同步。npm 包 firebase-stream 就是基于 Firebase 实时数据库开发的一个 Node.js 模块，可以让前端开发者更方便的使用 Firebase 实时数据库。
在本篇文章中，我们将会深入了解如何使用 firebase-stream 包来访问 Firebase 实时数据库。
安装 firebase-stream 包
在开始使用 firebase-stream 包之前，我们首先需要将它安装到我们的项目中。在 Node.js 项目中，可以使用 npm 命令来安装 firebase-stream 包。
npm install firebase-stream
安装完成后，我们就可以在项目中引入 firebase-stream 包来使用其中的功能。
const { Observable } = require('firebase-stream');获取 Firebase 实例
在使用 firebase-stream 包之前，我们需要获取 Firebase 实例。为了获取 Firebase 实例，我们需要在 Firebase 控制面板中创建一个新的 Firebase 应用，并获取 Firebase 应用的配置信息。
-- -------------------- ---- ------- ----- ------ - - ------- ----------- ----------- --------------- ------------ ---------------- -------------- ----------------- -- ----- -------- - -------------------- -------------------------------
在获取 Firebase 实例后，我们就可以使用 firebase-stream 包中的功能来访问 Firebase 实时数据库了。
访问 Firebase 实时数据库
在访问 Firebase 实时数据库之前，我们需要定义一个数据库引用变量，用于指向数据库的某一个节点。
const dbRef = firebase.database().ref('path/to/database/node');可以使用 on 方法来监听数据库节点的变化。on 方法可以接受一个回调函数作为参数，该回调函数将会在数据库节点发生变化时被调用，并获取数据库节点最新的数据。
dbRef.on('value', (snapshot) => {
console.log(snapshot.val());
});有时候我们并不想一直监听节点的变化，而只是想获取节点的最新数据。这时候我们可以使用 once 方法来获取节点最新的数据。once 方法也可以接受一个回调函数作为参数，该回调函数将在获取到节点最新数据后被调用。
dbRef.once('value', (snapshot) => {
console.log(snapshot.val());
});使用 firebase-stream 包
firebase-stream 包是基于 RxJS 库开发的，所以在使用 firebase-stream 包之前，我们需要先了解 RxJS 库的基本用法。
RxJS 库可以让我们更方便地管理异步数据流，例如通过 observable 的方式来监听节点变化。在使用 firebase-stream 包之前，我们需要先安装 RxJS 库。
npm install rxjs
使用完整的 firebase-stream 包前，你需要引入数据转化操作符 debounceTime、filter 和 map，即：
const { Observable } = require('firebase-stream');
const { debounceTime, filter, map } = require('rxjs/operators');监听 Firebase 实时数据库节点
要监听 Firebase 实时数据库节点变化，需要使用 Observable.fromRef() 方法转化出流，例如：
const node$ = Observable.fromRef(dbRef);
由于 fromRef() 方法返回的是一个 observable 对象，这时候我们就可以使用 RxJS 库中的方法来进一步处理节点变化的流了。
监听节点变化事件
使用 RxJS 库中的 subscribe() 方法来监听节点变化事件。
node$.subscribe(console.log);
这样只需一行代码，就可以监听 Firebase 实时数据库中节点的变化，并及时获取最新的数据。
过滤节点变化事件
RxJS 库中的 filter() 方法可以用于过滤流中的数据，例如：
node$.pipe( filter(snapshot => snapshot.val() % 2 === 0) ).subscribe(console.log);
这样就可以只监听被 2 整除的节点变化事件，并且获得这些节点最新的数据。
转化节点变化事件
RxJS 库中的 map() 方法可以用于转化流中的数据，例如：
node$.pipe(
map((snapshot) => {
const val = snapshot.val();
return val * val;
})
).subscribe(console.log);这样就可以将监听到的节点变化事件转化为节点数据的平方，并获取这些平方值。
节流节点变化事件
RxJS 库中的 debounceTime() 方法用于限制数据流发射的速率，以防止数据流太快，如：
node$.pipe(
map((snapshot) => {
const val = snapshot.val();
return val * val;
}),
debounceTime(1000)
).subscribe(console.log);这样就可以限制节点变化事件的变化速率，每间隔 1 秒钟获取一次最新数据。
总结
firebase-stream 包通过 observable 的方式让我们更方便地访问 Firebase 实时数据库，并使用 RxJS 库中的方法来进一步管理异步数据流。使用 firebase-stream 包可以大大提高前端开发者的效率，减少代码量并提升代码可读性，有利于帮助开发者更快速地开发实时操作型应用。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6005551b81e8991b448d2522