Node.js_node.js의 이벤트 이미터 패턴을 사용한 이벤트 바인딩에 대한 자세한 설명

Node에서는 많은 객체가 이벤트를 발생시킵니다. 예를 들어, TCP 서버는 클라이언트가 연결을 요청할 때마다 "connect" 이벤트를 발생시킵니다. 예를 들어, 전체 데이터 블록을 읽을 때마다 파일 시스템은 "data" 이벤트를 발생시킵니다. 이러한 객체를 Node.js에서는 이벤트 이미터라고 합니다. 이벤트 이미터를 사용하면 프로그래머가 관심 있는 이벤트를 구독하고 콜백 함수를 관련 이벤트에 바인딩할 수 있으므로 이벤트 이미터가 이벤트를 내보낼 때마다 콜백 함수가 호출됩니다. 게시/구독 모드는 기존 GUI 모드와 매우 유사합니다. 예를 들어 버튼을 클릭하면 프로그램이 해당 알림을 받습니다. 이 모드를 사용하면 클라이언트가 연결되거나 소켓에서 데이터를 사용할 수 있거나 파일이 닫힐 때와 같은 일부 이벤트가 발생할 때 서버 프로그램이 반응할 수 있습니다.

또한 자체 이벤트 이미터를 생성할 수도 있습니다. 실제로 Node는 자체 이벤트 이미터를 생성하기 위한 기본 클래스로 사용할 수 있는 EventEmitter 의사 클래스를 제공합니다.

콜백 패턴 이해

비동기 프로그래밍은 함수 호출의 끝을 나타내기 위해 함수 반환 값을 사용하지 않고 후속 전달 스타일을 채택합니다.

"Continuation-passing 스타일"(CPS: Continuation-passing style)은 흐름 제어가 명시적으로 다음 작업으로 전달되는 프로그래밍 스타일입니다...

CPS 스타일 함수는 함수를 추가 매개변수로 허용합니다. 이 함수는 프로그램에 의해 제어되는 다음 프로세스를 명시적으로 나타내는 데 사용됩니다. CPS 함수는 "반환 값"을 계산할 때 해당 프로세스를 나타내는 함수를 호출합니다. 프로그램의 다음 단계에서 프로세스의 함수를 실행하고 CPS 함수의 "반환 값"을 매개변수로 사용합니다.

위키피디아에서 - http://en.wikipedia.org/wiki/Continuation-passing_style

이 프로그래밍 스타일에서는 각 함수가 실행 후 콜백 함수를 호출하므로 프로그램이 계속 실행될 수 있습니다. 나중에 JavaScript가 이 프로그래밍 스타일에 매우 적합하다는 것을 이해하게 될 것입니다. 다음은 노드 아래의 메모리에 파일을 로드하는 예입니다.

코드 복사 코드는 다음과 같습니다.

var fs = require('fs');

fs.readFile('/etc/passwd', function(err, fileContent) {

if (err) {

던지기 오류;

}

console.log('파일 콘텐츠', fileContent.toString());

});

이 예에서는 인라인 익명 함수를 fs.readFile의 두 번째 매개 변수로 전달합니다. 실제로 이는 프로그램 실행의 후속 프로세스를 콜백 함수에 넘기기 때문에 CPS를 사용한 프로그래밍입니다.

보시다시피 콜백 함수의 첫 번째 매개변수는 오류 객체입니다. 프로그램에서 오류가 발생하면 이 매개변수는 Error 클래스의 인스턴스가 됩니다. 이는 Node.js의 CPS 프로그래밍에서 일반적인 패턴입니다.

이벤트 이미터 패턴 이해

표준 콜백 모드에서는 함수가 실행될 함수에 매개변수로 전달됩니다. 이 모드는 함수가 완료된 후 클라이언트에 알려야 하는 시나리오에서 잘 작동합니다. 그러나 이 모델은 함수 실행 중에 여러 이벤트가 발생하거나 해당 이벤트가 여러 번 반복적으로 발생하는 경우에는 적합하지 않습니다. 예를 들어, 소켓이 사용 가능한 데이터를 수신할 때마다 알림을 받으려면 표준 콜백 모드를 사용하기가 쉽지 않습니다. 이때 이벤트 이미터 모드를 사용할 수 있습니다. 이벤트 생성기와 이벤트 리스너를 명확하게 분리하기 위한 표준 인터페이스 세트입니다.

