对于发布订阅模式想必大家并不陌生，它在异步交互中具有很大的作用，能够使我们的代码结构更加清晰易读，便于维护。
在node中我们可以使用 内置模块node 来实现发布订阅模式，这篇文章我们将深入去学习event并演示它在我们实际开发中的作用，让我们开始吧！【相关教程推荐：nodejs视频教程】
一、初步使用
引入event内置模块
// 引入内置模块eventconst EventEmitter = require("events");
创建event对象
event内置模块本质是一个构造函数，我们需要通过new操作符去调用它
// 创建event对象const event = new EventEmitter();
监听事件
使用event对象上的event函数来定义一个监听事件，语法为：on
// 监听run事件event.on("run", (data) => { console.log("run事件运行，参数为：", data);});
触发事件
使用event.on(事件名,事件处理函数)对象上的emit函数来触发监听的事件，语法为：event
// 触发run事件event.emit("run", "111111");
完整代码
// 引入内置模块eventconst EventEmitter = require("events");// 创建event对象const event = new EventEmitter();// 监听run事件event.on("run", (data) => { console.log("run运行，参数为：", data);});// 触发run事件event.emit("run", "111111");
运行结果：
❗️ 事件重复监听的问题
==注意：当同一事件被监听多次时，触发事件时会同时触发这个事件的所有事件处理函数==
无阶未来模型擂台/AI 应用平台
无阶未来模型擂台/AI 应用平台，一站式模型+应用平台
35 查看详情 
二、应用
在上一节Node.js | 搭建后端服务器（含内置模块 http | url | querystring 的使用）中有一个使用event.emit(需要触发的事件名,需要给事件处理函数传递的参数)模拟node请求（转发跨域数据）的案例：
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); // 注意这里
这个例子中，我们是通过在get函数中传入一个回调函数来接收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);}
让我们使用内置模块httpget去改造一下上面event模拟node请求（转发跨域数据）的案例：
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); }); } );}
运行并调用get接口：
接口正常使用
注意上边代码/api/maoyan的位置，如果new EventEmitter()是在外部的话，相当于是只有一个全局的new EventEmitter()对象，当我们每次调用event接口时，/api/maoyan都会监听一个新的node事件，这就会导致resEnd事件被重复监听：
所以我们才需要将创建resEnd对象的代码event写到接口的new EventEmitter()分支里，这样当我们调用这个接口时，会创建一个新的case对象，老的event对象被弃用会被event垃圾处理机制给处理掉，这样就不会出现JS事件被重复监听的问题
更多node相关知识，请访问：nodejs 教程！
以上就是Node.js的内置模块 event，利用它怎么实现发布订阅模式的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/545256.html
微信扫一扫 
支付宝扫一扫 
