Node.js事件的正確使用方法
前言
事件驅(qū)動的編程變得流行之前,在程序內(nèi)部進(jìn)行通信的標(biāo)準(zhǔn)方法非常簡單:如果一個組件想要向另外一個發(fā)送消息,只是顯式地調(diào)用了那個組件上的方法。但是在 react 中用的卻是事件驅(qū)動而不是調(diào)用。
事件的好處
這種方法能夠使組件更加分離。在我們繼續(xù)寫程序時,會識別整個過程中的事件,在正確的時間觸發(fā)它們,并為每個事件附加一個或多個事件監(jiān)聽器,這使得功能擴展變得更加容易。我們可以為特定事件添加更多的 listener,而不必修改現(xiàn)有的偵聽器或觸發(fā)事件的應(yīng)用程序部分。我們所談?wù)摰氖怯^察者模式。
設(shè)計一個事件驅(qū)動的體系結(jié)構(gòu)
對事件進(jìn)行識別非常重要,我們不希望最終必須從系統(tǒng)中刪除或替換現(xiàn)有事件,因為這可能會迫使我們刪除或修改附加到事件上的眾多偵聽器。我的一般原則是僅在業(yè)務(wù)邏輯單元完成執(zhí)行時才考慮觸發(fā)事件。
假如你想在用戶注冊后發(fā)送一堆不同的電子郵件。注冊過程本身可能會涉及許多復(fù)雜的步驟和查詢,但從商業(yè)角度來看,這只是其中的一個步驟。每個要發(fā)送的電子郵件也是單獨的步驟。因此,一旦注冊完成馬上就發(fā)布事件是很有意義的。于是我們附加了多個監(jiān)聽器,每個監(jiān)聽器負(fù)責(zé)發(fā)送一種類型的電子郵件。
Node的異步事件驅(qū)動架構(gòu)具有一些被稱為“emitters”的對象。它們發(fā)出命名事件,這些事件會調(diào)用被稱為“l(fā)istener”的函數(shù)。發(fā)出事件的所有對象都是 EventEmitter 類的實例。使用它,我們可以創(chuàng)建自己的事件:
一個例子
讓我們使用內(nèi)置的 events 模塊(我建議你查看這個文檔:https://nodejs.org/api/events...)以獲取對 EventEmitter 的訪問權(quán)限。
const EventEmitter = require('events'); const myEmitter = new EventEmitter(); module.exports = myEmitter;
這是我們的服務(wù)器端程序的一部分,它負(fù)責(zé)接收HTTP請求,保存新用戶并發(fā)出事件:
const myEmitter = require('./my_emitter'); // Perform the registration steps // Pass the new user object as the message passed through by this event. myEmitter.emit('user-registered', user);
附加一個監(jiān)聽器的單獨模塊:
const myEmitter = require('./my_emitter'); myEmitter.on('user-registered', (user) => { // Send an email or whatever. });
將策略與實現(xiàn)分開是一種非常好的做法。在這種情況下,策略意味著哪些 listener 訂閱了哪些事件。實現(xiàn)意味著 listener 自己。
const myEmitter = require('./my_emitter'); const sendEmailOnRegistration = require('./send_email_on_registration'); const someOtherListener = require('./some_other_listener'); myEmitter.on('user-registered', sendEmailOnRegistration); myEmitter.on('user-registered', someOtherListener);
module.exports = (user) => { // Send a welcome email or whatever. }
這種分離使 listener 也可以被重復(fù)使用,它可以被附加到發(fā)送相同消息的其他事件上(用戶對象)。同樣重要的是 當(dāng)多個 listener 被附加到單個事件時,它們將按照附加的順序同步執(zhí)行。因此 someOtherListener 將在 sendEmailOnRegistration 完成執(zhí)行后運行。
但是,如果你希望自己的 listener 以異步方式運行,只需用 setImmediate 包裝它們的實現(xiàn),如下所示:
module.exports = (user) => { setImmediate(() => { // Send a welcome email or whatever. }); }
讓你的 Listeners 保持簡潔
在寫 listener 時要堅持單一責(zé)任原則。一個 listener 應(yīng)該只做一件事并把事情做好。例如:要避免在 listener 中編寫太多的條件并根據(jù)事件傳來的數(shù)據(jù)(消息)去決定做什么。在這種情況下使用不同的事件會更加合適:
const myEmitter = require('./my_emitter'); // Perform the registration steps // The application should react differently if the new user has been activated instantly. if (user.activated) { myEmitter.emit('user-registered:activated', user); } else { myEmitter.emit('user-registered', user); }
const myEmitter = require('./my_emitter'); const sendEmailOnRegistration = require('./send_email_on_registration'); const someOtherListener = require('./some_other_listener'); const doSomethingEntirelyDifferent = require('./do_something_entirely_different'); myEmitter.on('user-registered', sendEmailOnRegistration); myEmitter.on('user-registered', someOtherListener); myEmitter.on('user-registered:activated', doSomethingEntirelyDifferent); view raw
必要時明確分離 Listener
在前面的例子中,我們的 listener 是完全獨立的函數(shù)。但是在 listener 與對象關(guān)聯(lián)的情況下(這時是一種方法),必須手動將其從已訂閱的事件中分離出來。否則對象將永遠(yuǎn)不會被垃圾回收,因為對象( listener )的一部分將會繼續(xù)被外部對象( emitter )引用,所以存在內(nèi)存泄漏的可能。
例如,如果我們正在開發(fā)一個聊天程序,并且希望當(dāng)新消息到達(dá)用戶進(jìn)入的聊天室時,顯示通知的功能應(yīng)該位于該用戶對象本身的內(nèi)部,我們可能會這樣做:
class ChatUser { displayNewMessageNotification(newMessage) { // Push an alert message or something. } // `chatroom` is an instance of EventEmitter. connectToChatroom(chatroom) { chatroom.on('message-received', this.displayNewMessageNotification); } disconnectFromChatroom(chatroom) { chatroom.removeListener('message-received', this.displayNewMessageNotification); } }
當(dāng)用戶關(guān)閉他的標(biāo)簽或暫時斷開互聯(lián)網(wǎng)連接時,我們可能希望在服務(wù)器端發(fā)起一個回調(diào),通知其他用戶有人剛剛下線。當(dāng)然在這時為脫機用戶調(diào)用 displayNewMessageNotification 沒有任何意義。除非我們刪除它,否則它將繼續(xù)被用于調(diào)用新消息。如果不這樣做,除了不必要的調(diào)用之外,用戶對象也會被永久地保留在內(nèi)存中。因此在用戶脫機時應(yīng)該在服務(wù)器端回調(diào)中調(diào)用 disconnectFromChatroom。
注意事項
如果不小心,即便是松散耦合的事件驅(qū)動架構(gòu)也會導(dǎo)致復(fù)雜性的增加,可能會導(dǎo)致在系統(tǒng)中跟蹤依賴關(guān)系變得很困難。如果我們從偵聽器內(nèi)部發(fā)出事件,程序會特別容易出現(xiàn)這類問題。這可能會觸發(fā)意外的事件鏈。
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,謝謝大家對腳本之家的支持。
相關(guān)文章
Nodejs Buffer的使用及Stream流和事件機制詳解
這篇文章主要為大家介紹了Nodejs Buffer的使用及Stream流和事件機制詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-10-10通過nodejs 服務(wù)器讀取HTML文件渲染到頁面的方法
今天小編就為大家分享一篇通過nodejs 服務(wù)器讀取HTML文件渲染到頁面的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2018-05-05Node.js多進(jìn)程的方法與參數(shù)實例說明
這篇文章主要介紹了Node.js多進(jìn)程的方法與參數(shù)實例說明,Node.js 是以單線程的模式運行的,但它使用的是事件驅(qū)動來處理并發(fā),這樣有助于我們在多核 cpu 的系統(tǒng)上創(chuàng)建多個子進(jìn)程,從而提高性能,需要的朋友可以參考下2023-05-05node?NPM庫qs?iconv-lite字符串編碼轉(zhuǎn)換及解析URL查詢學(xué)習(xí)
這篇文章主要為大家介紹了node?NPM庫之qs解析URL查詢字符串及iconv-lite字符串編碼轉(zhuǎn)換學(xué)習(xí),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-07-07Node.js操作mysql數(shù)據(jù)庫增刪改查
這篇文章主要介紹使用Node.js操作mysql數(shù)據(jù)庫增刪改查的相關(guān)資料,需要的朋友可以參考下2016-03-03