이벤트 생성기 패턴을 사용할 때 두 개 이상의 객체, 즉 이벤트 방출자와 하나 이상의 이벤트 리스너가 관련됩니다.

이벤트 이미터는 이름에서 알 수 있듯이 이벤트를 생성할 수 있는 객체입니다. 이벤트 리스너는 다음 예와 같이 특정 유형의 이벤트를 수신하기 위해 이벤트 이미터에 바인딩된 코드입니다.

코드 복사 코드는 다음과 같습니다.

var req = http.request(옵션, 함수(응답)) {

response.on("data", function(data) {

console.log("응답의 일부 데이터", data);

});

response.on("end", function() {

console.log("응답이 종료되었습니다");

});

});

req.end();

이 코드는 Node의 http.request API를 사용하여 원격 HTTP 서버에 액세스하기 위한 HTTP 요청을 생성하는 데 필요한 두 단계를 보여줍니다(이후 장 참조). 첫 번째 줄은 "continuation-passing 스타일"(CPS: Continuation-passing 스타일)을 사용하여 HTTP 응답이 생성될 때 호출되는 인라인 함수를 전달합니다. HTTP 요청 API는 http.request 함수가 실행된 후에도 프로그램이 후속 작업을 계속 수행해야 하기 때문에 여기서 CPS를 사용합니다.

http.request가 실행되면 익명 콜백 함수가 호출되고 HTTP 응답 객체가 매개변수로 전달됩니다. 이 HTTP 응답 객체는 노드 문서에 따르면 가능합니다. Emit data, end at 많은 이벤트의 경우 등록한 콜백 함수는 이벤트가 발생할 때마다 호출됩니다.

요청한 작업이 완료된 후 실행 권한을 다시 받아야 하는 경우에는 CPS 패턴을 사용하고, 이벤트가 여러 번 발생할 수 있는 경우에는 Event Emitter 패턴을 사용하는 것이 일반적입니다.

이벤트 유형 이해

내보낸 이벤트에는 문자열로 표시되는 유형이 있습니다. 이전 예에는 "data"와 "end"라는 두 가지 이벤트 유형이 포함되어 있습니다. 이벤트 유형은 이벤트 방출기에 의해 정의된 임의의 문자열이지만 일반적으로 이벤트 유형은 소문자로 구성됩니다. 널 문자를 포함하지 않는 단어.

이벤트 이미터 API에는 내부 검사 메커니즘이 없기 때문에 코드를 사용하여 이벤트 이미터가 생성할 수 있는 이벤트 유형을 추론할 수 없습니다. 따라서 사용하는 API에는 어떤 유형의 이벤트를 생성할 수 있는지 보여주는 문서가 있어야 합니다.

이벤트가 발생하면 이벤트 이미터는 이벤트와 관련된 리스너를 호출하고 관련 데이터를 리스너에 매개변수로 전달합니다. 이전 http.request 예제에서 "data" 이벤트 콜백 함수는 데이터 객체를 첫 번째이자 유일한 매개변수로 받아들이는 반면, "end"는 어떤 데이터도 받아들이지 않습니다. 이러한 매개변수 역시 API의 일부로 API 작성자에 의해 결정됩니다. 주관적으로 정의된 이러한 콜백 함수의 매개변수 서명은 각 이벤트 이미터의 API 문서에도 설명되어 있습니다.

이벤트 이미터는 모든 유형의 이벤트를 제공하는 인터페이스이지만 "오류" 이벤트는 Node.js에서 특별하게 구현됩니다. Node의 대부분의 이벤트 이미터는 프로그램에서 오류가 발생할 때 "오류" 이벤트를 생성합니다. 프로그램이 이벤트 이미터의 "오류" 이벤트를 수신하지 않으면 이벤트 이미터는 오류가 발생할 때 이를 인지하고 발생시킵니다. . 잡히지 않는 예외.

Node PERL에서 다음 코드를 실행하여 효과를 테스트할 수 있습니다. 이는 두 가지 이벤트를 생성할 수 있는 이벤트 이미터를 시뮬레이션합니다.

코드 복사 코드는 다음과 같습니다.

