Day22 [实作] 一对一视讯通话(2): Signaling server

今天我们要实作 Signaling server 的部分：

建立文件

# 进入要放专案的路径
❯ cd ~/Desktop/WebRTC/sample

# 建立名为 1-on-1-webrtc 的资料夹
❯ mkdir 1-on-1-webrtc

# 进入 1-on-1-webrtc 资料夹内部
❯ cd 1-on-1-webrtc

# 建立 server.js 文件
❯ touch server.js

# 建立静态文件资料夹
❯ mkdir pubilc

# 建立 node.js 专案
❯ npm init --yes

# 安装必要的套件
❯ npm install express socket.io

# 在静态文件资料夹内建立 index.html 并写入 hello 用於测试
❯ echo "hello" > pubilc/index.html

使用 express 读取静态文件

在 server.js 中输入以下程序码

const express = require('express')
const app = express()
const http = require('http').createServer(app)

// 静态资源
app.use('/', express.static(__dirname + '/public/'))

// TODO: Signaling

// 启动 server 监听 8080 port
http.listen(8080, () => {
  console.log(`Server running in 8080`)
})

启动 server 测试静态文件

开启终端机

❯ cd ~/Desktop/WebRTC/sample/1-on-1-webrtc
❯ node server

加入信令(Signaling)

打开 server.js 在 TODO 的地方加入以下程序码：

const io = require('socket.io')(http, {
  cors: true,
})

// 有人连线就会触发
io.on('connection', (socket) => {

  // 加入房间
  socket.on('join', (room) => {
    socket.join(room)
    socket.to(room).emit('ready', '准备通话')
  })

  // 转传 Offer
  socket.on('offer', (room, desc) => {
    socket.to(room).emit('offer', desc)
  })

	// 转传 Answer
  socket.on('answer', (room, desc) => {
    socket.to(room).emit('answer', desc)
  })

  // 交换 ice candidate
  socket.on('ice_candidate', (room, data) => {
    socket.to(room).emit('ice_candidate', data)
  })

})

server.js 完整程序码如下

const express = require('express')
const app = express()
const http = require('http').createServer(app)

// 静态资源
app.use('/', express.static(__dirname + '/public/'))

const io = require('socket.io')(http, {
  cors: true,
})

// 有人连线就会触发
io.on('connection', (socket) => {

  // 加入房间
  socket.on('join', (room) => {
    socket.join(room)
    socket.to(room).emit('ready', '准备通话')
  })

  // 转传 Offer
  socket.on('offer', (room, desc) => {
    socket.to(room).emit('offer', desc)
  })

	// 转传 Answer
  socket.on('answer', (room, desc) => {
    socket.to(room).emit('answer', desc)
  })

  // 交换 ice candidate
  socket.on('ice_candidate', (room, data) => {
    socket.to(room).emit('ice_candidate', data)
  })

})

http.listen(8080, () => {
  console.log(`Server running in 8080`)
})

启动 server