Node.js EventEmitter

来源:https://www.cnblogs.com/chenyingying0/archive/2020/03/09/12448189.html
-Advertisement-
Play Games

events 模塊只提供了一個對象: events.EventEmitter。EventEmitter 的核心就是事件觸發與事件監聽器功能的封裝。 你可以通過require("events");來訪問該模塊。 //引入events模塊 var events=require("events"); // ...


events 模塊只提供了一個對象: events.EventEmitter。EventEmitter 的核心就是事件觸發與事件監聽器功能的封裝。

你可以通過require("events");來訪問該模塊。

//引入events模塊
var events=require("events");
//創建EventEmitter()對象
var eventEmitter=new events.EventEmitter();

 

EventEmitter 對象如果在實例化時發生錯誤,會觸發 error 事件。

當添加新的監聽器時,newListener 事件會觸發,當監聽器被移除時,removeListener 事件被觸發。

//引入events模塊
var events=require("events");
//創建EventEmitter()對象
var eventEmitter=new events.EventEmitter();

eventEmitter.on("myfn",function(){
    console.log("myfn被觸發了");
})

setTimeout(function(){
    eventEmitter.emit("myfn");//觸發事件
},1000)

 

 

 

帶參數的情況

//引入events模塊
var events=require("events");
//創建EventEmitter()對象
var eventEmitter=new events.EventEmitter();

eventEmitter.on("myfn",function(n1,n2){
    console.log(n1+n2);
})

setTimeout(function(){
    eventEmitter.emit("myfn",3,4);//觸發事件
},1000)

 

 

 

EventEmitter() 提供的方法:

addListener(event, listener)
為指定事件添加一個監聽器到監聽器數組的尾部。

on(event, listener)
為指定事件註冊一個監聽器,接受一個字元串 event 和一個回調函數。

server.on('connection', function (stream) {
  console.log('someone connected!');
});

once(event, listener)
為指定事件註冊一個單次監聽器,即 監聽器最多只會觸發一次,觸發後立刻解除該監聽器。

server.once('connection', function (stream) {
  console.log('Ah, we have our first user!');
});

removeListener(event, listener)

移除指定事件的某個監聽器,監聽器必須是該事件已經註冊過的監聽器。

它接受兩個參數,第一個是事件名稱,第二個是回調函數名稱。

var callback = function(stream) {
  console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);

removeAllListeners([event])
移除所有事件的所有監聽器, 如果指定事件,則移除指定事件的所有監聽器。

setMaxListeners(n)
預設情況下, EventEmitters 如果你添加的監聽器超過 10 個就會輸出警告信息。 setMaxListeners 函數用於提高監聽器的預設限制的數量。

listeners(event)
返回指定事件的監聽器數組。

emit(event, [arg1], [arg2], [...])
按監聽器的順序執行執行每個監聽器,如果事件有註冊監聽返回 true,否則返回 false。

 

類方法:

listenerCount(emitter, event)
返回指定事件的監聽器數量。

events.emitter.listenerCount(eventName) 
//引入events模塊
var events=require("events");
//創建EventEmitter()對象
var eventEmitter=new events.EventEmitter();
var count=eventEmitter.listenerCount("connection");
console.log("connection事件的監聽器數量"+count);

 

事件:

newListener

  • event - 字元串,事件名稱

  • listener - 處理事件函數

該事件在添加新監聽器時被觸發。

 

//引入events模塊
var events=require("events");
//創建EventEmitter()對象
var eventEmitter=new events.EventEmitter();

//監聽器listener1
var listener1=function listener1(){
    console.log("監聽器listener1執行")
}
//監聽器listener2
var listener2=function listener2(){
    console.log("監聽器listener2執行")
}

//為connection事件綁定兩個監聽器
eventEmitter.on("connection",listener1);
eventEmitter.on("connection",listener2);

//列印監聽器數量
var count=eventEmitter.listenerCount("connection");
console.log("connection事件的監聽器數量"+count);

//觸發connection事件
eventEmitter.emit("connection");

//移除監聽器listener1
eventEmitter.removeListener("connection",listener1);
console.log("監聽器listener1不再監聽");

//觸發connection事件
eventEmitter.emit("connection");

