物联网操作系统限时秒杀

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const redis = require('redis');
const client = redis.createClient();

app.use(bodyParser.json());

// 模拟库存
let stock = 100;

app.post('/seckill', async (req, res) => {
    if (stock <= 0) {
        return res.status(400).send('Out of stock');
    }

    // 使用Redis实现分布式锁
    const lockKey = 'seckill_lock';
    const lockAcquired = await acquireLock(client, lockKey);
    if (!lockAcquired) {
        return res.status(503).send('Service Unavailable');
    }

    try {
        // 扣减库存
        stock--;
        // 处理订单逻辑...
        res.send('Seckill successful');
    } finally {
        releaseLock(client, lockKey);
    }
});

async function acquireLock(client, key) {
    return new Promise((resolve) => {
        client.set(key, 'locked', 'NX', 'EX', 10, (err, reply) => {
            resolve(reply === 'OK');
        });
    });
}

function releaseLock(client, key) {
    client.del(key);
}

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