How to implement online live broadcast function in php

How to implement the online live broadcast function in php: 1. Find the live broadcast cloud service in the console and create a live broadcast cloud space; 2. Parse the domain name as needed; 3. Install the composer package; 4. Implement it through the liveStart method Just live broadcast.

The operating environment of this article: Windows 7 system, PHP version 7.1, Dell G3 computer.

How to implement online live broadcast function in php?

php Qiniu Cloud implements the live broadcast function:

1: I am currently working on a live broadcast selling project. The background is set up and ready to be connected to the live broadcast. I searched Alibaba, TX and Qiniu, and found out that Alibaba’s live broadcast PHP only has code and no documentation. My friend from TX said that the code is messy, so I didn’t consider it. I registered an account with Qiniu, but when I applied for the live broadcast space, I was blocked by the domain name. The card owner is stuck. The domain name that has already been registered needs to be registered with the public security on the website again

https://developer.qiniu.com/af/kb/3987/how-to-make-website-and-inquires-the-police-put-on-record-information?ref=support.qiniu.com

I searched again and found that if it involves online performance business, you need to apply for an "Internet Culture Business License", please consult the cultural administration of the local people's government Department, wait for the application to be completed before proceeding to the next step.

##2: The domain name registration is finally ready, let’s start the second step to implement the live broadcast function, you can refer to Seven on the mobile terminal Niuyun SDK, the following is a case of server-side push streaming. This time, rtmp stream is used to implement live broadcast. Find the live broadcast cloud service in the console and create the live broadcast cloud space.

will be generated after the live broadcast space is created. Several second-level domain names, parse the domain names as needed, and then it will look like the following

After the code is run, you will see the playback history and other information of the live stream you created in the live stream

Install composer package

php composer.phar require qiniu/php-sdk

You can find two cases in vendor/pili-engineering/pili-sdk-php.v2, one is live broadcast and the other is continuous wheat. This time I will implement the live broadcast first, and I will update Lianmai in the next article

<?php namespace App\Modules\Api\Http\Controllers;

use App\Modules\Live\Models\Broadcast;
use App\Modules\Live\Repositories\BroadcastRepositoryEloquent;
use Illuminate\Http\Request;
use Qiniu\Pili\Client;
use Qiniu\Pili\Mac;
use function Qiniu\Pili\RTMPPlayURL;
use function Qiniu\Pili\RTMPPublishURL;
use function Qiniu\Pili\SnapshotPlayURL;

class LiveController extends ApiBaseController
{
    private $auth;
    private $accessKey;
    private $secretKey;
    private $hubName;

    /**
     * Create a new controller instance.
     *
     * @return void
     */
    public function __construct()
    {
        $this->accessKey = config("qiniu.accessKey");
        $this->secretKey = config("qiniu.secretKey");
        $this->hubName = config("qiniu.bucket");
        parent::__construct();
    }
    /**
     *开启直播
     */
    public function liveStart(Request $request)
    {
        $userInfo = parent::getAuthenticatedUser($msg);
        if (isset($userInfo['user']) && !empty($userInfo['user'])) {
            $request->offsetSet('user_id', $userInfo['user']['id']);
        } else {
            return $this->sendResponse($msg, 'error', '', 401);
        }
        $data = $request->all();
        $broadcast = app(BroadcastRepositoryEloquent::class)->findWhere(['type' => $data['type'], 'user_id' => $data['user_id']])->first();
        if (empty($broadcast)) {
            return $this->sendResponse(trans('admin.operate_failed') . '未找到直播间');
        }
        $broadcast['name'] = $data['name'];
        //创建hub
        $mac = new Mac($this->accessKey, $this->secretKey);
        $client = new Client($mac);
        $hub = $client->hub($this->hubName);
        //获取stream
        $streamKey = $broadcast['show_id'];
        $stream = $hub->stream($streamKey);
        $list = $hub->listStreams($streamKey, 1, "");
        //如果没找到对应的直播流创建新直播流
        if (count($list['keys']) == 0) {
            //获取stream
            $hub->create($streamKey);
        }
        if ($data['type'] == 0) {
            $result = $this->updateShop($broadcast, $streamKey, $msg);
            if ($result == false) {
                return $this->sendResponse(trans('admin.operate_failed') . $msg);
            }
        } else {
            $result = $this->updateCurriculum($broadcast, $streamKey, $msg);
            if ($result == false) {
                return $this->sendResponse(trans('admin.operate_failed') . $msg);
            }
        }
        return $this->sendResponse(trans('admin.operate_succeeded'), 'succ', ['p_href' => $broadcast['p_href']]);
    }

    //更新商城直播间
    public function updateShop($broadcast, $streamKey, &$msg = '')
    {
        //获取推流地址
        $p_href = RTMPPublishURL("pili-publish.chengdulihong.com", $this->hubName, $streamKey, 3600, $this->accessKey, $this->secretKey);
        //获取播放地址
        $g_href = RTMPPlayURL("pili-publish.chengdulihong.com", $this->hubName, $streamKey);
        //截图直播地址
        $pic = SnapshotPlayURL("pili-publish.chengdulihong.com", $this->hubName, $streamKey);
        //更新直播间状态
        $u_broadcast = $broadcast->fill(['name' => $broadcast['name'], 'chatroom_status' => 0, 'p_href' => $p_href, 'g_href' => $g_href, 'pic' => $pic])->save();
        if ($u_broadcast == false) {
            return $this->sendResponse(trans('admin.operate_failed') . '更新直播间出错');
        }
        return true;
    }

Recommended learning: "

PHP Video Tutorial"

The above is the detailed content of How to implement online live broadcast function in php. For more information, please follow other related articles on the PHP Chinese website!