Node.js에 대한 자세한 설명: 이벤트 이벤트 모듈

대부분의 Nodejs 핵심 API는 비동기식 이벤트 중심 설계를 기반으로 설계되었습니다. 이벤트를 배포할 수 있는 모든 객체는 EventEmitter 클래스의 인스턴스입니다.

우리 모두 알고 있듯이 nodejs는 단일 스레드에서 실행되기 때문에 nodejs는 이벤트 폴링을 사용하여 이벤트 큐에 있는 이벤트 메시지를 지속적으로 쿼리한 다음 해당 이벤트에 해당하는 콜백 함수를 실행해야 합니다. Windows 메시지 매핑 메커니즘과 다소 유사합니다. 보다 자세한 구현 링크에 대해서는 별도로 정보를 찾을 수 있습니다.

다음은 EventEmitter의 사용법을 소개합니다.

1. 이벤트 수신 및 이벤트 배포

EventEmitter 인스턴스는 on 또는 addListener를 사용하여 이벤트를 수신할 수 있으며, Emit() 메서드는 아래와 같이 이벤트를 배포합니다.

const events = require('events'),
   EventEmitter = events.EventEmitter,
   util = require('util');
function myEmiter(){
  EventEmitter.call(this);
};
util.inherits(myEmiter,EventEmitter);//继承EventEmitter类
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',(o)=>{
  console.log('receive the data:'+o.a);
});

또는 클래스 클래스

class myEmiter extends EventEmitter{}//继承EventEmitter类
const myEmitterIns = new myEmiter();
 
myEmitterIns.on('data',(o)=>{
  console.log('receive the data:'+o.a);
});
myEmitterIns.emit('data',{a:1});

을 사용하여 실행 결과는 다음과 같습니다. :

E :developmentdocumentnodejsdemo>node event-example.js
데이터 수신:1

2. 이벤트 수신 콜백 함수에 매개변수 전달

위의 예에서 볼 수 있듯이, 방출() 메소드는 콜백 함수에 임의의 매개변수 세트를 전달할 수 있습니다. 한 가지 주목할 점은 this 키워드가 방출 메소드를 호출하는 EventEmiter 인스턴스를 가리킨다는 것입니다. 화살표 함수는 전역 this를 가리킵니다. 화살표 함수에서 this는 정의 시 바인딩되기 때문입니다. 아래와 같습니다.

class myEmiter extends EventEmitter{}
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',function(data){
  console.log("普通回调函数中this：");
  console.log(this);
});
myEmitterIns.on('data1',(data1)=>{
  console.log("箭头回调函数中this：");
  console.log(this);
});
myEmitterIns.emit('data',{a:1});
myEmitterIns.emit('data1',{a:1});

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
일반 콜백 함수 내에서는 다음과 같습니다.
myEmiter {
domain: null,
_events: { data: [Function], data1: [Function] },
_eventsCount: 2,
_maxListeners : 정의되지 않음 }
화살표 콜백 함수의 이 내용:
{}

여기서 화살표 함수의 이에 대해 이야기합니다. 그런데 화살표 함수가 정의되었을 때 이것을 바인딩할 수 있는 이유는 다음과 같습니다. 화살표 함수의 내부 기본 사항은 이것을 바인딩하는 메커니즘이 없기 때문에 외부 범위에서 이것을 사용하므로 생성자로 사용할 수 없습니다.

3. 이벤트 리스너의 실행 순서

EventEmiter 인스턴스는 여러 이벤트를 바인딩할 수 있습니다. 이러한 이벤트를 순차적으로 트리거하면 EventEmiter가 동기 모드로 실행됩니다. 처리 기능이 완료되지 않으면 아래와 같이 다음 이벤트가 발생하지 않습니다.

