Express

const express = require("express");
const router = express.Router();

// 模拟用户数据
const users = [
  { id: 1, name: "zhangsan", email: "zhangsan@example.com" },
  { id: 2, name: "lisi", email: "lisi@example.com" },
  { id: 3, name: "wangwu", email: "wangwu@example.com" },
];

/* GET users listing */
router.get("/", function (req, res, next) {
  const { page = 1, limit = 10 } = req.query;
  const startIndex = (page - 1) * limit;
  const endIndex = startIndex + parseInt(limit);

  const paginatedUsers = users.slice(startIndex, endIndex);

  res.json({
    success: true,
    data: {
      total: users.length,
      page: parseInt(page),
      limit: parseInt(limit),
      items: paginatedUsers,
    },
  });
});

/* GET user by ID */
router.get("/:id", function (req, res, next) {
  const userId = parseInt(req.params.id);
  const user = users.find((u) => u.id === userId);

  if (!user) {
    return res.status(404).json({
      success: false,
      message: "User not found",
    });
  }

  res.json({
    success: true,
    data: user,
  });
});

/* POST create user */
router.post("/", function (req, res, next) {
  const { name, email } = req.body;

  if (!name || !email) {
    return res.status(400).json({
      success: false,
      message: "Name and email are required",
    });
  }

  const newUser = {
    id: users.length + 1,
    name,
    email,
  };

  users.push(newUser);

  res.status(201).json({
    success: true,
    data: newUser,
  });
});

module.exports = router;

const express = require("express");
const router = express.Router();

/* GET health check */
router.get("/", function (req, res, next) {
  res.json({
    status: "healthy",
    timestamp: new Date().toISOString(),
    framework: "Express",
    version: process.env.npm_package_version || "1.0.0",
    node_version: process.version,
  });
});

module.exports = router;

var createError = require("http-errors");
var express = require("express");
var path = require("path");
var cookieParser = require("cookie-parser");
var logger = require("morgan");

var indexRouter = require("./routes/index");
var usersRouter = require("./routes/users");
var healthRouter = require("./routes/health");

var app = express();

// view engine setup
app.set("views", path.join(__dirname, "views"));
app.set("view engine", "pug");

app.use(logger("combined"));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, "public")));

// 路由配置
app.use("/", indexRouter);
app.use("/api/users", usersRouter);
app.use("/health", healthRouter);

// 404 错误处理
app.use(function (req, res, next) {
  next(createError(404));
});

// 全局错误处理
app.use(function (err, req, res, next) {
  // 设置错误信息，只在开发环境提供详细错误
  res.locals.message = err.message;
  res.locals.error = req.app.get("env") === "development" ? err : {};

  // 返回 JSON 格式的错误信息
  if (req.path.startsWith("/api/") || req.path.startsWith("/health")) {
    res.status(err.status || 500).json({
      success: false,
      message: err.message,
      error: req.app.get("env") === "development" ? err.stack : undefined,
    });
  } else {
    // 渲染错误页面
    res.status(err.status || 500);
    res.render("error");
  }
});

module.exports = app;

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var app = require("../app");
var debug = require("debug")("express-app:server");
var http = require("http");

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || "9000");
app.set("port", port);

/**
 * Create HTTP server.
 */

var server = http.createServer(app);

/**
 * Listen on provided port, on all network interfaces.
 */

server.listen(port, "0.0.0.0");
server.on("error", onError);
server.on("listening", onListening);

/**
 * Normalize a port into a number, string, or false.
 */

function normalizePort(val) {
  var port = parseInt(val, 10);

  if (isNaN(port)) {
    // named pipe
    return val;
  }

  if (port >= 0) {
    // port number
    return port;
  }

  return false;
}

/**
 * Event listener for HTTP server "error" event.
 */

function onError(error) {
  if (error.syscall !== "listen") {
    throw error;
  }

  var bind = typeof port === "string" ? "Pipe " + port : "Port " + port;

  // handle specific listen errors with friendly messages
  switch (error.code) {
    case "EACCES":
      console.error(bind + " requires elevated privileges");
      process.exit(1);
      break;
    case "EADDRINUSE":
      console.error(bind + " is already in use");
      process.exit(1);
      break;
    default:
      throw error;
  }
}

/**
 * Event listener for HTTP server "listening" event.
 */

function onListening() {
  var addr = server.address();
  var bind = typeof addr === "string" ? "pipe " + addr : "port " + addr.port;
  debug("Listening on " + bind);
  console.log("Express server listening on " + bind);
}

// 加载环境变量
require("dotenv").config();

// 使用环境变量
const isDevelopment = process.env.NODE_ENV === "development";
const port = process.env.PORT || 9000;

const cors = require("cors");

// 配置 CORS
app.use(
  cors({
    origin: process.env.ALLOWED_ORIGINS?.split(",") || "*",
    credentials: true,
  }),
);

const morgan = require("morgan");

// 配置日志格式
app.use(morgan(process.env.NODE_ENV === "production" ? "combined" : "dev"));

// 全局错误处理
app.use((err, req, res, next) => {
  console.error(err.stack);

  res.status(err.status || 500).json({
    success: false,
    message: err.message,
    ...(process.env.NODE_ENV === "development" && { stack: err.stack }),
  });
});

const helmet = require("helmet");

// 安全头配置
app.use(helmet());