蜗牛（tete）语音软件系统开发全市场源码搭建平台（案例）

const express = require('express');
const http = require('http');
const socketIo = require('socket.io');

const app = express();
const server = http.createServer(app);
const io = socketIo(server);

app.use(express.static('public')); // Serve static files from the public directory

// Store the list of connected users
let users = {};

io.on('connection', (socket) => {
    console.log('User connected: ', socket.id);

    // Join a room
    socket.on('join-room', (roomId) => {
        socket.join(roomId);
        console.log(`User ${socket.id} joined room ${roomId}`);

        // Notify others that a new peer has joined the room
        socket.to(roomId).emit('new-peer', socket.id);
    });

    // Handle offer
    socket.on('offer', (data) => {
        console.log('Received offer from ' + socket.id);
        socket.to(data.id).emit('offer', { offer: data.offer, id: socket.id });
    });

    // Handle answer
    socket.on('answer', (data) => {
        console.log('Received answer from ' + socket.id);
        socket.to(data.id).emit('answer', { answer: data.answer, id: socket.id });
    });

    // Handle ICE candidates
    socket.on('ice-candidate', (data) => {
        console.log('Received ICE candidate from ' + socket.id);
        socket.to(data.id).emit('ice-candidate', { candidate: data.candidate, id: socket.id });
    });

    // Disconnecting
    socket.on('disconnect', () => {
        console.log('User disconnected: ', socket.id);
        for (let roomId of socket.rooms) {
            socket.to(roomId).emit('user-left', socket.id);
        }
    });
});

const PORT = process.env.PORT || 3000;
server.listen(PORT, () => {
    console.log(`Server running on port ${PORT}`);
});