首页 > 代码库 > Redis实践操作之—— 直播视频定时控制【TCP长连接框架(WorkerMan)+键空间通知的机制 ( Keyspace Notifications)+短信接口(API)】
Redis实践操作之—— 直播视频定时控制【TCP长连接框架(WorkerMan)+键空间通知的机制 ( Keyspace Notifications)+短信接口(API)】
一、思路梳理
- 同步直播视频到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
Redis实践操作之—— 直播视频定时控制【TCP长连接框架(WorkerMan)+键空间通知的机制 ( Keyspace Notifications)+短信接口(API)】
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。