鑰匙要點(diǎn)

• 反應(yīng)性編程是一種使用並發(fā)數(shù)據(jù)流進(jìn)行編程的方法，這可能是異步的。它可以應(yīng)用於編程問題，因?yàn)镃PU處理由指令和數(shù)據(jù)組成的信息流。
JavaScript（RXJS）庫的反應(yīng)性擴(kuò)展使用方法鏈接並介紹觀察者（生產(chǎn)者）和觀察者（消費(fèi)者）。這兩種類型的可觀察物是熱可觀察的，即使不訂閱，也可以推動可觀察的觀測值，而冷可觀測值僅在訂閱時才開始推動。 。 可以從數(shù)組，承諾，功能和生成器創(chuàng)建> RXJS提供了許多引入並發(fā)性的操作員，例如油門，間隔或延遲。這些可用於通過指定的時間間隔匯總事件，或者用於在某個空閒時間後僅啟動請求的節(jié)氣門輸入。 > RXJS使JavaScript中的反應(yīng)性編程更加容易，更有效。它統(tǒng)一了一組簡潔且可複合的方法中反應(yīng)性編程的一些概念。它還具有有用的擴(kuò)展，例如RXJS-DOM，它簡化了與DOM的相互作用。
• 本文由MoritzKr?ger，Bruno Mota和Vildan Softic審查。感謝SitePoint所有的同行評審員製作SitePoint內(nèi)容的最佳狀態(tài)！
>在我們深入研究主題之前，我們必須回答至關(guān)重要的問題：什麼是反應(yīng)性編程？截至今天，最受歡迎的答案是，反應(yīng)性編程是通過並發(fā)數(shù)據(jù)流進(jìn)行編程。大多數(shù)時候，我們會發(fā)現(xiàn)並發(fā)單詞被異步取代，但是，稍後我們會在流中看到該流不必異步。
• >很容易看到“一切都是流”方法可以直接應(yīng)用於我們的編程問題。畢竟，CPU無非是處理由指令和數(shù)據(jù)組成的信息流的設(shè)備。我們的目標(biāo)是觀察該流並在特定數(shù)據(jù)的情況下進(jìn)行轉(zhuǎn)換。
>

>不用更多的是，讓我們通過使用JavaScript（RXJS）庫的反應(yīng)性擴(kuò)展來弄髒我們的手。 RXJS使用了很多鏈接，這是一種流行的技術(shù)，在其他庫中也使用。方法鏈條指南（在Ruby的背景下）可在SitePoint上找到。

>

>

熱可觀察。 rx還引入了冷可觀察物，其行為更像是標(biāo)準(zhǔn)迭代器，因此流中的信息由每個觀察者的所有項(xiàng)目組成。 >以下圖像說明了一些外部類型的流。我們看到（以前啟動）請求並通常提到了Web掛鉤，以及UI事件（例如鼠標(biāo)或鍵盤交互）。最後，我們還可以從設(shè)備，例如GPS傳感器，加速度計或其他傳感器中接收數(shù)據(jù)。

>圖像還包含一個流的流，稱為

。消息可以以幾種形式出現(xiàn)。最簡單的表格之一是我們網(wǎng)站與其他網(wǎng)站之間的通信。其他示例包括與Websocket或Web工人的通信。讓我們看看後者的一些示例代碼。 > >工人的代碼在下面介紹。該代碼試圖從2到10

> 通常，包括如下的Web Worker（假定在文件prime.js中）。為了簡潔起見，我們跳過檢查網(wǎng)絡(luò)工作者的支持和返回結(jié)果的合法性。

<span>(function (start<span>, end</span>) {
</span>    <span>var n = start - 1;
</span>
    <span>while (n++ < end) {
</span>        <span>var k = Math.sqrt(n);
</span>        <span>var found = false;
</span>
        <span>for (var i = 2; !found && i <= k; ++i) {
</span>            found <span>= n % i === 0;
</span>        <span>}
</span>
        <span>if (!found) {
</span>            <span>postMessage(n.toString());
</span>        <span>}
</span>    <span>}
</span><span>})(2, 1e10);
</span>

的Parallel JavaScript。

<span>var worker = new Worker('prime.js');
</span>worker<span>.addEventListener('message', function (ev) {
</span>    <span>var primeNumber = ev.data * 1;
</span>    <span>console.log(primeNumber);
</span><span>}, false);
</span>

可以用簡單的時間軸和斑點(diǎn)來說明結(jié)果：>

> 在兩種情況下，答案是在給定時間間隔上匯總以前的事件。兩個描述的方案之間的區(qū)別在於，在給定時間間隔之後應(yīng)始終顯示質(zhì)數(shù)（即，某些質(zhì)子數(shù)在介紹中可能會延遲）。相比之下，搜索查詢只有在指定間隔期間未發(fā)生密鑰衝程時觸發(fā)新請求。因此，一旦檢測到鑰匙中風(fēng)，計時器即將重置。

<span>(function (start<span>, end</span>) {
</span>    <span>var n = start - 1;
</span>
    <span>while (n++ < end) {
</span>        <span>var k = Math.sqrt(n);
</span>        <span>var found = false;
</span>
        <span>for (var i = 2; !found && i <= k; ++i) {
</span>            found <span>= n % i === 0;
</span>        <span>}
</span>
        <span>if (!found) {
</span>            <span>postMessage(n.toString());
</span>        <span>}
</span>    <span>}
</span><span>})(2, 1e10);
</span>

<span>var worker = new Worker('prime.js');
</span>worker<span>.addEventListener('message', function (ev) {
</span>    <span>var primeNumber = ev.data * 1;
</span>    <span>console.log(primeNumber);
</span><span>}, false);
</span>

<span>(function (start<span>, end</span>) {
</span>    <span>var n = start - 1;
</span>
    <span>while (n++ < end) {
</span>        <span>var k = Math.sqrt(n);
</span>        <span>var found = false;
</span>
        <span>for (var i = 2; !found && i <= k; ++i) {
</span>            found <span>= n % i === 0;
</span>        <span>}
</span>
        <span>if (!found) {
</span>            <span>postMessage(n.toString());
</span>        <span>}
</span>    <span>}
</span><span>})(2, 1e10);
</span>

<span>var worker = new Worker('prime.js');
</span>worker<span>.addEventListener('message', function (ev) {
</span>    <span>var primeNumber = ev.data * 1;
</span>    <span>console.log(primeNumber);
</span><span>}, false);
</span>

以上是RXJ的功能反應(yīng)性編程簡介的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！