nodejs多房间web聊天室[通俗易懂]

全栈程序员-站长 • 2022年6月22日上午7:16 • 未分类 • 阅读 35

大家好，又见面了，我是你们的朋友全栈君。

一年之前的做的小项目，过了许久，翻出当时的PPT文档总结一下。源码下载：https://github.com/CreekLou/chatRoom

Nodejs背景简介

1 ，JavaScript最早是运行在浏览器中，然而浏览器只是提供了一个上下文
2 ，node.js事实上就是另外一种上下文，它允许在后端（脱离浏览器环境）运行JavaScript代码
3 ，Node.js事实上既是一个运行时环境，同时又是一个库

Nodejs架构如下图

nodejs多房间web聊天室[通俗易懂]

Node.js 的异步机制是基于事件的，所有的磁盘 I/O 、网络通信、数据库查询都以非阻塞，的方式请求，返回的结果由事件循环来处理

•事件驱动的回调（事件轮询）

•异步IO避免了频繁的上下文切换

•在node中除了代码，所有一切都是并行执行的

nodejs多房间web聊天室[通俗易懂]

多线程同步式 I/O与单线程异步式 I/O

同步式 I/O （阻塞式）：
利用多线程提供吞吐量
通过事件片分割和线程调度利用多核CPU
需要由操作系统调度多线程使用多核 CPU
难以充分利用 CPU 资源
内存轨迹大，数据局部性弱
符合线性的编程思维

异步式 I/O （非阻塞式）：
单线程即可实现高吞吐量
通过功能划分利用多核CPU
可以将单进程绑定到单核 CPU
可以充分利用 CPU 资源
内存轨迹小，数据局部性强
不符合传统编程思维

nodejs多房间web聊天室[通俗易懂]

Node.js 程序由事件循环开始，到事件循环结束，所有的逻辑都是事件的回调函数，所以 Node.js 始终在事件循环中，程序入口就是事件循环第一个事件的回调函数

nodejs多房间web聊天室[通俗易懂]

Nodejs核心模块

1，核心模块是 Node.js 的心脏，它由一些精简而高效的库组成，为 Node.js 提供了基本的 API

2，process：用于描述当前 Node.js 进程状态的对象，提供了一个与操作系统的简单接口，通常在你写本地命令行程序的时候用到。

3，console ：用于提供控制台标准输出。（IE）

4，Util：是一个 Node.js 核心模块，提供常用函数的集合

5，events ：是 Node.js 最重要的模块，没有“之一”

6，fs ：文件系统，提供了文件的读取、写入、更名、删除、遍历目录、链接等 POSIX 文件系统操作

模块httpServer,Nodejs server 采用V8虚拟机

var http = require("http");//请求（require）Node.js自带的 http 模块，并且把它赋值给 http 变量
http.createServer(function(request, response) {
      //调用http模块提供的函数： createServer
	  response.writeHead(200, {"Content-Type": "text/plain"});
	  response.write("Hello World");
	  response.end();
}).listen(8888);

socket.io

socket.io 提供了三种默认的事件：connect 、message 、disconnect 。

当与对方建立连接后自动触发 connect 事件，当收到对方发来的数据后触发 message 事件（通常为 socket.send() 触发），当对方关闭连接后触发 disconnect 事件。
socket.emit() ：向建立该连接的客户端广播
socket.broadcast.emit() ：向除去建立该连接的客户端的所有客户端广播
io.sockets.emit() ：向所有客户端广播，等同于上面两个的和

CLIENT (INDEX.HTML)

<script src="/socket.io/socket.io.js"></script> <script>
varsocket=io.connect('http://localhost'); socket.on('news', function (data) { 
     console.log(data); 
      socket.emit('my other event', { my: 'data' }); 
}); 

</script>

SERVER (APP.JS)

var app = require('express')() ,
server = require('http').createServer(app) ,
 io = require('socket.io').listen(server); 
//将 socket.io 绑定到服务器上
server.listen(80);
 app.get('/', function (req, res) { 
    res.sendfile(__dirname + '/index.html'); 
});
//服务器监听所有客户端，并返回该新连接对象
 io.sockets.on('connection', function (socket) {
 socket.emit('news', { hello: 'world' 
}); 
socket.on('my other event', function (data) { 
console.log(data);
 }); 
});