//移除監聽器listener2
eventEmitter.removeListener("connection",listener2);
console.log("監聽器listener2不再監聽");

//再次列印監聽器數量
count=eventEmitter.listenerCount("connection");
console.log("connection事件的監聽器數量"+count);

console.log("結束");

 

 

removeListener

  • event - 字元串,事件名稱

  • listener - 處理事件函數

從指定監聽器數組中刪除一個監聽器。需要註意的是,此操作將會改變處於被刪監聽器之後的那些監聽器的索引。

 

EventEmitter 定義了一個特殊的事件 error,它包含了錯誤的語義,我們在遇到 異常的時候通常會觸發 error 事件。

當 error 被觸發時,EventEmitter 規定如果沒有響 應的監聽器,Node.js 會把它當作異常,退出程式並輸出錯誤信息。

我們一般要為會觸發 error 事件的對象設置監聽器,避免遇到錯誤後整個程式崩潰。

//引入events模塊
var events=require("events");
//創建EventEmitter()對象
var eventEmitter=new events.EventEmitter();

//觸發error
eventEmitter.emit("error");

 

 

大多數時候我們不會直接使用 EventEmitter,而是在對象中繼承它。

包括 fs、net、 http 在內的,只要是支持事件響應的核心模塊都是 EventEmitter 的子類。

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 概述 Proxy 與 Reflect是 ES6為了操作對象引入的 API 。Proxy可以對目標對象的讀取、函數調用等操作進行攔截,然後進行操作處理。它不直接操作對象,而是像代理模式,通過對象的代理對象進行操作,在進行這些操作時,可以添加一些需要的額外操作。 Proxy的存在就相當於 在對象的讀取、 ...
  • 0.獲取源碼 https://github.com/vuejs/vue 從github地址,直接download下來就行了。在新建項目的時候也可以node_modelus里的vue搭配著看。 1.數據的掛載 首先先引入vue,然後新建他的實例。 首先我們得知道我們引入 的是個什麼東西。所以我們找到源 ...
  • H5微信是沒有直接分享的功能,想要微信分享,只能用微信內置好的分享菜單,所以,想自定義微信直接分享的朋友們,趁早換種方式吧,比如改為二維碼形式也不錯 前言 微信jssdk文檔介紹的微信分享api不詳細,坑賊多,還限制多,太霸道了 微信分享的坑 在可以調用微信jssdk的基礎介面前提下,調起分享介面, ...
  • 努力的一天又開始了,編輯這一篇文章,寫下當初我自學web前端走的彎路,希望大家引以為戒,不要多走前人走過的彎路,浪費時間。 彎路一:盲目的去學當初我在對於web前端這個行業什麼都不瞭解的情況下,比如:不知道未來發展趨勢,不知道學習web前端應該註意哪些初始問題,不知道具體的學習規劃學習路線等等,一味 ...
  • 寬度自適應: 預設寬度100%的元素 width:;單位為% 最小寬度自適應: min-width:; 最大寬度自適應: max-width:; 高度自適應: 不寫height,讓內容撐起 height:50%; 前提==>html,body{height:100%;} 最小高度自適應: min-h ...
  • 理解 隨著前端業務的發展, 我們一般在寫一個較為大型的 項目時候,會使用到 ,來根據指定的 或者 來進行內容的分發,可以達到不像服務端發送請求,就完成頁面內容的切換,能夠減少像伺服器發送的請求,讓用戶進行頁面跳轉時候能夠更快,體驗更好 疑問 在初學 的時候,一般人都會有一個印象, 以及 都是 原生自 ...
  • Vue 項目開發過程中,經常用到插件,比如原生插件 `vue-router`、`vuex`,還有 `element-ui` 提供的 `notify`、`message` 等等。這些插件讓我們的開發變得更簡單更高效。那麼 Vue 插件是怎麼開發的呢?如何自己開發一個 Vue 插件然後打包發佈到npm? ...
  • JavaScript 語言自身只有字元串數據類型,沒有二進位數據類型。 但在處理像TCP流或文件流時,必須使用到二進位數據。 因此在 Node.js中,定義了一個 Buffer 類,該類用來創建一個專門存放二進位數據的緩存區。 在v6.0之前創建Buffer對象直接使用new Buffer()構造函 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...