nodejs의 이벤트 모듈에 대한 심층 분석

이 글에서는 node의 이벤트 모듈을 자세히 소개하겠습니다. 도움이 필요한 친구들이 모두 참고할 수 있기를 바랍니다.

관련 권장 사항: "nodejs tutorial"

events 모듈은 node의 핵심 모듈입니다. 일반적으로 사용되는 거의 모든 노드 모듈은 http, fs 등과 같은 이벤트 모듈을 상속합니다. 이 기사에서는 nodeJS의 이벤트 메커니즘을 자세히 소개합니다.

EventEmitter

대부분의 Node.js 핵심 API는 특정 유형의 객체(트리거라고 함)가 이름이 지정된 이벤트를 주기적으로 트리거하는 기존 비동기 이벤트 기반 아키텍처를 채택합니다. 객체(청취자). 예를 들어, net.Server 객체는 새로운 연결이 있을 때마다 이벤트를 트리거합니다. fs.ReadStream은 파일이 열릴 때 이벤트를 트리거합니다. 스트림은 데이터를 읽을 수 있을 때 이벤트를 트리거합니다.

【EventEmitter】

　EventEmitter 클래스는 이벤트 모듈에 의해 정의되고 열립니다. 이벤트를 트리거할 수 있는 모든 객체는 EventEmitter 클래스의 인스턴스입니다.

var EventEmitter = require('events');
/*
{ [Function: EventEmitter]
  EventEmitter: [Circular],
  usingDomains: false,
  defaultMaxListeners: [Getter/Setter],
  init: [Function],
  listenerCount: [Function] }
 */
console.log(EventEmitter);

　이벤트 모듈의 EventEmitter 속성은 모듈 자체를 가리킵니다.

var events = require('events');
console.log(events.EventEmitter === events);//true

EventEmitter 생성자입니다. 이벤트 생성기 이미터의 인스턴스를 생성하는 데 사용할 수 있습니다.

var EventEmitter = require('events');
var emitter = new EventEmitter();
/*
EventEmitter {
  domain: null,
  _events: {},
  _eventsCount: 0,
  _maxListeners: undefined }
 */
console.log(emitter);

method

[emitter.emit(eventName[, ...args])]

eventName <any>
...args <any></any></any>

　이 메서드는 등록된 각 리스너를 순서대로 동기적으로 호출합니다. 제공된 매개변수를 전달하는 eventName이라는 이벤트에 대한 리스너입니다. 이벤트에 리스너가 있으면 true를 반환하고 그렇지 않으면 false를 반환

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test1',function(){});
console.log(emitter.emit('test1'));//true
console.log(emitter.emit('test2'));//false

【emitter.on(eventName,listener)】

　이 메소드는 eventName이라는 이벤트에 대한 리스너 배열 끝에 리스너 함수를 추가하는 데 사용됩니다

eventName <any> 事件名
listener <function> 回调函数</function></any>

[참고] 리스너 추가 여부를 확인하지 않습니다. 여러 번 호출하고 동일한 eventName과 리스너를 전달하면 리스너가 여러 번 추가되고 호출됩니다.

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
});
emitter.on('test',function(){
    console.log(2);
});
emitter.emit('test');//1 2

　이 메서드는 체인에서 호출할 수 있는 EventEmitter 참조를 반환합니다

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
}).on('test',function(){
    console.log(2);
});
emitter.emit('test');//1 2

【emitter.addListener(eventName, Listener) )】

　emitter Alias ​​of .on(eventName,listener)

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.addListener('test',function(){
    console.log(1);
});
emitter.emit('test');//1

【emitter.prependListener()】

on() 메서드와 달리 prependListener() 메서드는 이벤트 리스너를 이벤트 리스너에 추가하는 데 사용할 수 있습니다. 리스너 배열의 시작

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
}).prependListener('test',function(){
    console.log(2);
});
emitter.emit('test');//2 1

