游戏服务器引擎秒杀

const express = require('express');
const app = express();
const { Pool } = require('pg'); // PostgreSQL数据库连接池

const pool = new Pool({
  user: 'your_db_user',
  host: 'your_db_host',
  database: 'your_db_name',
  password: 'your_db_password',
  port: 5432,
});

app.use(express.json());

app.post('/seckill', async (req, res) => {
  const { productId, userId } = req.body;
  
  try {
    // 开始事务
    await pool.query('BEGIN');
    
    // 检查商品库存
    const stockQuery = 'SELECT stock FROM products WHERE id = $1 FOR UPDATE';
    const stockResult = await pool.query(stockQuery, [productId]);
    
    if (stockResult.rows[0].stock <= 0) {
      await pool.query('ROLLBACK');
      return res.status(400).send('Out of stock');
    }
    
    // 减少库存
    const updateStockQuery = 'UPDATE products SET stock = stock - 1 WHERE id = $1';
    await pool.query(updateStockQuery, [productId]);
    
    // 记录秒杀成功
    const insertRecordQuery = 'INSERT INTO seckill_records (product_id, user_id) VALUES ($1, $2)';
    await pool.query(insertRecordQuery, [productId, userId]);
    
    // 提交事务
    await pool.query('COMMIT');
    
    res.send('Seckill successful');
  } catch (error) {
    await pool.query('ROLLBACK');
    res.status(500).send('Internal Server Error');
  }
});

app.listen(3000, () => {
  console.log('Server is running on port 3000');
});