Node.js的内置模块 event,利用它怎么实现发布订阅模式
对于发布订阅模式想必大家并不陌生,它在异步交互中具有很大的作用,能够使我们的代码结构更加清晰易读,便于维护。
在node
中我们可以使用 内置模块event
来实现发布订阅模式,这篇文章我们将深入去学习event
并演示它在我们实际开发中的作用,让我们开始吧!
一、初步使用
引入event内置模块
- // 引入内置模块event
- const EventEmitter = require("events");
创建event对象
event
内置模块本质是一个构造函数,我们需要通过new
操作符去调用它
- // 创建event对象
- const event = new EventEmitter();
监听事件
使用event
对象上的on
函数来定义一个监听事件,语法为:event.on(事件名,事件处理函数)
- // 监听run事件
- event.on("run", (data) => {
- console.log("run事件运行,参数为:", data);
- });
触发事件
使用event
对象上的emit函数来触发监听的事件,语法为:event.emit(需要触发的事件名,需要给事件处理函数传递的参数)
- // 触发run事件
- event.emit("run", "111111");
完整代码
- // 引入内置模块event
- const EventEmitter = require("events");
- // 创建event对象
- const event = new EventEmitter();
- // 监听run事件
- event.on("run", (data) => {
- console.log("run运行,参数为:", data);
- });
- // 触发run事件
- event.emit("run", "111111");
运行结果:
❗️ 事件重复监听的问题
==注意:当同一事件被监听多次时,触发事件时会同时触发这个事件的所有事件处理函数==
二、应用
使用node
模拟get
请求(转发跨域数据):
- const http = require("http");
- const https = require("https");
- // http和https的区别仅在于一个是http协议一个是https协议
- const url = require("url");
- const server = http.createServer();
- server.on("request", (req, res) => {
- const urlObj = url.parse(req.url, true);
- res.writeHead(200, {
- "content-type": "application/json;charset=utf-8",
- "Access-Control-Allow-Origin": "http://127.0.0.1:5500",
- });
- switch (urlObj.pathname) {
- case "/api/maoyan":
- // 我们定义的httpget方法:使node充当客户端去猫眼的接口获取数据
- httpget((data) => res.end(data)); // 注意这里
- break;
- default:
- res.end("404");
- break;
- }
- });
- server.listen(3000, () => {
- console.log("服务器启动啦!");
- });
- function httpget(cb) {
- // 定义一个存放数据的变量
- let data = "";
- // 因为猫眼的接口是https协议的,所以我们需要引入https
- // http和https都具有一个get方法能够发起get请求,区别是一个是http协议,一个是https协议
- // http get方法第一个参数为接口地址,第二个参数为回调函数
- https.get(
- "https://i.maoyan.com/api/mmdb/movie/v3/list/hot.json?ct=%E8%A5%BF%E5%8D%8E&ci=936&channelId=4",
- (res) => {
- // http get方法获取的数据是一点点返回的,并不是直接返回全部
- // 监听data,当有数据返回时就会被调用
- res.on("data", (chunk) => {
- // 收集数据
- data += chunk;
- });
- // 监听end,数据返回完毕后调用
- res.on("end", () => {
- cb(data); // 注意这里
- });
- }
- );
- }
注意上面代码的第19行和第49行:
- httpget((data) => res.end(data)); // 注意这里
- cb(data); // 注意这里
这个例子中,我们是通过在httpget
函数中传入一个回调函数来接收httpget
函数获取到的数据,这种写法实际是没有问题的,在开发中也常常进行使用。
但在一些情况下,特别是函数多层嵌套调用时(如下面的例子),这种写法就显得不够优雅,因为它的代码结构不是很清晰,不能很直观的看懂其逻辑:
- function user() {
- getUser((data) => {
- console.log(data);
- });
- }
- function getUser(cb) {
- // ....
- const id = 1;
- getUserInfo(cb, id);
- }
- function getUserInfo(cb, id) {
- // ....
- const name = id + "Ailjx";
- cb(name);
- }
让我们使用内置模块event
去改造一下上面node
模拟get
请求(转发跨域数据)的案例:
- const http = require("http");
- const https = require("https");
- const url = require("url");
- const EventEmitter = require("events");
- const server = http.createServer();
- // 存放event对象
- let event = "";
- server.on("request", (req, res) => {
- const urlObj = url.parse(req.url, true);
- res.writeHead(200, {
- "content-type": "application/json;charset=utf-8",
- "Access-Control-Allow-Origin": "http://127.0.0.1:5500",
- });
- switch (urlObj.pathname) {
- case "/api/maoyan":
- event = new EventEmitter(); // 注意该位置
- // 监听事件
- event.on("resEnd", (data) => {
- res.end(data);
- });
- httpget();
- break;
- default:
- res.end("404");
- break;
- }
- });
- server.listen(3000, () => {
- console.log("服务器启动啦!");
- });
- function httpget() {
- let data = "";
- https.get(
- "https://i.maoyan.com/api/mmdb/movie/v3/list/hot.json?ct=%E8%A5%BF%E5%8D%8E&ci=936&channelId=4",
- (res) => {
- res.on("data", (chunk) => {
- data += chunk;
- });
- res.on("end", () => {
- // 触发事件并传递数据
- event.emit("resEnd", data);
- });
- }
- );
- }
运行并调用/api/maoyan
接口:
接口正常使用
注意上边代码new EventEmitter()
的位置,如果new EventEmitter()
是在外部的话,相当于是只有一个全局的event
对象,当我们每次调用/api/maoyan
接口时,node
都会监听一个新的resEnd
事件,这就会导致resEnd
事件被重复监听:
所以我们才需要将创建event
对象的代码new EventEmitter()
写到接口的case
分支里,这样当我们调用这个接口时,会创建一个新的event
对象,老的event
对象被弃用会被JS
垃圾处理机制给处理掉,这样就不会出现resEnd
事件被重复监听的问题
本文网址:https://www.zztuku.com/detail-13127.html
站长图库 - Node.js的内置模块 event,利用它怎么实现发布订阅模式
申明:本文转载于《掘金社区》,如有侵犯,请 联系我们 删除。
您还没有登录,请 登录 后发表评论!
提示:请勿发布广告垃圾评论,否则封号处理!!