使用Express.js构建一个简单的RESTful API，处理CRUD操作

在现代Web开发中，RESTful API在前后端分离的架构中扮演着越来越重要的角色。它不仅使得前端和后端能够独立开发，还提高了系统的可维护性和 scalability。今天，我们将一起学习如何使用Express.js构建一个简单的RESTful API，处理基本的CRUD操作（创建、读取、更新和删除）。

什么是Express.js？

Express.js是一个快速、极简的Node.js web应用框架，提供了一系列强大的特性，可以帮助我们构建各种Web应用。它具有简洁的API和中间件支持，使得路由、请求处理等变得无比简单。因此，非常适合构建RESTful风格的API。

准备工作

在开始之前，请确保你已经安装了Node.js和npm（Node包管理器）。如果没有，可以前往Node.js官网进行下载和安装。

接下来，我们将创建一个新的项目文件夹，并安装Express.js。

mkdir express-rest-api

cd express-rest-api

npm init -y

npm install express body-parser mongoose

在上面的命令中，我们首先创建了一个新的项目文件夹，然后安装了Express.js、body-parser（用于解析请求体）和mongoose（用于MongoDB交互）。

创建基本的Express服务器

首先，我们要建立一个基础的Express服务器。创建一个server.js文件，并在其中添加以下代码：

const express = require('express');

const bodyParser = require('body-parser');



const app = express();

const PORT = 3000;



// 中间件

app.use(bodyParser.json()); // 解析JSON格式的请求体



// 路由

app.get('/', (req, res) => {

    res.send('Hello World! This is a simple RESTful API.');

});



// 启动服务器

app.listen(PORT, () => {

    console.log(`Server is running on http://localhost:${PORT}`);

});

运行node server.js启动服务器，然后在浏览器中访问http://localhost:3000，你应该能看到“Hello World! This is a simple RESTful API.”的消息。

CRUD操作的实现

我们将使用一个简单的模型来演示CRUD操作。在这个例子中，我们将构建一个“用户”模型，包含名称和邮箱属性。使用Mongoose连接到MongoDB数据库，并实现CRUD操作。

首先，安装MongoDB并确保你的数据库正在运行。然后，在server.js文件中添加Mongoose连接代码：

const mongoose = require('mongoose');



mongoose.connect('mongodb://localhost:27017/expressRestApi', {

    useNewUrlParser: true,

    useUnifiedTopology: true,

})

.then(() => console.log('MongoDB connected'))

.catch(err => console.error('MongoDB connection error:', err));

创建用户模型

接下来，我们需要定义用户的Mongoose模型。创建一个名为User.js的文件，并添加以下代码：

const mongoose = require('mongoose');



const UserSchema = new mongoose.Schema({

    name: { type: String, required: true },

    email: { type: String, required: true, unique: true },

});



const User = mongoose.model('User', UserSchema);



module.exports = User;

实现CRUD接口

现在，回到server.js文件，添加CRUD操作的路由：

const User = require('./User');



// 创建用户（Create）

app.post('/users', async (req, res) => {

    const { name, email } = req.body;

    const user = new User({ name, email });

    try {

        await user.save();

        res.status(201).json(user);

    } catch (err) {

        res.status(400).json({ message: err.message });

    }

});



// 获取所有用户（Read）

app.get('/users', async (req, res) => {

    try {

        const users = await User.find();

        res.json(users);

    } catch (err) {

        res.status(500).json({ message: err.message });

    }

});



// 更新用户（Update）

app.patch('/users/:id', async (req, res) => {

    const { id } = req.params;

    const { name, email } = req.body;

    try {

        const user = await User.findByIdAndUpdate(id, { name, email }, { new: true });

        res.json(user);

    } catch (err) {

        res.status(400).json({ message: err.message });

    }

});



// 删除用户（Delete）

app.delete('/users/:id', async (req, res) => {

    const { id } = req.params;

    try {

        await User.findByIdAndDelete(id);

        res.json({ message: 'User deleted' });

    } catch (err) {

        res.status(500).json({ message: err.message });

    }

});

测试API

现在，我们已经实现了一个简单的CRUD API，你可以使用Postman或cURL进行测试。

创建用户（POST请求到http://localhost:3000/users）：

{

    "name": "John Doe",

    "email": "john@example.com"

}

获取所有用户（GET请求到http://localhost:3000/users）。
更新用户（PATCH请求到http://localhost:3000/users/{userId}）：

{

    "name": "Jane Doe",

    "email": "jane@example.com"

}

删除用户（DELETE请求到http://localhost:3000/users/{userId}）。

完整代码

在这个简单的教程中，我们使用Express.js和Mongoose成功创建了一个RESTful API，处理了CRUD操作。以下是完整的server.js文件代码：

const express = require('express');

const bodyParser = require('body-parser');

const mongoose = require('mongoose');

const User = require('./User');



const app = express();

const PORT = 3000;



mongoose.connect('mongodb://localhost:27017/expressRestApi', {

    useNewUrlParser: true,

    useUnifiedTopology: true,

})

.then(() => console.log('MongoDB connected'))

.catch(err => console.error('MongoDB connection error:', err));



app.use(bodyParser.json());



app.get('/', (req, res) => {

    res.send('Hello World! This is a simple RESTful API.');

});



// Create User

app.post('/users', async (req, res) => {

    const { name, email } = req.body;

    const user = new User({ name, email });

    try {

        await user.save();

        res.status(201).json(user);

    } catch (err) {

        res.status(400).json({ message: err.message });

    }

});



// Read Users

app.get('/users', async (req, res) => {

    try {

        const users = await User.find();

        res.json(users);

    } catch (err) {

        res.status(500).json({ message: err.message });

    }

});



// Update User

app.patch('/users/:id', async (req, res) => {

    const { id } = req.params;

    const { name, email } = req.body;

    try {

        const user = await User.findByIdAndUpdate(id, { name, email }, { new: true });

        res.json(user);

    } catch (err) {

        res.status(400).json({ message: err.message });

    }

});



// Delete User

app.delete('/users/:id', async (req, res) => {

    const { id } = req.params;

    try {

        await User.findByIdAndDelete(id);

        res.json({ message: 'User deleted' });

    } catch (err) {

        res.status(500).json({ message: err.message });

    }

});



app.listen(PORT, () => {

    console.log(`Server is running on http://localhost:${PORT}`);

});