私域直播系统开发从0开始：完整搭建流程解析

主播端推流 → 流媒体服务器 → CDN分发 → 用户播放

rtmp {
    server {
        listen 1935;
        chunk_size 4096;

        application live {

            live on;

            record off;

            hls on;

            hls_path /tmp/hls;

            hls_fragment 3;
        }
    }
}

rtmp://live.xxx.com/live/test

http://live.xxx.com/hls/test.m3u8

<template>
  <video
    ref="videoPlayer"
    controls
    autoplay
    class="live-video"
  ></video>
</template>

<script>
import Hls from 'hls.js'

export default {

  mounted() {

    const video = this.$refs.videoPlayer

    const hls = new Hls()

    hls.loadSource('https://live.xxx.com/live/test.m3u8')

    hls.attachMedia(video)
  }
}
</script>

const WebSocket = require('ws')

const wss = new WebSocket.Server({
    port: 8080
})

wss.on('connection', ws => {

    ws.on('message', message => {

        wss.clients.forEach(client => {

            client.send(message.toString())

        })

    })

})

CREATE TABLE live_goods (

    id BIGINT PRIMARY KEY AUTO_INCREMENT,

    live_id BIGINT,

    goods_name VARCHAR(255),

    price DECIMAL(10,2),

    stock INT,

    cover VARCHAR(500),

    status TINYINT
);

public boolean deductStock(Long goodsId){

    Long stock = redisTemplate.opsForValue()
        .decrement("goods_stock_" + goodsId);

    return stock >= 0;
}

Map<String, String> data = new HashMap<>();

data.put("appid", appId);

data.put("mch_id", mchId);

data.put("nonce_str", UUID.randomUUID().toString());

data.put("body", "直播商品购买");

data.put("out_trade_no", orderNo);

data.put("total_fee", "100");

String result = wxPay.unifiedOrder(data);

直播流录制 → 视频存储 → 上传OSS → 生成回放

ffmpeg -i rtmp://live.xxx.com/live/test \
-c copy \
-f mp4 \
record.mp4

FROM openjdk:17

COPY live.jar app.jar

ENTRYPOINT ["java","-jar","/app.jar"]

apiVersion: apps/v1

kind: Deployment

metadata:
  name: live-system

spec:

  replicas: 3

  selector:
    matchLabels:
      app: live-system

  template:

    metadata:
      labels:
        app: live-system

    spec:

      containers:
      - name: live-system

        image: live-system:v1