【emitter .once(eventName,listener)】

　이 메소드는 eventName이라는 이벤트에 일회성 리스너 함수를 추가합니다. 다음에 eventName 이벤트가 트리거되면 리스너가 제거된 후

eventName <any> 事件名
listener <function> 回调函数</function></any>

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
}).once('test',function(){
    console.log(2);
});
emitter.emit('test');//1 2
emitter.emit('test');//1

[emitter.prependOnceListener()]

　이 메소드는 리스너 배열의 시작 부분에 이벤트 리스너를 추가하는 데 사용됩니다. 다음에 eventName 이벤트가 트리거되면 리스너가 제거되고

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
}).prependOnceListener('test',function(){
    console.log(2);
});
emitter.emit('test');//2 1
emitter.emit('test');//1

【emitter.removeAllListeners([eventName])】

eventName <any></any>

　를 호출하여 모든 또는 지정된 eventName 리스너를 제거하고 EventEmitter 참조를 반환합니다. 연쇄 호출

　　[참고] 코드의 다른 곳에 추가된 리스너를 제거하는 것은 나쁜 습관입니다. 특히 EventEmitter 인스턴스가 다른 구성 요소나 모듈(예: 소켓 또는 파일 스트림)에 의해 생성되는 경우

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
}).removeAllListeners('test');
emitter.emit('test');//''

[emitter.removeListener(eventName , 리스너)】

eventName <any>
listener <function></function></any>

　eventName

var EventEmitter = require('events');
var emitter = new EventEmitter();
function show(){
    console.log(1);
}
emitter.on('test',show).removeListener('test',show);
emitter.emit('test');//''

　라는 이벤트의 리스너 배열에서 지정된 리스너를 제거합니다.[참고] RemoveListener는 리스너 배열에서 최대 하나의 리스너 인스턴스만 제거합니다. 단일 리스너가 지정된 eventName에 대한 리스너 배열에 여러 번 추가된 경우 각 인스턴스를 제거하려면 RemoveListener를 여러 번 호출해야 합니다.

var EventEmitter = require('events');
var emitter = new EventEmitter();
function show(){
    console.log(1);
}
emitter.on('test',show).on('test',show).removeListener('test',show);
emitter.emit('test');//'1'

　 [참고] 이벤트가 트리거되면 이벤트에 바인딩된 모든 리스너가 트리거됩니다. 순서. 이는 이벤트가 발생한 후 마지막 리스너의 실행이 완료되기 전에 RemoveListener() 또는 RemoveAllListeners()를 호출해도 Emit()에서 해당 이벤트가 제거되지 않음을 의미합니다. 후속 이벤트는 예상대로 발생합니다.

리스너는 내부 배열을 사용하여 관리되므로 이를 호출하면 리스너가 제거된 후 등록된 모든 리스너의 위치 인덱스가 변경됩니다. 이는 리스너가 호출되는 순서에 영향을 미치지 않지만, Emitter.listeners() 메서드에서 반환된 리스너 배열의 복사본을 다시 생성해야 함을 의미합니다

var EventEmitter = require('events');
var emitter = new EventEmitter();
function show1(){
    console.log(1);
    emitter.removeListener('test',show2);
}
function show2(){
    console.log(2);
}
emitter.on('test',show1).on('test',show2);
emitter.emit('test');//1 2
emitter.emit('test');//1

settings

【emitter.eventNames()】

목록을 반환합니다. Trigger 리스너가 등록된 이벤트 배열입니다. 배열의 값은 문자열 또는 기호입니다

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.addListener('test1',function(){console.log(1);});
emitter.addListener('test2',function(){console.log(2);});
console.log(emitter.eventNames());//[ 'test1', 'test2' ]

【emitter.listenerCount(eventName)】

eventName <any> 正在被监听的事件名</any>

　 eventName

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.addListener('test',function(){console.log(1);});
emitter.addListener('test',function(){console.log(1);});
console.log(emitter.listenerCount('test'));//2

【emitter.listeners(eventName)】

이라는 이벤트를 듣고 있는 리스너의 수를 반환합니다.

eventName <any></any>

eventName

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.addListener('test',function(){console.log(1);});
emitter.addListener('test',function(){console.log(2);});
console.log(emitter.listeners('test'));//[ [Function], [Function] ]emitter.listeners('test')[0]();//1

【emitter.getMaxListeners()】

　 EventEmitter

var EventEmitter = require('events');
var emitter = new EventEmitter();
console.log(emitter.getMaxListeners());//10

【emitter.setMaxListeners(n)】

의 현재 최대 리스너 제한 값을 반환합니다.

　　默认情况下，如果为特定事件添加了超过 10 个监听器，则 EventEmitter 会打印一个警告。 此限制有助于寻找内存泄露。 但是，并不是所有的事件都要被限为 10 个。 emitter.setMaxListeners() 方法允许修改指定的 EventEmitter 实例的限制。 值设为 Infinity（或 0）表明不限制监听器的数量。返回一个 EventEmitter 引用，可以链式调用

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){});
/*
Warning: Possible EventEmitter memory leak detected. 11 a listeners added. Use emitter.setMaxListeners() to increase limit
 */

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.setMaxListeners(11);
emitter.on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){});

