Node.js의 이벤트 수신 및 이벤트 게시 사용 예에 ​​대한 자세한 설명

node.js는 단일 스레드 비차단 비동기 I/O를 기반으로 합니다. 비동기 I/O는 I/O 작업이 발생하면 스레드가 차단하지 않고 다음 작업을 수행한 다음 I/O를 수행한다는 의미입니다. O 작업이 완료되었습니다. 스레드는 작업이 완료되었음을 어떻게 알 수 있습니까?

작업이 시간이 많이 걸리는 I/O 작업을 완료하면 I/O 작업의 스레드가 이벤트 형식으로 알림을 받고 특정 시간에 이 이벤트를 처리하고 다음 작업을 수행합니다. 비동기 I/O를 완료하려면 스레드에 완료되지 않은 이벤트가 있는지 지속적으로 확인하고 이러한 이벤트 처리를 순차적으로 완료하는 이벤트 루프 메커니즘이 있어야 합니다.

블로킹 I/O의 경우 스레드가 시간이 많이 걸리는 I/O 작업을 만나면 실행을 중지하고 작업이 완료될 때까지 기다립니다. 이때 스레드는 다른 작업 요청을 수락할 수 없습니다. 처리량을 높이려면 여러 작업을 생성해야 합니다. 스레드는 각 스레드가 고객의 요청에 응답하지만 동시에 하나의 스레드만 CPU 코어에서 실행할 수 있습니다. 여러 스레드를 실행하려면 서로 다른 스레드 간에 전환해야 합니다.

그래서 node.js는 멀티 스레드에서 스레드 생성 및 스레드 전환 비용을 줄여줍니다. 이를 위해 메모리를 할당하고 동시에 일정에 포함해야 합니다. 스레드 전환시 메모리 실행을 위해 단일 스레드를 사용하여 페이지 변경 및 기타 작업을 줄일 수 있습니다. 그러나 이 프로그래밍 방법에도 단점이 있으며 사람들의 디자인 사고와 일치하지 않습니다.

node.js는 비동기 I/O를 구현하기 위해 이벤트 모드를 기반으로 시작되면 완료되지 않은 이벤트가 있는지 지속적으로 순회한 후 실행이 완료된 후 스레드에 알림을 보냅니다. 이 작업은 완료되었으며 이 이벤트는 완료되지 않은 이벤트 목록에 추가됩니다. 스레드는 다음 번에 이 이벤트를 순회한 다음 이를 실행합니다. 소규모 이벤트의 경우 node.js는 일부 높은 I/O 및 낮은 논리 시나리오를 처리하는 데에도 적합합니다.

다음 예는 비동기식 파일 읽기를 보여줍니다.

var fs = require('fs'); 
fs.readFile('file.txt', 'utf-8', function(err, data) { 
if (err) { 
<span style="white-space:pre"> </span>console.error(err); 
} else { 
<span style="white-space:pre"> </span>console.log(data); 
} 
}); 
[javascript] view plain copy
console.log("end");

위의 fs.readFile과 같이 파일을 비동기식으로 읽은 다음 다른 파일을 기다리지 않고 프로세스가 계속됩니다. 파일을 읽으면 이벤트가 해제됩니다. 실행 스레드는 이벤트를 탐색하고 해당 작업을 수행합니다. 다음은 해당 콜백 함수입니다. 예에서는 파일 내용이 오기 전에 문자열 끝이 인쇄됩니다. 밖으로. fs.readFile异步读取文件，之后流程就会继续走，并不会等待其读取完文件，当文件读取完毕之后，会发布一个事件，执行线程遍历到该事件就会去执行对应的操作，这里是执行相应的回调函数，例子中字符串end会比文件内容先打印出来。

node.js的事件API

events.EventEmitter：EventEmitter对node.js中的事件发射与事件监听功能提供了封装，每个事件由一个标识事件名的字符串和对应的操作组成。

事件的监听：

var events = require("events"); 
var emitter = new events.EventEmitter(); 
 <span style="font-family: Arial, Helvetica, sans-serif;">emitter.on("eventName", function(){</span> 
  console.log("eventName事件发生") 
})

事件的发布：

emitter.emit("eventName");

发布事件的时候我们可以传入多个参数，第一个参数表示事件的名称，其后的参数表示传入的参数，这些参数会被传入到事件的回调函数中。

EventEmitter.once("eventName", listener) :为事件注册一个只执行一次的监听器，当事件第一次发生并触发监听器之后，该监听器就会解除，之后如果事件发生，该监听器不会执行。

