直播小程序开发

<!-- index.wxml -->
<view class="container">
  <video id="live-video" controls src="{{liveUrl}}" autoplay></video>
  <button bindtap="joinLive">加入直播</button>
</view>

// index.js
Page({
  data: {
    liveUrl: ''
  },
  onLoad: function () {
    this.getLiveUrl();
  },
  getLiveUrl: function () {
    // 调用后端接口获取直播地址
    wx.request({
      url: 'https://your-backend-api/live/url',
      success: (res) => {
        this.setData({
          liveUrl: res.data.url
        });
      }
    });
  },
  joinLive: function () {
    // 处理用户加入直播的逻辑
    wx.navigateTo({
      url: '/pages/live-room/live-room'
    });
  }
});

const express = require('express');
const { RTMP } = require('node-media-server');

const app = express();

const config = {
  rtmp: {
    port: 1935,
    chunk_size: 60000,
    gop_cache: true,
    ping: 30,
    ping_timeout: 60
  },
  http: {
    port: 8000,
    allow_origin: '*'
  }
};

var nms = new RTMP(config);
nms.run();

app.get('/live/url', (req, res) => {
  res.json({ url: 'rtmp://your-server/live/stream' });
});

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