【EventEmitter.defaultMaxListeners】
　　每个事件默认可以注册最多10个监听器。单个EventEmitter实例的限制可以使用emitter.setMaxListeners(n)方法改变。所有EventEmitter实例的默认值可以使用EventEmitter.defaultMaxListeners属性改变

　　[注意]设置 EventEmitter.defaultMaxListeners 要谨慎，因为会影响所有EventEmitter 实例，包括之前创建的。因而，调用 emitter.setMaxListeners(n) 优先于 EventEmitter.defaultMaxListeners

var EventEmitter = require('events');var emitter = new EventEmitter();
EventEmitter.defaultMaxListeners = 11;
emitter.on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){}).on('a',function(){});

事件

【'newListener' 事件】

eventName <any> 要监听的事件的名称
listener <function> 事件的句柄函数</function></any>

　　EventEmitter 实例会在一个监听器被添加到其内部监听器数组之前触发自身的 'newListener' 事件

　　注册了 'newListener' 事件的监听器会传入事件名与被添加的监听器的引用。事实上，在添加监听器之前触发事件有一个微妙但重要的副作用： 'newListener' 回调中任何额外的被注册到相同名称的监听器会在监听器被添加之前被插入 

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('newListener',function(){
    console.log(2);
})
emitter.on('test',function(){
    console.log(1);
})

emitter.emit('test');//2 1

var EventEmitter = require('events');
var emitter = new EventEmitter();
emitter.on('test',function(){
    console.log(1);
})
emitter.on('newListener',function(){
    console.log(2);
})
emitter.emit('test');//1

【'removeListener' 事件】

eventName <any> 事件名
listener <function> 事件句柄函数</function></any>

　　'removeListener' 事件在 listener 被移除后触发

var EventEmitter = require('events');
var emitter = new EventEmitter();
function show(){
    console.log(1);
}
emitter.on('removeListener',function(){
    console.log(2);//2})
emitter.on('test',show).removeListener('test',show);

var EventEmitter = require('events');
var emitter = new EventEmitter();
function show(){
    console.log(1);
}
emitter.on('test',show).removeListener('test',show);
emitter.on('removeListener',function(){
    console.log(2);//''})

var EventEmitter = require('events');
var emitter = new EventEmitter();
function show(){
    console.log(1);
}
emitter.removeListener('test',show);
emitter.on('removeListener',function(){
    console.log(2);//''})

更多编程相关知识，请访问：编程视频！！

위 내용은 nodejs의 이벤트 모듈에 대한 심층 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!