var em = new (require('events').EventEmitter)();

em.emit('event1');

em.emit('error', new Error('내 실수'));

다음과 같은 출력이 표시됩니다.

코드 복사 코드는 다음과 같습니다.

var em = new (require('events').EventEmitter)();

정의되지 않음

> em.emit('event1');

거짓

> em.emit('error', new Error('내 실수'));

오류: 내 실수입니다

답변:1:18

REPLServer.eval(repl.js:80:21)

repl.js:190:20

REPLServer.eval(repl.js:87:5)

Interface.(repl.js:182:12)

Interface.emit(events.js:67:17)

Interface._onLine(readline.js:162:10)

Interface._line(readline.js:426:8)

Interface._ttyWrite(readline.js:603:14)

ReadStream에서.(readline.js:82:12)

>

코드의 두 번째 줄에서는 "event1"이라는 이벤트가 무작위로 발생하며 아무런 효과가 없습니다. 그러나 "error" 이벤트가 발생하면 오류가 스택에 발생합니다. 프로그램이 PERL 명령줄 환경에서 실행되고 있지 않으면 포착되지 않은 예외로 인해 프로그램이 중단됩니다.

이벤트 이미터 API 사용

이벤트 이미터 패턴(예: TCP 소켓, HTTP 요청 등)을 구현하는 모든 개체는 다음 메서드 세트를 구현합니다.

코드 복사 코드는 다음과 같습니다.

.addListener 및 .on - 지정된 이벤트 유형에 대한 이벤트 리스너 추가
.once - 지정된 이벤트 유형에 대해 한 번만 실행되는 이벤트 리스너를 바인딩합니다.
.removeEventListener - 지정된 이벤트에 바인딩된 리스너를 제거합니다.
.removeAllEventListener - 지정된 이벤트에 바인딩된 모든 리스너를 제거합니다

아래에서 자세히 소개합니다.

콜백 함수를 바인딩하려면 .addListener() 또는 .on()을 사용하세요.

이벤트 종류와 콜백 함수를 지정하여 이벤트 발생 시 수행할 동작을 등록할 수 있습니다. 예를 들어, 파일이 데이터 스트림을 읽을 때 사용 가능한 데이터 블록이 있으면 "data" 이벤트가 발생합니다. 다음 코드는 콜백 함수를 전달하여 프로그램이 데이터 이벤트가 발생했음을 알리도록 하는 방법을 보여줍니다. .

코드 복사 코드는 다음과 같습니다.

함수 receiveData(데이터) {

console.log("파일 읽기 스트림에서 데이터를 얻었습니다: %j", data);

}

readStream.addListener(“data”, receiveData);

또한 .addListener의 약어인 .on을 사용할 수도 있습니다. 다음 코드는 위와 동일합니다.

코드 복사 코드는 다음과 같습니다.

함수 receiveData(데이터) {

console.log("파일 읽기 스트림에서 데이터를 얻었습니다: %j", data);

}
readStream.on(“data”, receiveData);

이전 코드에서는 콜백 함수로 미리 정의된 명명된 함수를 사용합니다. 또한 인라인 익명 함수를 사용하여 코드를 단순화할 수도 있습니다.

코드 복사 코드는 다음과 같습니다.

readStream.on("data", function(data) {

console.log("파일 읽기 스트림에서 데이터를 얻었습니다: %j", data);

});

앞서 언급했듯이 콜백 함수에 전달되는 매개변수의 수와 서명은 특정 이벤트 이미터 객체와 이벤트 유형에 따라 다릅니다. "data" 이벤트는 데이터 버퍼 객체를 전달할 수 있으며 "error" 이벤트는 다음과 같습니다. 데이터 버퍼 개체를 전달합니다. 오류 개체를 전달하면 데이터 흐름의 "종료" 이벤트는 이벤트 리스너에 데이터를 전달하지 않습니다.

여러 이벤트 리스너 바인딩

이벤트 이미터 패턴을 사용하면 여러 이벤트 리스너가 다음과 같이 동일한 이벤트 이미터의 동일한 이벤트 유형을 수신할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

여기에 데이터가 있습니다.

여기에도 데이터가 있습니다.

