帶有事件發射器的 EDD

使用事件發射器在 node.js 中建立事件驅動的應用程式。一個內建模組，是 Node.js 架構的核心。 EventEmitter 是一個幫助我們在 Node.js 中建立發布者-訂閱者模式的類別。

我們將透過建立巴士預訂應用程式來了解如何使用 EventEmitter，用戶可以在其中預訂巴士座位並在預訂成功時收到電子郵件通知。首先，我們將使用 /book 路線設定一個簡單的 Express 應用程式。

index.js

import express from "express"
import { addTrip } from "./utils"

const app = express()

app.post("/book", (req, res) = {
    const {origin, destination, date} = req.body;

    if (!(origin && destination && date)) {
        res.status(400).send("Invalid request")
    }

    addTrip({
        origin, destination, date
    }).then((response) => {
        if (response.status) {
            // send notification to user
            // we can make a request to an email service (like resend) 
            // to send the user the notification. But this will mean we'll have
            // to wait for a response from resend before sending a response to the client.
            // This makes the response time a bit longer
        } else {
            // somehting went wrong
        }
    }).catch((error) => {
        // an error occured
        res.status(400).send(error.message)
    }).finally(() => {
        res.status(200).send("Request Received")
    })
})

app.listen(3000)

在這個簡單的路線中，添加直接發送電子郵件通知的邏輯將導致我們的 api 有點慢。因此，我們可以做的是，在將行程新增至資料庫後，我們發出命名事件，清單器將選擇該事件並發送通知，然後使用 EventEmitter。以下是我們如何添加它。

import express from "express"
import EventEmitter from "node:events" // import the EventEmitter class
import { addTrip } from "./utils"

const app = express();
const myEmitter = new EventEmitter(); // We create an instance of the EventEmitter class

// Let's setup a listener to listen for a named event, in this case 'booking'
myEmitter.on("booking", (trip) => {
    // Make the call to your email service to send the email
    console.log(trip)
})

app.post("/book", (req, res) = {
    const {origin, destination, date} = req.body;

    if (!(origin && destination && date)) {
        res.status(400).send("Invalid request")
    }

    addTrip({
        origin, destination, date
    }).then((response) => {
        if (response.status) {
            // emit an event and the listener will pick it up
            let trip = response.data
            myEmitter.emit("book", trip)
        } else {
            // somehting went wrong
        }
    }).catch((error) => {
        // an error occured
        res.status(400).send(error.message)
    }).finally(() => {
        res.status(200).send("Request Received")
    })
})

app.listen(3000)

以上是帶有事件發射器的 EDD的詳細內容。更多資訊請關注PHP中文網其他相關文章！