一、思路梳理
- 同步直播视频到Redis
- 用户观看直播模板，点击直播按钮，检查是否有权限。
- 直播定时免费观看(免费观看10分钟)，用户点击播放按钮开始，异步检查获取直播活动设置的免费观看时间(后台维护人员设置,Redis的hash存储信息),是否是直播。
- 是直播视频：判断该客户是否已经观看过了免费的20分钟时间，
- 没有看过，则获取该直播视频的免费时间根据活动ID，同时设置该直播视频的过期时间（只针对该用户自己哦),返回个模板，说:这个人可以观看的。
- 直播视频已经看过了，则不可以继续观看哦！嘻嘻...
二、免费观看时间原理：
- 客户打开直播视频，立马通过消息系统(WorkerMan)获取clientId(该直播页面唯一的票据).
- 用户点击播放按钮时候，Ajax异步Post一个数据到服务器(clientId、liveId、openId)，绑定该用户的与直播视频，根据liveId在Redis获取该活动的免费过期时间expireTime，设置自己的基本信息存储到Reids中，哈希存储格式key：liveId+clientIp.
- 返回给直播模板200，客户可以观看啦！
- 这时候就会在服务器端有一个PHP脚本(psubscribe.php)在执行,执行方式一nohub,详情观看，他负责只要有key过期。这个脚本则会收到给key过期的事件（键空间通知的机制），该过期事件会返回一个回调函数(返回值：liveId+clientIp)，然后我们在这个回调函数中调用一个平台的API接口,同时传递参数过去【liveId+clientIp】,该接口接受到参数后，立马想视频直播页面通过消息机制（workerman），发送一条消息，免费时间观看完了，马上关闭视频，这时候只要在发送通知信息的时候携带一个参数状态即可。检查权限一开始就会终止掉该权限检测和关闭该视频直播的操作（JS+css样式去实现可以了），客户没办法观看了，直播窗口立即弹出。
- 再次点击则无法观看
- 刷新浏览器：点击继续观看，异步到Ｒｅｄｉｓ查找根据liveId和clientIp查找是否具有权限观看。
直播基本Redis信息hash存储：[后台维护人员设置或者同步Redis]
// 同步活动信息到Redis
public function synchronizeLive()
{
$liveId = ‘L00735‘;
$redis = new \Redis();
$redis->connect(‘121.141.188.202‘, 63789);
$setResult = $redis->hMset($liveId, [
‘liveId‘ => $liveId,
‘expireTime‘ => -1, //过期时间设定
‘isLive‘ => 1, //是否是直播，1.直播,0.非直播（历史回顾）
]);
if($setResult == false ) exit(‘Hmset fail‘);
exit(‘Hmset success‘);
}
权限设置判断代码：
/**
* 活动模板页面，权限请求处理
* 这个操作应该是客户端发起的请求，当客户点击播放按钮的时候，开始该活动的免费时间（10分钟）播放，到期立马关掉
*/
public function checkAuth($liveId = ‘L00735‘, $clientId = ‘‘, $openId = ‘‘)
{
$redis = new \Redis();
$redis->connect(‘121.41.88.209‘, 63789);
//检查是否是直播，还是历史回顾视频的观看
$isLive = $redis->hGet($liveId, ‘isLive‘);
$clientIp = $this->getClientIp();
if ($isLive == 1) //是直播 ,则这时候就会根据客户端的IP来判断，同一个IP则不可以继续观看啦
{
$watchTag = $redis->hGet($liveId . ‘:‘ . $clientIp, ‘watchTag‘); // 该值不存在，返回：false
if ($watchTag == false) { // 没有看过的
//用户给自己设置过期时间
$expireTime = $redis->hGet($liveId, ‘expireTime‘);
$redis->setex($liveId . ‘:‘ . $clientIp, $expireTime, $liveId . $expireTime);
$redis->hMset($liveId . ‘:‘ . $clientIp, [
‘liveId‘ => $liveId,
‘clientIp‘ => $clientIp, //客户端IP
‘clientId‘ => $clientId, //客户观看唯一id
‘watchTag‘ => 1, //观看标记:1.已经看过,0.一次都看过
‘openId‘ => $openId, //微信用户唯一标识
]);
//JSON 返回信息
$message = [
‘status‘ => 200,
‘liveId‘ => $liveId,
‘clientId‘ => $clientId,
‘watchTag‘ => 0, // 0 表示没有观看过
‘isLive‘ => $isLive, // 是直播
];
exit(json_encode($message)); // 您是第一来，可以观看的
} else {
$redisIp = $redis->hGet($liveId . ‘:‘ . $clientIp, ‘clientIp‘);
if ($clientIp == $redisIp && $watchTag == 1) {
$message = [
‘status‘ => 500,
‘liveId‘ => $liveId,
‘clientId‘ => $clientId,
‘watchTag‘ => 1, // 1 表示已经观看过了
‘isLive‘ => $isLive, // 是直播
];
exit(json_encode($message)); //不可以继续观看了
}
}
} else //不是直播,你可以继续观看，但是每次都是从头开始看哦
{
$watchTag = $redis->hGet($liveId . ‘:‘ . $clientIp, ‘watchTag‘); // 该值不存在，返回：false
if ($watchTag == false) // 您是第一来，可以观看的
{
//用户给自己设置过期时间
$expireTime = $redis->hGet($liveId, ‘expireTime‘);
$redis->setex($liveId . ‘:‘ . $clientIp, $expireTime, $liveId . $expireTime);
$redis->hMset($liveId . ‘:‘ . $clientIp, [
‘liveId‘ => $liveId,
‘clientIp‘ => $this->getClientIp(), //客户端IP
‘clientId‘ => $clientId, //客户观看唯一id
‘watchTag‘ => 1, //观看标记:1.已经看过,0.一次都看过
‘openId‘ => $openId, //微信用户唯一标识
]);
//JSON 返回信息
$message = [
‘status‘ => 200,
‘liveId‘ => $liveId,
‘clientId‘ => $clientId,
‘watchTag‘ => 0, // 1 表示已经观看过了
‘isLive‘ => 0, // 是直播
];
exit(json_encode($message));
}
// 您是第二次来了，自己给自己重新设置过期时间,从头开始播放吧
$expireTime = $redis->hGet($liveId, ‘expireTime‘);
$redis->setex($liveId . ‘:‘ . $clientIp, $expireTime, $liveId . $expireTime);
$redis->hMset($liveId . ‘:‘ . $clientIp, [
‘liveId‘ => $liveId,
‘clientIp‘ => $this->getClientIp(), //客户端IP
‘clientId‘ => $clientId, //客户观看唯一id
‘watchTag‘ => 1, //观看标记:1.已经看过,0.一次都看过
‘openId‘ => $openId, //微信用户唯一标识
]);
//========================统计该用户看过的次数以及刷新次数==========================
$redis->incr($liveId . ‘:‘ . $this->getClientIp());
//如果想知道用户在一年中每天的点击量，那么只要将用户 ID 以及相关的日期信息作为键
$redis->incr(date(‘Y-m-d‘) . ‘:‘ . $clientId);
//========================统计该用户看过的次数以及刷新次数==========================
$message = [
‘status‘ => 200,
‘liveId‘ => $liveId,
‘clientId‘ => $clientId,
‘watchTag‘ => 1, // 1 表示已经观看过了
‘isLive‘ => 0, // 是直播
];
exit(json_encode($message)); // 您是第一来，可以观看的
}
}
服务器API接口：
/**
* 过期事件处理
* 这个是一个key过期之后要执行的一个Api接口,同时携带liveId参数过来
*/
public function expireEvent()
{
$liveId = $_POST[‘liveId‘];
$redis = new \Redis();
$redis->connect(‘121.141.188.209‘, 63789);
//活动模板页面的消息处理
$clientId = $redis->hGet($liveId, ‘clientId‘);
$message = [
‘liveId‘ => $liveId,
‘clientId‘ => $clientId,
‘watchTag‘ => 1, // 1 表示已经观看过了
‘openId‘ => $redis->hGet($liveId, ‘openId‘),
];
Gateway::$registerAddress = ‘130.126.220.213:1238‘;
Gateway::sendToClient($clientId, $message);
$phone = ‘1366936*****‘;
$code = rand(100000, 999999);
$this->sendMessage($phone, $code);
}
发送短信接口：
/**
* @param $smsMob
* @param $code
* @return mixed|string
* 短信接口
*/
public function sendMessage($smsMob, $code)
{
$uId = "userName";
$key = "85fd6d7ab31231231214c557814df0";
$smsText = "你以为你干的这些事情没人知道?把你传网上去,看你还有什么脸,回复验证码:" . $code . ",自己看";
$url = ‘http://utf8.sms.webchinese.cn/?Uid=‘ . $uId . ‘&Key=‘ . $key . ‘&smsMob=‘ . $smsMob . ‘&smsText=‘ . $smsText;
if (function_exists(‘file_get_contents‘)) {
$file_contents = file_get_contents($url);
} else {
$ch = curl_init();
$timeout = 5;
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
$file_contents = curl_exec($ch);
curl_close($ch);
}
return $file_contents;
}
获取客户端ＩＰ地址：
/**
* 获取客户端IP
*/
public function getClientIp()
{
$ip = ‘unknown‘;
$unknown = ‘unknown‘;
if (isset($_SERVER[‘HTTP_X_FORWARDED_FOR‘]) && $_SERVER[‘HTTP_X_FORWARDED_FOR‘] && strcasecmp($_SERVER[‘HTTP_X_FORWARDED_FOR‘], $unknown)) {
// 使用透明代理、欺骗性代理的情况
$ip = $_SERVER[‘HTTP_X_FORWARDED_FOR‘];
} elseif (isset($_SERVER[‘REMOTE_ADDR‘]) && $_SERVER[‘REMOTE_ADDR‘] && strcasecmp($_SERVER[‘REMOTE_ADDR‘], $unknown)) {
// 没有代理、使用普通匿名代理和高匿代理的情况
$ip = $_SERVER[‘REMOTE_ADDR‘];
}
// 处理多层代理的情况
if (strpos($ip, ‘,‘) !== false) {
// 输出第一个IP
$ip = reset(explode(‘,‘, $ip));
}
return $ip;
}
待续．．．．．
参考地址:
- https://segmentfault.com/a/1190000002890750
- http://www.imooc.com/article/10431
时间： 2024-10-06 10:55:01