私域直播小程序搭建全流程：从0到1打造企业专属直播平台

用户端小程序
      │
      ▼
API接口层
      │
 ┌────┼────┐
 ▼         ▼
直播服务   商城服务
 ▼         ▼
Redis    MySQL
 ▼
对象存储OSS

function createPushUrl($streamName)
{
    $key = "live_secret";
    $time = strtoupper(dechex(time()+3600));

    $txSecret = md5($key.$streamName.$time);

    return "rtmp://live.push.com/live/".$streamName.
           "?txSecret=".$txSecret.
           "&txTime=".$time;
}

rtmp://push.aliyun.com/live/test

https://play.aliyun.com/live/test.m3u8

navigator.mediaDevices
.getUserMedia({
    video:true,
    audio:true
})
.then(stream=>{
    video.srcObject=stream;
});

微信小程序
+
UniApp
+
Vue3

<view class="live-container">

  <video
    id="livePlayer"
    src="{{liveUrl}}"
    autoplay
    controls
  ></video>

  <view class="goods-list">
      <view wx:for="{{goods}}">
          {{item.name}}
      </view>
  </view>

</view>

<view class="goods-popup">

  <image src="{{goods.cover}}"></image>

  <text>{{goods.title}}</text>

  <button bindtap="buyNow">
      立即购买
  </button>

</view>

Page({

  data:{
      likes:0
  },

  sendLike(){

      this.setData({
          likes:this.data.likes+1
      })

  }

})

Java SpringBoot
或
PHP Laravel
或
Node.js NestJS

@RestController
@RequestMapping("/user")
public class UserController {

    @PostMapping("/login")
    public Result login(
            @RequestBody LoginDTO dto){

        return userService.login(dto);
    }

}

@GetMapping("/live/list")
public Result getLiveList(){

    List<LiveRoom> rooms =
            liveService.list();

    return Result.success(rooms);
}

@PostMapping("/live/create")
public Result createLive(
        @RequestBody LiveDTO dto){

    return liveService.create(dto);

}

WebSocket

@ServerEndpoint("/chat/{uid}")
@Component
public class ChatServer {

    private Session session;

    @OnOpen
    public void onOpen(
            Session session){

        this.session=session;
    }

    @OnMessage
    public void onMessage(
            String message){

        session.getBasicRemote()
                .sendText(message);
    }

}

const ws = new WebSocket(
    "wss://api.demo.com/chat/1"
)

ws.onmessage=function(e){

    console.log(e.data)

}

@PostMapping("/order/create")
public Result createOrder(
        @RequestBody OrderDTO dto){

    return orderService.create(dto);

}

Map<String,String> params =
wechatPayService.unifiedOrder(
    orderNo,
    amount
);

{
  "timeStamp":"123456",
  "nonceStr":"abcdef",
  "package":"prepay_id=xxxx",
  "signType":"RSA",
  "paySign":"xxxx"
}

CREATE TABLE member_level(

id BIGINT PRIMARY KEY,

level_name VARCHAR(50),

growth_value INT,

discount_rate DECIMAL(10,2)

);

coupon

group_buy

flash_sale

distribution

live_lottery

redisTemplate.opsForValue()
.set(
    "live:room:1001",
    roomData
);

主播
 ↓
直播云
 ↓
CDN节点
 ↓
用户

RabbitMQ
Kafka
RocketMQ

4核8G
100M带宽

8核16G
200M带宽

Nginx
Docker
MySQL
Redis
SpringBoot

docker run -d \
-p 8080:8080 \
--name live-system \
live-platform:1.0