使用 Fastify 和 MongoDB Atlas 构建一个订单处理 API-JavaScript中文网-JavaScript教程资源分享门户

介绍

在本文中，我们将使用 Fastify 和 MongoDB Atlas 构建一个简单的订单处理 API。Fastify 是一个快速、低开销、可扩展的 Node.js 框架，而 MongoDB Atlas 是云数据库服务，它可以轻松地部署、管理和扩展 MongoDB 数据库。

我们将使用 Fastify 和 MongoDB Atlas 来构建一个订单处理 API，该 API 可以执行以下操作：

创建一个新订单
获取所有订单
获取特定订单
更新一个订单
删除一个订单

我们将使用 MongoDB Atlas 作为我们的数据存储，因为它是一个可扩展的、具有高可用性的云数据库，可以轻松地扩展和管理我们的订单数据。

准备工作

在开始构建我们的订单处理 API 之前，我们需要做一些准备工作。首先，我们需要安装 Node.js 和 MongoDB。您可以从以下链接下载并安装它们：

接下来，我们需要创建一个 MongoDB Atlas 帐户。您可以在以下链接注册一个帐户：

MongoDB Atlas

完成注册后，您需要创建一个集群。您可以在 Atlas 控制台上创建集群。创建集群时，请确保选择一个与您的云提供商相同的地理位置。

在 Atlas 控制台的“Security”选项卡中，您需要创建一个数据库用户，并为该用户授予对您的集群的读写权限。请确保记住您的用户名和密码，因为我们将在代码中使用它们。

最后，我们需要安装一些必要的 Node.js 模块。您可以使用以下命令在命令行中安装它们：

npm install fastify fastify-cors fastify-mongodb

构建订单处理 API

现在，我们可以开始构建我们的订单处理 API。我们将使用 Fastify 来构建 API，使用 MongoDB Atlas 来存储订单数据。我们将使用以下路由来实现我们的 API：

POST /orders - 创建一个新订单
GET /orders - 获取所有订单
GET /orders/:id - 获取特定订单
PUT /orders/:id - 更新一个订单
DELETE /orders/:id - 删除一个订单

在开始编写代码之前，让我们先创建一个名为 index.js 的文件，并将以下代码添加到文件中：

-- -------------------- ---- -------
----- ------- - -------------------- ------- ---- --
----- ---- - -----------------------
----- ------- - --------------------------

---------------------- -
  ------- ----
  -------- ------- ------ ------- ---------
--

------------------------- -
  ---- --------------------------------------------------------------------------------------------------
--

---------------- ----- --------- ------ -- -
  ------ - -------- -------- -- --- ----- ---- -
--

-------------------- ----- -------- -- -
  -- ----- -
    ------------------
    ---------------
  -
  ------------------- --------- -- ------------
--

在上面的代码中，我们使用 fastify 模块创建了一个 Fastify 实例，并使用 fastify-cors 和 fastify-mongodb 插件注册了一些中间件。我们还定义了一个 / 路由，该路由返回一个欢迎消息。最后，我们使用 fastify.listen() 方法将服务器绑定到端口 3000。

现在，我们可以开始编写我们的订单处理路由。首先，我们将创建一个 /orders 路由，该路由将用于创建新订单。我们将使用以下代码添加路由：

-- -------------------- ---- -------
----------------------- ----- --------- ------ -- -
  ----- -- - ----------------
  ----- ---------- - -----------------------

  ----- - ----- ------ ------- - - ------------

  ----- ------ - ----- ----------------------
    -----
    ------
    --------
    ----------- --- ------
  --

  ------ - --- ----------------- -
--

在上面的代码中，我们首先获取 MongoDB 数据库实例，并使用 insertOne() 方法将新订单插入到 orders 集合中。我们还为订单添加了一个 created_at 字段，该字段包含订单创建的时间戳。最后，我们返回了订单的 ID。

接下来，我们将创建一个 /orders 路由，该路由将用于获取所有订单。我们将使用以下代码添加路由：

fastify.get('/orders', async (request, reply) => {
  const db = fastify.mongo.db
  const collection = db.collection('orders')

  const result = await collection.find().toArray()

  return result
})

在上面的代码中，我们首先获取 MongoDB 数据库实例，并使用 find() 方法获取所有订单。我们将订单转换为数组，并将其返回。

接下来，我们将创建一个 /orders/:id 路由，该路由将用于获取特定订单。我们将使用以下代码添加路由：

-- -------------------- ---- -------
-------------------------- ----- --------- ------ -- -
  ----- -- - ----------------
  ----- ---------- - -----------------------

  ----- ------ - ----- --------------------
    ---- -----------------------------------------
  --

  -- --------- -
    ------ ---------------------- -------- ------ --- ------ --
  -

  ------ ------
--

在上面的代码中，我们首先获取 MongoDB 数据库实例，并使用 findOne() 方法获取特定订单。我们使用 fastify.mongo.ObjectId() 方法将订单 ID 转换为 MongoDB ObjectId。如果找不到订单，则返回 404 状态码和错误消息。

接下来，我们将创建一个 /orders/:id 路由，该路由将用于更新特定订单。我们将使用以下代码添加路由：

-- -------------------- ---- -------
-------------------------- ----- --------- ------ -- -
  ----- -- - ----------------
  ----- ---------- - -----------------------

  ----- - ----- ------ ------- - - ------------

  ----- ------ - ----- ----------------------------
    - ---- ----------------------------------------- --
    - ----- - ----- ------ ------- - --
    - --------------- ----- -
  -

  -- --------------- -
    ------ ---------------------- -------- ------ --- ------ --
  -

  ------ ------------
--

在上面的代码中，我们首先获取 MongoDB 数据库实例，并使用 findOneAndUpdate() 方法更新特定订单。我们使用 fastify.mongo.ObjectId() 方法将订单 ID 转换为 MongoDB ObjectId。如果找不到订单，则返回 404 状态码和错误消息。

最后，我们将创建一个 /orders/:id 路由，该路由将用于删除特定订单。我们将使用以下代码添加路由：

-- -------------------- ---- -------
----------------------------- ----- --------- ------ -- -
  ----- -- - ----------------
  ----- ---------- - -----------------------

  ----- ------ - ----- -----------------------------
    ---- -----------------------------------------
  --

  -- --------------- -
    ------ ---------------------- -------- ------ --- ------ --
  -

  ------ - -------- ------ -------- -
--

在上面的代码中，我们首先获取 MongoDB 数据库实例，并使用 findOneAndDelete() 方法删除特定订单。我们使用 fastify.mongo.ObjectId() 方法将订单 ID 转换为 MongoDB ObjectId。如果找不到订单，则返回 404 状态码和错误消息。

现在，我们已经完成了订单处理 API 的构建。您可以使用以下命令在命令行中启动服务器：

node index.js

结论

在本文中，我们使用 Fastify 和 MongoDB Atlas 构建了一个简单的订单处理 API。我们学习了如何使用 Fastify 和 MongoDB Atlas 来构建一个可扩展、具有高可用性的订单处理 API。我们还学习了如何使用 Fastify 插件来注册中间件，并使用 MongoDB 来存储订单数据。最后，我们编写了一些路由来实现订单处理 API 的各种操作。

通过本文的学习，您应该能够使用 Fastify 和 MongoDB Atlas 构建自己的 API，并将其部署到生产环境中。如果您想了解更多关于 Fastify 和 MongoDB Atlas 的内容，请查阅官方文档。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/6763f1b9856ee0c1d424db79