class myEmiter extends EventEmitter{}
const myEmitterIns = new myEmiter();
myEmitterIns.on('data',function(data){
  console.time('data事件执行了');
  for(var i = 0 ; i< 100000; i++)
    for(var j = 0 ; j< 100000; j++)
      ;
  console.timeEnd(&#39;data事件执行了&#39;);
});
myEmitterIns.on(&#39;data1&#39;,(data1)=>{
  console.log("data1事件开始执行...");
});
myEmitterIns.emit(&#39;data&#39;,{a:1});
myEmitterIns.emit(&#39;data1&#39;,{a:1});

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
데이터 이벤트가 실행되었습니다: 4721.401ms
data1 이벤트가 실행되기 시작했습니다...

물론 다음에서 비동기 작업을 사용할 수 있습니다. 아래와 같이 비동기 효과를 얻기 위해 setTimeout, setImmediate 또는 process.nextTick() 등과 같은 콜백 함수를 사용합니다.

myEmitterIns.on('data',function(data){
  setImmediate(()=>{
    console.log('data事件执行了...');
  });
});

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
data1 이벤트가 실행되었습니다...
data 이벤트가 실행되었습니다...

4. -시간 이벤트 모니터링

EventEmiter는 한 번만 사용하여 이벤트를 수신할 수 있으며 이벤트 핸들러는 한 번만 트리거됩니다. 그 후에는 표시된 것처럼 리스너가 로그아웃되므로 이벤트가 무시됩니다. 아래:

myEmitterIns.once('one',(data)=>{
  console.log(data);
});
myEmitterIns.emit('one','this is first call!');
myEmitterIns.emit('one','this is second call!');

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
this 첫 번째 호출입니다!

위 결과에서 알 수 있듯이 'one' 이벤트는 한 번만 실행됩니다.

5. 이벤트 바인딩 제거

DOM 이벤트 수신과 유사하게 EventEmiter는 이벤트 바인딩을 제거하고 RemoveListener(eventName,listener) 메서드를 사용하여 이벤트 바인딩을 해제할 수도 있습니다. 따라서 콜백 함수 리스너는 명명된 함수여야 합니다. 그렇지 않으면 함수를 찾을 수 없습니다. 함수는 참조 유형이므로 함수 본문이 동일하더라도 아래와 같이 동일한 함수가 아닙니다.

myEmitterIns.on('data',function(e){
  console.log(e);
});
myEmitterIns.removeListener('data',function(e){
  console.log(e);
});
myEmitterIns.emit('data','hello data!');
function deal(e){
  console.log(e);
}
myEmitterIns.on('data1',deal);
myEmitterIns.removeListener('data1',deal);
myEmitterIns.emit('data1','hello data1!');

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
hello data!
E :developmentdocumentnodejsdemo>

실행 결과를 보면 data 이벤트는 익명 함수를 사용하여 제거되지 않은 반면, data1 이벤트는 성공적으로 바인딩 해제된 것을 확인할 수 있습니다. 여기서 주목해야 할 점은 방출이 이벤트를 트리거한 후에는 이벤트에 바인딩된 모든 콜백 함수가 호출된다는 것입니다. 콜백 함수에서 RemoveListener 함수를 사용하여 다른 콜백을 제거하더라도 쓸모가 없지만 후속 이벤트 큐는 콜백을 제거했습니다. 아래와 같이:

function dealData1(e){
  console.log('data事件执行了...A');
}
myEmitterIns.on('data',function(e){
  console.log(e);
  myEmitterIns.removeListener('data',dealData1);//这里解除dealData1的绑定
});
myEmitterIns.on('data',dealData1);
myEmitterIns.emit('data','data事件执行了...B');
/*执行结果为：
 data事件执行了...B
 data事件执行了...A
*/
//再次触发该事件时,dealData1回调已经被解除绑定了
myEmitterIns.emit('data','data事件执行了...');
//data事件执行了...
   
另外可以使用removeAllListeners()解除所有事件的绑定。

6. 이벤트 리스너 수와 리스너 함수를 가져옵니다.

emitter.listenerCount(eventName) 함수를 사용하여 이벤트 리스너 수를 가져옵니다. 지정된 이벤트 및 Emitter.listeners(eventName) 함수를 사용하여 다음과 같이 지정된 이벤트의 모든 청취 기능을 얻을 수 있습니다.

var cbA = ()=>{},
  cbB = ()=>{};
var emitter = new myEmiter();
emitter.on('data',cbA);
emitter.on('data',cbB);
console.log('emitter实例的data事件绑定了%d个回调函数',emitter.listenerCount('data'));
console.log('它们是：',emitter.listeners('data'));

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
이미터 인스턴스의 데이터 이벤트는 2개의 콜백 함수에 바인딩됩니다
그들은 다음과 같습니다: [ [함수: cbA ], [함수: cbB] ]

7. 최대 이미터 리스너 수를 가져오고 설정하세요
Nodejs에서는 동일한 이벤트에 대한 리스너 수가 10을 초과하지 않을 것을 권장합니다. 이는 다음을 통해 확인할 수 있습니다. 아래와 같이 EventEmitter.defaultMaxListeners 속성을 확인합니다.

console.log(EventEmitter.defaultMaxListeners);//结果为10个

emitter는 getMaxListeners() 메서드를 통해 최대 리스너 수를 얻고 최대 수를 설정합니다. 아래와 같이 setMaxListeners(n) 메소드를 통해 청취자를 생성합니다.

var cbA = ()=>{},
  cbB = ()=>{};
var emitter = new myEmiter();
emitter.setMaxListeners(1);
emitter.on('data',cbA);
emitter.on('data',cbB);
console.log(emitter.getMaxListeners());

실행 결과는 다음과 같습니다.

E:developmentdocumentnodejsdemo>node event-example.js
최대 이미터 이벤트 리스너 수: 1
(node:6808) 경고: 가능 EventEmitter 메모리 누수가 감지되었습니다. 2개의 데이터 리스너
가 추가되었습니다. Emitter.setMaxListeners()를 사용하여 제한을 늘리세요

위 결과에서 볼 수 있듯이 최대 리스너 수가 설정된 경우에는 사용하지 않는 것이 가장 좋습니다. 동일한 이벤트에 대한 최대 리스너 수를 초과하지 않으면 메모리 누수가 발생할 수 있습니다.