PHP快⼿直播弹幕采集，获取⽃鱼弹幕php版（原创）实例
error_reporting(0);
$config = array(
'roomId'=>$argv[1],//房间ID
'dmServerIp'=>gethostbyname('openbarrage.douyutv'),
'dmServerPort'=> 8601,//
'groupId'=>-9999,//据说⽬前填-9999就⾏不须获取gid了
'gidServerIp'=>'119.90.49.110',//119.90.49.111  119.90.49.104
'gidServerPort'=>8046,//8020
);
function checkRoomOnline($html){
$reg = '#"show_status":(\d*),#';
preg_match($reg,$html,$match);
if(count($match)==0){
return -1;
}
return $match[1];
}
function packMsg($str){
$length = pack('V', 4 + 4 + strlen($str) + 1);
$code = $length;
$magic = chr(0xb1).chr(0x02).chr(0x00).chr(0x00);
$end = chr(0x00);
return $length.$code.$magic.$str.$end;
}
function guid(){山下智久电视剧
mt_srand((double)microtime()*10000);//optional for php 4.2.0 and up.
$charid = strtoupper(md5(uniqid(rand(), true)));
$hyphen = chr(45);// "-"
腾讯q币充值中心
$uuid = //chr(123)// "{"
substr($charid, 0, 8).$hyphen
.substr($charid, 8, 4).$hyphen
.substr($charid,12, 4).$hyphen
.
substr($charid,16, 4).$hyphen
.substr($charid,20,12);
// .chr(125);// "}"
return $uuid;
}
function getGidMsg(){
global $config;
$time = time();
$uuid = str_replace('-','',guid());
$msg = 'type@=loginreq/username@=/password@=/roomid@='.$config['roomId'].'/'; $msg.='ct@=2/';
$msg.='devid@='.$uuid.'/';
$msg.='rt@='.$time;
$msg.='vk@='.md5($time.'7oE9nPEG9xXV69phU31FYCLUagKeYtsF'.$uuid).'/'; $msg.='ver@=20150929/';
return $msg;
}
function msg_decode($str)
{
if(empty($str)){
return '';
}
$data = array();
$key = $val = '';
if ($str[strlen($str) - 1] !== '/') {
$str .= '/';
}
for ($i = 0; $i
if ($str[$i] == '/') {
$data[$key] = $val;
if(strpos($val,'@S/')!==false){
胡静老公朱兆祥$arr = explode('@S/',$val);
$data[$key] = array();
foreach($arr as $v){
$data[$key][] = msg_decode(decodeStr($v));
}
}
$key=$val='';
} else {
if($str[$i]=='@'){
$i++;
if($str[$i]=='A'){
$val.='@';
}else{
if($str[$i]=='S'){
$val.='/';
}else{
if($str[$i]=='='){
$key = $val;
$val='';
王珞丹孔二狗}
蒜蓉辣酱的做法
}
}
}else{
$val.=$str[$i];
}
}
}
return $data;
}
吴毅将所有电影function decodeStr($str){
return str_replace('@S','/',str_replace('@A','@',$str)); }
function getServerConfig($html){
global $config;
$reg = '#server_config":"(.*?)"#';
preg_match($reg,$html,$match);
$t = urldecode($match[1]);
$list = (json_decode($t,true));
if(!empty($list)){
$config['gidServerIp'] = $list[0]['ip'];
$config['gidServerPort'] = $list[0]['port'];
echo "get gidServerIp success ip:{$config['gidServerIp']},
port:{$config['gidServerPort']}\r\n";
}else{
echo 'get gidServerIp error '."\r\n";
}
}
function getGid(){
global $config;
$gid_client = new swoole_client(SWOOLE_SOCK_TCP);
if (!$gid_client->connect($config['gidServerIp'], $config['gidServerPort'], -1)) {
exit("connect failed. Error: {$gid_client->errCode}\n");
}
$gid_client->send(packMsg(getGidMsg()));
$str = $gid_client->recv();
$str.= $gid_client->recv();
print_r(msg_decode($str));
$gid_client->close();
preg_match_all('#gid@=(\d+)/#',decodeStr($str),$matchs);
foreach($matchs as $gid){
if(is_numeric($gid[0]) && $gid[0]>0){
$config['groupId'] = $gid[0];
break;
}
}
preg_match('#@ASport@AA=(\d+)@#',$str,$ports);
if($ports[1]>1){
$config['dmServerPort'] = $ports[1];
}
echo 'gid is '.$config['groupId']."\r\n port is {$config['dmServerPort']}";
}
if(empty($argv[1])){
die('参数有误，房间id不存在，Usage：php yu.php 265593'."\n");
}
$html = file_get_contents('www.douyutv/'.$config['roomId']);
$roomStatus = checkRoomOnline($html);
if($roomStatus==-1){
die("房间{$config['roomId']}不存在\n");
}else if($roomStatus==2){
echo "房间{$config['roomId']}还在直播路上\n";
}
getServerConfig($html);
/
/getGid();  //获取gid  //据说⽬前填-9999就⾏不须获取gid了
$client = new swoole_client(SWOOLE_SOCK_TCP,SWOOLE_SOCK_ASYNC);
$client->on("connect", function($cli) {
global $config;
$cli->send(packMsg(
'type@=loginreq/username@=auto_KRLJbE8mZM/password@=1234567890123456/roomid@=' .$config['roomId'].'/'));
$cli->send(packMsg("type@=joingroup/rid@="
.$config['roomId'] . "/gid@=".$config['groupId']."/"));
});
$client->on("receive", function($cli, $data){
static $flag=true;
$sub_data = substr($data,12,-1);
//file_put_contents("",$sub_data."\r\n",8);
$dataArr = msg_decode($sub_data);
if(empty($dataArr['type'])){
echo '解析错误，原始数据:'.$data."\r\n";
return;
}
switch($dataArr['type']){
case "loginres":
echo '已连接上服务器...'."\r\n";