이벤트 이미터는 리스너가 등록된 순서대로 지정된 이벤트 유형에 바인딩된 모든 리스너를 호출하는 역할을 합니다. 즉,

1. 이벤트가 발생하면 이벤트 리스너가 즉시 호출되지 않을 수 있습니다.
2. 스택에 예외가 발생하는 것은 비정상적인 동작입니다. 코드에 버그가 있기 때문일 수 있습니다. 이벤트가 호출될 때 이벤트 리스너가 예외를 발생시키면 일부 이벤트가 발생할 수 있습니다. 청취자는 호출되지 않습니다. 이 경우 이벤트 이미터는 예외를 포착하고 처리할 수도 있습니다.

이 예를 보세요:

코드 복사 코드는 다음과 같습니다.

readStream.on("data", function(data) {

새로운 오류 발생("뭔가 문제가 발생했습니다");

});

readStream.on("data", function(data) {

console.log('여기에도 데이터가 있습니다.');

});

첫 번째 리스너가 예외를 발생시켰기 때문에 두 번째 리스너는 호출되지 않습니다.

.removeListener()를 사용하여 이벤트 이미터에서 이벤트 리스너 제거

객체의 이벤트에 더 이상 관심이 없다면 다음과 같이 이벤트 유형과 콜백 함수를 지정하여 등록된 이벤트 리스너를 취소할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

함수 receiveData(데이터) {

console.log("파일 읽기 스트림에서 데이터를 얻었습니다: %j", data);

}

readStream.on("data", receiveData);

// ...

readStream.removeListener("data", receiveData);

이 예에서 마지막 줄은 향후 언제든지 호출될 수 있는 이벤트 이미터 객체에서 이벤트 리스너를 제거합니다.

리스너를 삭제하려면 콜백 함수 이름을 지정해야 합니다. 추가 및 제거 시 콜백 함수 이름이 필요하기 때문입니다.

콜백 함수를 최대 한 번 실행하려면 .once()를 사용하세요.

최대 한 번 실행될 수 있는 이벤트를 모니터링하고 싶거나 이벤트가 처음 발생할 때만 관심이 있는 경우 .once() 함수를 사용할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

함수 receiveData(데이터) {

console.log("파일 읽기 스트림에서 데이터를 얻었습니다: %j", data);

}

readStream.once("data", receiveData);

위 코드에서 receiveData 함수는 한 번만 호출됩니다. readStream 객체가 데이터 이벤트를 발생시키는 경우 receiveData 콜백 함수는 한 번만 트리거됩니다.

실제로는 편의를 위한 방법일 뿐입니다. 다음과 같이 구현이 매우 간단하기 때문입니다.

코드 복사 코드는 다음과 같습니다.

var EventEmitter = require("events").EventEmitter;

EventEmitter.prototype.once = 함수(유형, 콜백) {

var that = this;

this.on(유형, 함수 리스너() {

that.removeListener(유형, 리스너);

callback.apply(that, 인수);

});

};

위 코드에서는 EventEmitter.prototype.once 함수를 재정의하고 EventEmitter에서 상속되는 각 객체의 Once 함수도 재정의합니다. 코드는 단순히 .on() 메서드를 사용합니다. 이벤트가 수신되면 .removeEventListener()를 사용하여 콜백 함수 등록을 취소하고 원래 콜백 함수를 호출합니다.

참고: function.apply() 메서드는 이전 코드에서 사용되었으며, 이 메서드는 객체를 허용하고 이를 포함된 이 변수 ​​및 매개변수 배열로 사용합니다. 이전 예에서는 수정되지 않은 매개변수 배열이 이벤트 이미터를 통해 콜백 함수에 투명하게 전달됩니다.

.removeAllListeners()를 사용하여 이벤트 이미터에서 모든 이벤트 리스너를 제거합니다.

다음과 같이 이벤트 이미터에서 지정된 이벤트 유형에 등록된 모든 리스너를 제거할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

Emitter.removeAllListeners(type);

예를 들어 다음과 같이 모든 프로세스 인터럽트 신호 리스너를 취소할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

process.removeAllListeners("SIGTERM");

