双12低延时互动直播购买

const { RTCPeerConnection, RTCSessionDescription } = require('wrtc');
const express = require('express');
const app = express();

app.use(express.static('public'));

app.get('/offer', async (req, res) => {
    const peerConnection = new RTCPeerConnection();
    // 设置ICE候选者
    peerConnection.onicecandidate = event => {
        if (event.candidate) {
            // 发送ICE候选者到服务器
        }
    };
    // 处理远程描述
    const offer = new RTCSessionDescription(req.body);
    await peerConnection.setRemoteDescription(offer);
    // 创建并发送回答
    const answer = await peerConnection.createAnswer();
    await peerConnection.setLocalDescription(answer);
    res.json(peerConnection.localDescription);
});

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