EventEmitter.removeListener(event, listener) ：移除掉事件的监听器

EventEmitter.removeAllListeners(event) ：移除掉事件的所有的监听器

EventEmitter.setMaxListeners(n) :node.js默认单个事件最大的监听器个数是10，如果超过10会给予警告，这么做是为了防止内存的溢出，我们可以更改这种限制设置为其他的数字，如果设置为0表示不进行限制。

EventEmitter.listeners(event)

node.js 이벤트 API
events.EventEmitter: EventEmitter는 node.js에서 이벤트 방출 및 이벤트 수신 기능의 캡슐화를 제공합니다. 각 이벤트는 이벤트 이름으로 식별됩니다. 문자열 및 해당 작업.

이벤트 모니터링:

api.getUser("username", function (profile) {
 // Got the profile
});
api.getTimeline("username", function (timeline) {
 // Got the timeline
});
api.getSkin("username", function (skin) {
 // Got the skin
});

이벤트 게시:

api.getUser("username", function (profile) {
 api.getTimeline("username", function (timeline) {
  api.getSkin("username", function (skin) {
   // TODO
  });
 });
});

var proxy = new EventProxy();
proxy.all("profile", "timeline", "skin", function (profile, timeline, skin) {
 // TODO
});
api.getUser("username", function (profile) {
 proxy.emit("profile", profile);
});
api.getTimeline("username", function (timeline) {
 proxy.emit("timeline", timeline);
});
api.getSkin("username", function (skin) {
 proxy.emit("skin", skin);
});

var select = function (callback) {
  db.select("SQL", function (results) {
   callback(results);
  });
 };

为解决这类问题，我曾写作一个模块来实现多事件协作，以下为上面代码的改进版：

var proxy = new EventProxy();
proxy.all("profile", "timeline", "skin", function (profile, timeline, skin) {
 // TODO
});
api.getUser("username", function (profile) {
 proxy.emit("profile", profile);
});
api.getTimeline("username", function (timeline) {
 proxy.emit("timeline", timeline);
});
api.getSkin("username", function (skin) {
 proxy.emit("skin", skin);
});

EventProxy也是一个简单的事件侦听者模式的实现，由于底层实现跟Node.js的EventEmitter不同，无法合并进Node.js中。但是却提供了比EventEmitter更强大的功能，且API保持与EventEmitter一致，与Node.js的思路保持契合，并可以适用在前端中。
这里的all方法是指侦听完profile、timeline、skin三个方法后，执行回调函数，并将侦听接收到的数据传入。

利用事件队列解决雪崩问题

所谓雪崩问题，是在缓存失效的情景下，大并发高访问量同时涌入数据库中查询，数据库无法同时承受如此大的查询请求，进而往前影响到网站整体响应缓慢。

那么在Node.js中如何应付这种情景呢。

var select = function (callback) {
  db.select("SQL", function (results) {
   callback(results);
  });
 };

以上是一句数据库查询的调用，如果站点刚好启动，这时候缓存中是不存在数据的，而如果访问量巨大，同一句SQL会被发送到数据库中反复查询，影响到服务的整体性能。一个改进是添加一个状态锁。

var status = "ready";
var select = function (callback) {
  if (status === "ready") {
   status = "pending";
   db.select("SQL", function (results) {
    callback(results);
    status = "ready";
   });
  }
 };

但是这种情景，连续的多次调用select发，只有第一次调用是生效的，后续的select是没有数据服务的。所以这个时候引入事件队列吧：

var proxy = new EventProxy();
var status = "ready";
var select = function (callback) {
  proxy.once("selected", callback);
  if (status === "ready") {
   status = "pending";
   db.select("SQL", function (results) {
    proxy.emit("selected", results);
    status = "ready";
   });
  }
 };

这里利用了EventProxy对象的once方法，将所有请求的回调都压入事件队列中，并利用其执行一次就会将监视器移除的特点，保证每一个回调只会被执行一次。对于相同的SQL语句，保证在同一个查询开始到结束的时间中永远只有一次，在这查询期间到来的调用，只需在队列中等待数据就绪即可，节省了重复的数据库调用开销。由于Node.js单线程执行的原因，此处无需担心状态问题。这种方式其实也可以应用到其他远程调用的场景中，即使外部没有缓存策略，也能有效节省重复开销。此处也可以用EventEmitter替代EventProxy，不过可能存在侦听器过多，引发警告，需要调用setMaxListeners(0)移除掉警告，或者设更大的警告阀值。

위 내용은 Node.js의 이벤트 수신 및 이벤트 게시 사용 예에 ​​대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!