文章目录
- 9. `mongodb` 模块
- 安装和引入
- 连接数据库
- 操作集合
- 获取集合
- 插入文档
- 查询文档
- 更新文档
- 删除文档
- 关闭连接
- 10. `socket.io` 模块
- 安装和引入
- 监听连接事件
- 监听自定义事件
- 在服务器端监听事件
- 在客户端触发事件
- 广播消息
- 在服务器端广播消息
- 在客户端监听广播消息
- 断开连接
- 完整示例
9. mongodb 模块
用于连接和操作 MongoDB 数据库。
const MongoClient = require('mongodb').MongoClient;
mongodb 模块是 Node.js 中用于与 MongoDB 数据库进行交互的官方驱动程序。它提供了一组功能丰富的 API，使我们能够在 Node.js 应用程序中连接、操作和管理 MongoDB 数据库。
下面我将详细介绍 mongodb 模块的一些常用功能和使用方法：
安装和引入
首先，需要通过 npm 安装 mongodb 模块。
npm install mongodb
然后，在你的 Node.js 代码中引入 mongodb 模块。
const { MongoClient } = require('mongodb');
连接数据库
使用 MongoClient 对象来连接 MongoDB 数据库。
const uri = 'mongodb://localhost:27017';
const client = new MongoClient(uri);
async function connect() {
try {
await client.connect();
console.log('Connected to the database');
} catch (error) {
console.error('Failed to connect to the database:', error);
}
}
connect();
上述代码中，我们使用 MongoClient 对象创建了一个客户端，并使用 connect 方法连接到 MongoDB 数据库。
操作集合
一旦连接到数据库，我们可以操作集合（Collection）来进行数据的增删改查。
获取集合
const db = client.db('mydb');
const collection = db.collection('mycollection');
上述代码中，我们获取了名为 mycollection 的集合对象，用于后续的操作。
插入文档
const insertResult = await collection.insertOne({ name: 'John', age: 30 });
console.log('Inserted document:', insertResult.insertedId);
上述代码中，我们使用 insertOne 方法向集合中插入一条文档，并通过返回结果获取插入的文档的 _id 值。
查询文档
const query = { age: { $gt: 25 } };
const cursor = collection.find(query);
while (await cursor.hasNext()) {
const document = await cursor.next();
console.log(document);
}
上述代码中，我们使用 find 方法查询满足条件的文档，并通过游标（Cursor）进行遍历并打印每个文档。
更新文档
const filter = { name: 'John' };
const update = { $set: { age: 35 } };
const updateResult = await collection.updateOne(filter, update);
console.log('Updated document count:', updateResult.modifiedCount);
上述代码中，我们使用 updateOne 方法更新满足条件的文档，并通过返回结果获取更新的文档数量。
删除文档
const filter = { name: 'John' };
const deleteResult = await collection.deleteOne(filter);
console.log('Deleted document count:', deleteResult.deletedCount);
上述代码中，我们使用 deleteOne 方法删除满足条件的文档，并通过返回结果获取删除的文档数量。
关闭连接
在使用完数据库之后，需要关闭数据库连接。
async function close() {
try {
await client.close();
console.log('Connection closed');
} catch (error) {
console.error('Failed to close the connection:', error);
}
}
close();
上述代码中，我们使用 close 方法关闭数据库连接。
除了上述介绍的功能之外，mongodb 模块还提供了更多的 API 和功能，例如聚合管道（Aggregation Pipeline）、索引管理、事务处理等。你可以根据自己的需求查阅官方文档来了解更多详细信息。
需要注意的是，实际使用中，我们通常会在连接数据库、操作集合等步骤中添加适当的错误处理和异常捕捉，以确保代码的健壮性和可靠性。
10. socket.io 模块
用于构建实时的 WebSocket 应用程序，支持双向通信。
const io = require('socket.io');
socket.io 是一个流行的用于实现实时、双向通信的 JavaScript 库。它提供了一种简单而强大的方式，使得服务器和客户端可以通过 WebSocket 或轮询等技术进行通信。在本次讲解中，我将详细介绍 socket.io 模块的主要功能和使用方法。
安装和引入
首先，需要通过 npm 安装 socket.io 模块。
npm install socket.io
然后，在你的 Node.js 代码中引入 socket.io 模块，并创建一个 socket.io 服务器对象。
const http = require('http');
const io = require('socket.io');
// 创建 HTTP 服务器
const server = http.createServer();
// 创建 socket.io 服务器
const socketServer = io(server);
上述代码中，我们使用 http 模块创建了一个 HTTP 服务器，并使用 io 函数创建了一个 socket.io 服务器，将其与 HTTP 服务器关联起来。
监听连接事件
socket.io 使用事件驱动的模型进行通信。服务器和客户端之间的通信通过触发和监听不同的事件来实现。首先，我们需要监听连接事件，当客户端连接到服务器时触发该事件。
socketServer.on('connection', (socket) => {
console.log('A new client connected');
// 在这里可以处理客户端的其他事件
});
上述代码中，我们使用 on 方法监听 connection 事件，并在回调函数中处理连接事件。当有新的客户端连接到服务器时，回调函数会被触发，并传入一个 socket 对象，该对象代表与客户端之间的连接。
监听自定义事件
一旦建立了连接，我们可以通过触发和监听自定义事件来在服务器和客户端之间进行通信。
在服务器端监听事件
在服务器端，我们可以使用 on 方法来监听自定义事件。
socket.on('event_name', (data) => {
console.log('Received data from client:', data);
// 在这里可以处理和回复客户端的数据
});
上述代码中，我们使用 on 方法监听名为 event_name 的自定义事件，并在回调函数中处理接收到的数据。
在客户端触发事件
在客户端，我们可以使用 emit 方法来触发自定义事件，并传递数据给服务器。
socket.emit('event_name', data);
上述代码中，我们使用 emit 方法触发名为 event_name 的自定义事件，并将 data 数据发送给服务器。
广播消息
socket.io 还提供了广播功能，可以向除了当前连接以外的所有客户端发送消息。
在服务器端广播消息
在服务器端，我们可以使用 broadcast 属性来广播消息。
socket.broadcast.emit('event_name', data);
上述代码中，我们使用 broadcast.emit 方法广播名为 event_name 的消息，并将 data 数据发送给除了当前连接以外的所有客户端。
在客户端监听广播消息
在客户端，我们可以使用 on 方法监听服务器端广播的消息。
socket.on('event_name', (data) => {
console.log('Received broadcast data:', data);
// 在这里可以处理服务器端广播的数据
});
上述代码中，我们使用 on 方法监听名为 event_name 的广播事件，并在回调函数中处理接收到的数据。
断开连接
当客户端断开与服务器的连接时，会触发 disconnect 事件。
socket.on('disconnect', () => {
console.log('Client disconnected');
// 在这里可以做一些清理和处理工作
});
上述代码中，我们使用 on 方法监听 disconnect 事件，并在回调函数中处理客户端断开连接的情况。
完整示例
下面是一个使用 socket.io 实现简单聊天室的完整示例。
const http = require('http');
const io = require('socket.io');
const server = http.createServer();
const socketServer = io(server);
socketServer.on('connection', (socket) => {
console.log('A new client connected');
socket.on('chat_message', (message) => {
console.log('Received message:', message);
socket.broadcast.emit('chat_message', message);
});
socket.on('disconnect', () => {
console.log('Client disconnected');
});
});
server.listen(3000, () => {
console.log('Server is running on port 3000');
});
上述示例中，服务器在端口 3000 上监听连接请求，并在连接建立后处理 chat_message 事件来实现聊天室的功能。当客户端发送消息时，服务器会将消息广播给所有其他客户端。
以上就是对 socket.io 模块的详细讲解，希望能对你有所帮助。socket.io 还提供了很多高级功能和配置选项，你可以参考官方文档以获取更多信息。
以上列举的是 Node.js 中的十大常用模块，每个模块都有其特定的功能和用途，可以根据具体需求选择和使用。