참고: 경험상 무엇을 삭제할지 정확히 알고 있는 경우에만 이 기능을 사용하는 것이 좋습니다. 그렇지 않으면 애플리케이션의 다른 부분이 이벤트 리스너 컬렉션을 삭제하도록 허용해야 합니다. 애플리케이션이 스스로 책임을 집니다. 리스너를 제거합니다. 그러나 어떤 경우에도 이 기능은 이벤트 발생기를 순서대로 종료하거나 전체 프로세스를 종료하려고 준비하는 경우와 같은 일부 드문 시나리오에서 여전히 매우 유용합니다.

이벤트 이미터 생성

이벤트 이미터는 프로그래밍 인터페이스를 더욱 다양하게 만드는 좋은 방법입니다. 일반적이고 이해하기 쉬운 프로그래밍 패턴에서는 클라이언트가 다양한 함수를 직접 호출하는 반면, 이벤트 이미터 패턴에서는 클라이언트가 다양한 이벤트에 바인딩됩니다. 이렇게 하면 프로그램이 더욱 유연해집니다. (역자 주: 이 문장은 그다지 확신이 없기 때문에 원본 텍스트를 게시했습니다. 이벤트 이미터는 프로그래밍 인터페이스를 보다 일반적으로 만드는 훌륭한 방법을 제공합니다. 일반적으로 이해되는 패턴을 사용하면 클라이언트는 함수를 호출하는 대신 이벤트에 바인딩됩니다. 프로그램을 더욱 유연하게 만듭니다.)

또한 이벤트 이미터를 사용하면 관련되지 않은 여러 리스너를 동일한 이벤트에 바인딩하는 등 많은 기능을 얻을 수도 있습니다.

노드 이벤트 이미터에서 상속

Node의 이벤트 이미터 패턴에 관심이 있고 이를 자신의 애플리케이션에서 사용할 계획이라면 EventEmitter를 상속하여 의사 클래스를 생성할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

util = require('util');

var EventEmitter = require('events').EventEmitter;

// 이것은 MyClass의 생성자입니다:

var MyClass = function() {

}

util.inherits(MyClass, EventEmitter);

참고: util.inherits는 MyClass 인스턴스가 EventEmitter의 프로토타입 메서드를 사용할 수 있도록 MyClass의 프로토타입 체인을 설정합니다.

런칭 이벤트

EventEmitter를 상속함으로써 MyClass는 다음과 같은 이벤트를 내보낼 수 있습니다.

코드 복사 코드는 다음과 같습니다.

MyClass.prototype.someMethod = function() {

this.emit("맞춤 이벤트", "인수 1", "인수 2");

};

위 코드에서 MyClass의 인스턴스에 의해 someMethod 메소드가 호출되면 "cuteom event"라는 이벤트가 발생합니다. 이 이벤트는 "argument 1" 및 "argument 2"라는 두 문자열도 데이터로 발생시킵니다. , 이벤트 리스너에 매개변수로 전달됩니다.

MyClass 인스턴스의 클라이언트는 다음과 같은 "사용자 정의 이벤트" 이벤트를 수신할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

var myInstance = new MyClass();

myInstance.on('맞춤 이벤트', function(str1, str2) {

console.log('str1 %s 및 str2 %s!', str1, str2);

});

또 다른 예로, 매초 "틱" 이벤트를 발생시키는 Ticker 클래스를 생성할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

var util = require('util'),

EventEmitter = require('events').EventEmitter;

var Ticker = function() {

var self = this;

setInterval(함수() {

self.emit('틱');

}, 1000);

};

util.inherits(Ticker, EventEmitter);

Ticker 클래스를 사용하는 클라이언트는 Ticker 클래스를 사용하는 방법과 "tick" 이벤트를 수신하는 방법을 보여줄 수 있습니다.

코드 복사 코드는 다음과 같습니다.

var ticker = new Ticker();

ticker.on("tick", function() {

console.log("틱");

});

요약

이벤트 이미터 패턴은 이벤트 관련 코드 세트에서 이벤트 이미터 객체를 분리하는 데 사용할 수 있는 재진입 패턴입니다.

event_emitter.on()을 사용하여 특정 유형의 이벤트에 대한 리스너를 등록하고, event_emitter.removeListener()를 사용하여 등록을 취소할 수 있습니다.

EventEmitter를 상속하고 간단히 .emit() 함수를 사용하여 자신만의 이벤트 이미터를 만들 수도 있습니다.