|
|
@@ -1,1063 +1,1064 @@
|
|
|
-
|
|
|
-//引入http模块
|
|
|
-var socketio = require('socket.io'),
|
|
|
- fs = require('fs'),
|
|
|
- https = require('http'),
|
|
|
- domain = require('domain'),
|
|
|
- redis = require('redis'),
|
|
|
- redisio = require('socket.io-redis'),
|
|
|
- request = require('request'),
|
|
|
- md5 = require('md5-node'),
|
|
|
- config = require('./config.js');
|
|
|
-
|
|
|
-var d = domain.create();
|
|
|
-d.on("error", function(err) {
|
|
|
- //console.log(err);
|
|
|
-});
|
|
|
-
|
|
|
-//var numscount=0;// 在线人数统计
|
|
|
-var sockets = {};
|
|
|
-var chat_history={};
|
|
|
-var chat_interval={};
|
|
|
-/* 主播连麦关系 */
|
|
|
-var LiveConnect={};
|
|
|
-var LiveConnect_pull={};
|
|
|
-
|
|
|
-
|
|
|
-// redis 链接
|
|
|
-var clientRedis = redis.createClient(config['REDISPORT'],config['REDISHOST']);
|
|
|
-clientRedis.auth(config['REDISPASS']);
|
|
|
-//var server = https.createServer(options,function(req, res) {
|
|
|
-var server = https.createServer(function(req, res) {
|
|
|
- res.writeHead(200, {
|
|
|
- 'Content-type': 'text/html;charset=utf-8'
|
|
|
- });
|
|
|
- //res.write("人数: " + numscount );
|
|
|
- res.end();
|
|
|
-}).listen(config['socket_port'], function() {
|
|
|
- ////console.log('服务开启19965');
|
|
|
-});
|
|
|
-
|
|
|
-var io = socketio.listen(server,{
|
|
|
- pingTimeout: 60000,
|
|
|
- pingInterval: 25000
|
|
|
-});
|
|
|
-/* var pub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] });
|
|
|
- var sub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] });
|
|
|
- io.adapter(redisio({ pubClient: pub, subClient: sub })); */
|
|
|
-//setInterval(function(){
|
|
|
- //global.gc();
|
|
|
- ////console.log('GC done')
|
|
|
-//}, 1000*30);
|
|
|
-
|
|
|
-io.on('connection', function(socket) {
|
|
|
- //console.log('连接成功');
|
|
|
- //numscount++;
|
|
|
-
|
|
|
- var interval;
|
|
|
-
|
|
|
- //进入房间
|
|
|
- socket.on('conn', function(data) {
|
|
|
-
|
|
|
- if(!data || !data.token){
|
|
|
- return !1;
|
|
|
- }
|
|
|
-
|
|
|
- userid=data.uid;
|
|
|
- old_socket = sockets[userid];
|
|
|
- if (old_socket && old_socket != socket) {
|
|
|
-
|
|
|
- if(data.uid != data.roomnum && data.uid==old_socket.roomnum){
|
|
|
- /* 进房间 但旧链接是 主播 */
|
|
|
- var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}';
|
|
|
- old_socket.emit('broadcastingListen',[data_str]);
|
|
|
- }else if(data.uid== data.roomnum && data.stream==old_socket.stream){
|
|
|
- /* 主播重连 */
|
|
|
- old_socket.reusing = 1;
|
|
|
- //console.log("重用");
|
|
|
- }else if(data.uid== data.roomnum && data.stream!=old_socket.stream){
|
|
|
- /* 主播多端开播 */
|
|
|
- var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}';
|
|
|
- old_socket.emit('broadcastingListen',[data_str]);
|
|
|
- }
|
|
|
- old_socket.disconnect()
|
|
|
- }
|
|
|
-
|
|
|
- clientRedis.get(data.token,function(error,res){
|
|
|
- if(error){
|
|
|
- return;
|
|
|
- }else if(res==null){
|
|
|
- //console.log("[获取token失败]"+data.uid);
|
|
|
- }else{
|
|
|
- if(res != null){
|
|
|
-
|
|
|
- var userInfo = evalJson(res);
|
|
|
- if(userInfo['id'] == data.uid ){
|
|
|
- //console.log("[初始化验证成功]--"+data.uid+"---"+data.roomnum+'---'+data.stream);
|
|
|
- //获取验证token
|
|
|
- socket.token = data.token;
|
|
|
- socket.roomnum = data.roomnum;
|
|
|
- socket.stream = data.stream;
|
|
|
- socket.nicename = userInfo['user_nickname'];
|
|
|
- socket.avatar = userInfo['avatar'];
|
|
|
- socket.sign = Number(userInfo['sign']);
|
|
|
- socket.usertype = parseInt(userInfo['usertype']);
|
|
|
- socket.uid = data.uid;
|
|
|
- socket.reusing = 0;
|
|
|
-
|
|
|
- socket.join(data.roomnum);
|
|
|
- sockets[userid] = socket;
|
|
|
- socket.emit('conn',['ok']);
|
|
|
-
|
|
|
- if( socket.roomnum!=socket.uid && socket.uid >0 ){
|
|
|
-
|
|
|
-
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"SendMsg",
|
|
|
- "action":"0",
|
|
|
- "ct":{
|
|
|
- "id":''+userInfo['id'],
|
|
|
- "user_nickname":''+userInfo['user_nickname'],
|
|
|
- "avatar":userInfo['avatar'],
|
|
|
- "avatar_thumb":userInfo['avatar_thumb'],
|
|
|
- "usertype":''+userInfo['usertype'],
|
|
|
- "guard_type":''+userInfo['guard_type'],
|
|
|
- "contribution":''+userInfo['contribution'],
|
|
|
-
|
|
|
- },
|
|
|
- "msgtype":"0"
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
- process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
- if(socket.stream){
|
|
|
- clientRedis.zadd('user_'+socket.stream,socket.sign,userInfo['id']);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- //sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容,账号会被封禁;安全部门会24小时巡查哦~");
|
|
|
- var stemMgs='直播内容包含任何低俗、暴露和涉黄内容,账号会被封禁;安全部门会24小时巡查哦~';
|
|
|
- if(userInfo['lang']=='en'){
|
|
|
- stemMgs='If the live content contains any vulgar, explicit, or pornographic content, the account will be banned; The security department will conduct 24-hour inspections~';
|
|
|
- }
|
|
|
- sendSystemMsg(socket,stemMgs);
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- return;
|
|
|
- }else{
|
|
|
- socket.disconnect();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- socket.emit('conn',['no']);
|
|
|
- });
|
|
|
-
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
- socket.on('broadcast',function(data){
|
|
|
- ////console.log(data);
|
|
|
- if(socket.token != undefined){
|
|
|
- var dataObj = typeof data == 'object'?data:evalJson(data);
|
|
|
-
|
|
|
- //console.log('==================='+data);
|
|
|
- var msg = dataObj['msg'][0];
|
|
|
- var token = dataObj['token'];
|
|
|
- var method = msg['_method_'];
|
|
|
- var action = msg['action'];
|
|
|
- var data_str = typeof data == 'object'?JSON.stringify(data):data;
|
|
|
- switch(method){
|
|
|
- case 'SendMsg':{ //聊天
|
|
|
-
|
|
|
- //sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容,账号会被封禁;安全部门会24小时巡查哦~");
|
|
|
-
|
|
|
- clientRedis.hget( "super",socket.uid,function(error,res){
|
|
|
- if(error) return;
|
|
|
- if(res != null){
|
|
|
- var data_str2={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"SystemNot",
|
|
|
- "action":"1",
|
|
|
- "ct":''+dataObj['msg'][0]['ct'],
|
|
|
- "msgtype":"4"
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
-
|
|
|
-
|
|
|
- process_msg(io,socket.roomnum,JSON.stringify(data_str2));
|
|
|
- }else{
|
|
|
- clientRedis.hget(socket.roomnum + "shutup",socket.uid,function(error,res){
|
|
|
- if(error) return;
|
|
|
- if(res != null){
|
|
|
- var newData = dataObj;
|
|
|
- newData['retcode'] = '409002';
|
|
|
- socket.emit('broadcastingListen',[JSON.stringify(newData)]);
|
|
|
- }else{
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
- });
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'SendGift':{ //送礼物
|
|
|
- var gifToken = dataObj['msg'][0]['ct'];
|
|
|
- clientRedis.get(gifToken,function(error,res){
|
|
|
- if(!error&&res != null){
|
|
|
- var resObj = evalJson(res);
|
|
|
- dataObj['msg'][0]['ct'] = resObj;
|
|
|
-
|
|
|
- var ifpk='0',
|
|
|
- pkuid1='0',
|
|
|
- pkuid2='0',
|
|
|
- pktotal1='0',
|
|
|
- pktotal2='0';
|
|
|
-
|
|
|
- //console.log('SendGift');
|
|
|
- //console.log(resObj);
|
|
|
- if(resObj['ispk']==1 ){
|
|
|
- ifpk='1';
|
|
|
- pkuid1=''+resObj['pkuid1'];
|
|
|
- pkuid2=''+resObj['pkuid2'];
|
|
|
- pktotal1=''+resObj['pktotal1'];
|
|
|
- pktotal2=''+resObj['pktotal2'];
|
|
|
- //console.log('pk');
|
|
|
- }
|
|
|
- dataObj['msg'][0]['ifpk']=ifpk;
|
|
|
- dataObj['msg'][0]['pkuid1']=pkuid1;
|
|
|
- dataObj['msg'][0]['pkuid2']=pkuid2;
|
|
|
- dataObj['msg'][0]['pktotal1']=pktotal1;
|
|
|
- dataObj['msg'][0]['pktotal2']=pktotal2;
|
|
|
- dataObj['msg'][0]['roomnum']=socket.roomnum;
|
|
|
-
|
|
|
-
|
|
|
- console.log('---------礼物信息--------------------'+[JSON.stringify(dataObj)]);
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- io.sockets.in(socket.roomnum).emit('broadcastingListen',[JSON.stringify(dataObj)]);
|
|
|
- if(pkuid2>0){
|
|
|
-
|
|
|
- io.sockets.in(pkuid2).emit('broadcastingListen',[JSON.stringify(dataObj)]);
|
|
|
- }
|
|
|
-
|
|
|
- clientRedis.del(gifToken);
|
|
|
- }
|
|
|
- });
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'ConnectVideo' :{ //用户和主播连麦
|
|
|
- //1:发起连麦;2;接受连麦;3:拒绝连麦;4:连麦成功通知;5.发起者断开连麦;6:主播断开连麦;7:主播正忙碌 8:主播无响应
|
|
|
- if(action=='5' || action=='6'){
|
|
|
- clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
|
|
|
- if(error){
|
|
|
- return !1;
|
|
|
- }
|
|
|
- if(!res){
|
|
|
- return !1;
|
|
|
- }
|
|
|
- var res_j=JSON.parse(res);
|
|
|
-
|
|
|
- if( socket.uid==res_j['uid'] || socket.uid==socket.roomnum ){
|
|
|
- clientRedis.hdel('ShowVideo',socket.roomnum);
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }
|
|
|
- });
|
|
|
- }else if(action=='2'){
|
|
|
- //console.log('主播同意连麦');
|
|
|
- var touid=msg['touid'];
|
|
|
- //console.log(touid);
|
|
|
-
|
|
|
- request(config['WEBADDRESS']+"?service=Live.showVideo&uid="+socket.uid + "&token=" + socket.token+ "&touid="+touid+"&pull_url=''",function(error, response, body){
|
|
|
- //console.log('showVideo');
|
|
|
- //console.log(body);
|
|
|
- });
|
|
|
-
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }else{
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- case 'light' :{ //点亮
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- case 'updateVotes' :{//更新映票[暂时不用]
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'CloseLive' :{//关闭直播
|
|
|
- if(socket.usertype == 50 ){
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'KickUser' :{//踢人
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'ShutUpUser' :{//禁言
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'stopLive' :{//超管关播
|
|
|
- clientRedis.hget( "super",socket.uid,function(error,res){
|
|
|
- if(error) return;
|
|
|
- if(res != null){
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }
|
|
|
- });
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'ResumeUser' :{//恢复发言
|
|
|
- if(socket.usertype == 50 || socket.usertype == 40){
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'setAdmin' :{//设置/取消管理员
|
|
|
- //console.log(data_str);
|
|
|
- //console.log(socket.usertype);
|
|
|
- if(socket.usertype == 50 ){
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
-
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'StartEndLive':{
|
|
|
- if(socket.usertype == 50 ){
|
|
|
- socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]);
|
|
|
- }else{
|
|
|
- clientRedis.get("LiveAuthority" + socket.uid,function(error,res){
|
|
|
- if(error) return;
|
|
|
- if(parseInt(res) == 5 ||parseInt(res) == 1 || parseInt(res) == 2){
|
|
|
- socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]);
|
|
|
- }
|
|
|
- })
|
|
|
- }
|
|
|
- break;
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- case 'BuyGuard':{//购买守护
|
|
|
-
|
|
|
-
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- case 'LiveConnect':{//主播和主播连麦
|
|
|
- if(socket.roomnum != socket.uid){
|
|
|
- //非主播不能操作
|
|
|
- return !1;
|
|
|
- }
|
|
|
- var pkuid=msg['pkuid'];
|
|
|
- var pkpull=msg['pkpull'];
|
|
|
-
|
|
|
- //1:发起连麦;2;接受连麦;3:拒绝连麦;4:连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应 9:主播繁忙(游戏)
|
|
|
- if(action=='1'){
|
|
|
- // console.log('发起连麦');
|
|
|
- // console.log(FormatNowDate());
|
|
|
- // console.log(socket.uid+'---'+pkuid);
|
|
|
- // console.log(pkpull);
|
|
|
- // console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
|
|
|
- LiveConnect_pull[socket.uid]=pkpull;
|
|
|
- clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
|
|
|
- }
|
|
|
- if(action=='2'){
|
|
|
-// // console.log('接受连麦');
|
|
|
-// // console.log(FormatNowDate());
|
|
|
-// // console.log(socket.uid+'---'+pkuid);
|
|
|
-// // console.log(pkpull);
|
|
|
-// // console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
|
|
|
-// LiveConnect_pull[socket.uid]=pkpull;
|
|
|
-// clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
|
|
|
-//
|
|
|
-// /* 更新数据库 */
|
|
|
-// var sign_data={uid:socket.uid,pkuid:pkuid,type:1};
|
|
|
-// var sign=setSign(sign_data);
|
|
|
-// request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+socket.uid + "&pkuid=" + pkuid+ "&type=1&sign=" +sign,function(error, response, body){
|
|
|
-// // console.log('changeLive');
|
|
|
-// // console.log(body);
|
|
|
-//
|
|
|
-// });
|
|
|
-//
|
|
|
-// /* 发送连麦成功信息 */
|
|
|
-// /* 当前房间 */
|
|
|
-// var data_obj={
|
|
|
-// "msg":[
|
|
|
-// {
|
|
|
-// "_method_":"LiveConnect",
|
|
|
-// "action":"4",
|
|
|
-// "msgtype":"10",
|
|
|
-// "pkuid":""+pkuid,
|
|
|
-// "pkpull":""+LiveConnect_pull[pkuid],
|
|
|
-// "uid":""+socket.uid,
|
|
|
-// "uname":""+socket.nicename
|
|
|
-// }
|
|
|
-// ],
|
|
|
-// "retcode":"000000",
|
|
|
-// "retmsg":"OK"
|
|
|
-// };
|
|
|
-// // console.log(data_obj);
|
|
|
-// process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
-// /* 对方房间 */
|
|
|
-// var data_obj_pk={
|
|
|
-// "msg":[
|
|
|
-// {
|
|
|
-// "_method_":"LiveConnect",
|
|
|
-// "action":"4",
|
|
|
-// "msgtype":"10",
|
|
|
-// "pkuid":""+socket.uid,
|
|
|
-// "pkpull":""+LiveConnect_pull[socket.uid],
|
|
|
-// "uid":""+socket.uid,
|
|
|
-// "uname":""+socket.nicename
|
|
|
-// }
|
|
|
-// ],
|
|
|
-// "retcode":"000000",
|
|
|
-// "retmsg":"OK"
|
|
|
-// };
|
|
|
-// // console.log(data_obj_pk);
|
|
|
-// process_msg(io,pkuid,JSON.stringify(data_obj_pk));
|
|
|
- // 接受连麦(扩展为多人房间)
|
|
|
- LiveConnect_pull[socket.uid]=pkpull;
|
|
|
- clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
|
|
|
-
|
|
|
- /* 更新数据库 */
|
|
|
- var sign_data={uid:socket.uid,pkuid:pkuid,type:1};
|
|
|
- var sign=setSign(sign_data);
|
|
|
- request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+socket.uid + "&pkuid=" + pkuid+ "&type=1&sign=" +sign,function(error, response, body){
|
|
|
- if(error) return;
|
|
|
-
|
|
|
- // 获取房间所有成员并通知
|
|
|
- getRoomMembers(socket.uid, function(members) {
|
|
|
- notifyRoomMembers(io, members, socket.uid, pkuid, 'join');
|
|
|
- });
|
|
|
- });
|
|
|
- }else if(action=='5'){ //主播和主播断开连麦
|
|
|
- /* 清除连麦信息 */
|
|
|
- //console.log('endLiveConnect--action--5');
|
|
|
-// endLiveConnect(io,socket.uid);
|
|
|
- endLiveConnectWithRoom(io, socket.uid);
|
|
|
- }else{
|
|
|
- var socket_pkuid=sockets[pkuid];
|
|
|
- if(socket_pkuid){
|
|
|
- socket_pkuid.emit('broadcastingListen',[data_str]);
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'LivePK':{//主播PK
|
|
|
- console.log("----------------主播PK------------"+data_str);
|
|
|
-
|
|
|
- if(socket.roomnum != socket.uid){
|
|
|
- //非主播不能操作
|
|
|
- return !1;
|
|
|
- }
|
|
|
- var uid=msg['uid'];
|
|
|
- var pkuid=msg['pkuid'];
|
|
|
- //1:发起连麦;2;接受连麦;3:拒绝连麦;4:连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应; 9:PK结果
|
|
|
- if(action=='1'){
|
|
|
- console.log('发起PK');
|
|
|
- console.log(FormatNowDate());
|
|
|
- console.log(socket.uid+'---'+pkuid);
|
|
|
- }
|
|
|
- if(action=='2'){
|
|
|
- /* 更新PK状态 */
|
|
|
- console.log('LivePK');
|
|
|
- console.log(socket.uid);
|
|
|
- console.log(pkuid);
|
|
|
- console.log('开始PK');
|
|
|
- console.log(FormatNowDate());
|
|
|
- console.log(socket.uid+'---'+pkuid);
|
|
|
- var sign_data={uid:socket.uid,pkuid:pkuid};
|
|
|
- var sign=setSign(sign_data);
|
|
|
- request(config['WEBADDRESS']+"?service=Livepk.setPK&uid="+socket.uid + "&pkuid=" + pkuid+ "&sign=" +sign,function(error, response, body){
|
|
|
- if(error) return;
|
|
|
- // console.log('setPK');
|
|
|
- // console.log(body);
|
|
|
- var res = evalJson(body);
|
|
|
- if( response.statusCode == 200 && res.data.code == 0){
|
|
|
-
|
|
|
- var info = res.data.info[0];
|
|
|
- // console.log('info');
|
|
|
- // console.log(info);
|
|
|
- /* 发送连麦成功信息 */
|
|
|
- /* 当前房间 */
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"LivePK",
|
|
|
- "action":"4",
|
|
|
- "msgtype":"10",
|
|
|
- "pkuid":""+pkuid,
|
|
|
- "uid":""+socket.uid,
|
|
|
- "uname":""+socket.nicename
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
-
|
|
|
- process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
- /* 对方房间 */
|
|
|
- var data_obj_pk={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"LivePK",
|
|
|
- "action":"4",
|
|
|
- "msgtype":"10",
|
|
|
- "pkuid":""+socket.uid,
|
|
|
- "uid":""+socket.uid,
|
|
|
- "uname":""+socket.nicename
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
- process_msg(io,pkuid,JSON.stringify(data_obj_pk));
|
|
|
-
|
|
|
- setTimeout(function() {//定时发送结果
|
|
|
- // console.log('计时器');
|
|
|
- // console.log(FormatNowDate());
|
|
|
- // console.log('uid---'+socket.uid);
|
|
|
- endLivePk(io,socket.uid,0,info['addtime']);
|
|
|
- }, 5*60*1000);
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
- }else if(action=='5'){
|
|
|
- /* 清除PK信息 */
|
|
|
- // console.log('endLivePk --action--5');
|
|
|
- // console.log(FormatNowDate());
|
|
|
- endLivePk(io,socket.uid,1,0);
|
|
|
- }else{
|
|
|
- var socket_pkuid=sockets[pkuid];
|
|
|
- if(socket_pkuid){
|
|
|
- socket_pkuid.emit('broadcastingListen',[data_str]);
|
|
|
- }
|
|
|
- //process_msg(io,pkuid,data_str);
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- case 'goodsLiveShow' :{//商品在直播间展示/不展示
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- case 'SystemNot':{//系统通知
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
- case 'requestFans':{ //暂时不用
|
|
|
- request(config['WEBADDRESS']+"?service=Live.getZombie&stream=" + socket.stream+"&uid=" + socket.uid,function(error, response, body){
|
|
|
- if(error) return;
|
|
|
- var res = evalJson(body);
|
|
|
- if( response.statusCode == 200 && res.data.code == 0){
|
|
|
- var data_str2="{\"msg\":[{\"_method_\":\"requestFans\",\"action\":\"3\",\"ct\": "+ body + ",\"msgtype\":\"0\"}],\"retcode\":\"000000\",\"retmsg\":\"OK\"}";
|
|
|
- process_msg(io,socket.roomnum,data_str2);
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- case 'SystemWarning':{//警告通知
|
|
|
- process_msg(io,socket.roomnum,data_str);
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
- /*封禁通知*/
|
|
|
- socket.on('LiveBanadmin',function(data){
|
|
|
- if(data['token'] == config['TOKEN']){
|
|
|
- var data_obj={
|
|
|
- "retmsg":"ok",
|
|
|
- "retcode":"000000",
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "msgtype":"1",
|
|
|
- "_method_":"stopLive",
|
|
|
- "action":"1",
|
|
|
- "uid":"0",
|
|
|
- "ct":''+ data['content'],
|
|
|
- }
|
|
|
- ]
|
|
|
- };
|
|
|
- process_msg(io,data['roomnum'],JSON.stringify(data_obj));
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- /*警告通知*/
|
|
|
- socket.on('warningadmin',function(data){
|
|
|
- if(data['token'] == config['TOKEN']){
|
|
|
-
|
|
|
- var data_obj={
|
|
|
- "retmsg":"ok",
|
|
|
- "retcode":"000000",
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "msgtype":"1",
|
|
|
- "_method_":"SystemWarning",
|
|
|
- "action":"1",
|
|
|
- "ct":''+ data['content'],
|
|
|
- }
|
|
|
- ]
|
|
|
- };
|
|
|
- process_msg(io,data['roomnum'],JSON.stringify(data_obj));
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- /*关播通知*/
|
|
|
- socket.on('superadminaction',function(data){
|
|
|
-
|
|
|
- //console.log(data['token']);
|
|
|
- //console.log(config['TOKEN']);
|
|
|
-
|
|
|
- if(data['token'] == config['TOKEN']){
|
|
|
- var data_obj={
|
|
|
- "retmsg":"ok",
|
|
|
- "retcode":"000000",
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "msgtype":"1",
|
|
|
- "_method_":"stopLive",
|
|
|
- "action":"1",
|
|
|
- "uid":"0",
|
|
|
- "ct":''+ data['content'],
|
|
|
- }
|
|
|
- ]
|
|
|
- };
|
|
|
- process_msg(io,data['roomnum'],JSON.stringify(data_obj));
|
|
|
-
|
|
|
-
|
|
|
- /* io.sockets.in(data['roomnum']).emit("broadcastingListen", ['stopplay']); */
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- /* 系统信息 */
|
|
|
- socket.on('systemadmin',function(data){
|
|
|
- if(data['token'] == config['TOKEN']){
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"SystemNot",
|
|
|
- "action":"1",
|
|
|
- "ct":''+ data.content,
|
|
|
- "msgtype":"4"
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
- io.emit('broadcastingListen',[JSON.stringify(data_obj)]);
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- //资源释放
|
|
|
- socket.on('disconnect', function() {
|
|
|
- /* numscount--;
|
|
|
- if(numscount<0){
|
|
|
- numscount=0;
|
|
|
- } */
|
|
|
-
|
|
|
- if(socket.roomnum ==null || socket.token==null || socket.uid <=0){
|
|
|
- return !1;
|
|
|
- }
|
|
|
-
|
|
|
- d.run(function() {
|
|
|
-
|
|
|
- /* 用户连麦 */
|
|
|
- clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
|
|
|
- if(error){
|
|
|
- return !1;
|
|
|
- }
|
|
|
- if(!res){
|
|
|
- return !1;
|
|
|
- }
|
|
|
- var res_j=JSON.parse(res);
|
|
|
-
|
|
|
- if( socket.uid == res_j['uid'] || socket.uid == socket.roomnum ){
|
|
|
- clientRedis.hdel('ShowVideo',socket.roomnum);
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"ConnectVideo",
|
|
|
- "action":"5",
|
|
|
- "msgtype":"10",
|
|
|
- "uid":""+socket.uid,
|
|
|
- "uname":""+socket.nicename
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
- process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
-
|
|
|
- if(socket.roomnum==socket.uid){
|
|
|
- //console.log("主播socket断开");
|
|
|
- /* 主播 */
|
|
|
- if(socket.reusing==0){
|
|
|
- //console.log("请求关播接口");
|
|
|
- //console.log(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream);
|
|
|
- request(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream,function(error, response, body){
|
|
|
- //console.log("error:"+error);
|
|
|
- var data_obj={
|
|
|
- "retmsg":"ok",
|
|
|
- "retcode":"000000",
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "msgtype":"1",
|
|
|
- "_method_":"StartEndLive",
|
|
|
- "action":"18",
|
|
|
- "ct":"直播关闭"
|
|
|
- }
|
|
|
- ]
|
|
|
- };
|
|
|
- process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
- // console.log('关播');
|
|
|
- // console.log(FormatNowDate());
|
|
|
- // console.log('uid---'+socket.uid);
|
|
|
- });
|
|
|
- endLiveConnect(io,socket.uid);
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- }else{
|
|
|
- /* 观众 */
|
|
|
- clientRedis.zrem('user_'+socket.stream,socket.uid,function(error,res){
|
|
|
- if(error) return;
|
|
|
- if(res){
|
|
|
-
|
|
|
- //用于每日任务--用户观看直播时长统计
|
|
|
- request(config['WEBADDRESS']+"?service=Live.signOutWatchLive&uid="+socket.uid + "&token=" + socket.token,function(error, response, body){});
|
|
|
-
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"disconnect",
|
|
|
- "action":"1",
|
|
|
- "ct":{
|
|
|
- "id":''+socket.uid,
|
|
|
- "user_nickname":''+socket.nicename,
|
|
|
- "avatar":socket.avatar
|
|
|
- },
|
|
|
- "msgtype":"0",
|
|
|
- "uid":''+socket.uid,
|
|
|
- "uname":socket.nicename
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
- //console.log(JSON.stringify(data_obj));
|
|
|
- process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
- }
|
|
|
- //console.log(socket.roomnum+"==="+socket.token+"===="+socket.uid+"======"+socket.stream);
|
|
|
-
|
|
|
- socket.leave(socket.roomnum);
|
|
|
- delete io.sockets.sockets[socket.id];
|
|
|
- sockets[socket.uid] = null;
|
|
|
- delete sockets[socket.uid];
|
|
|
-
|
|
|
- });
|
|
|
- });
|
|
|
-
|
|
|
-});
|
|
|
-
|
|
|
- // 获取房间成员
|
|
|
- function getRoomMembers(uid, callback) {
|
|
|
- clientRedis.hget('LiveRoomMaster', uid, function(error, room_id) {
|
|
|
- if(error || !room_id) {
|
|
|
- callback([]);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- clientRedis.hget('LiveRoom', room_id, function(error, members_str) {
|
|
|
- if(error || !members_str) {
|
|
|
- callback([]);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- var members = members_str.split(',');
|
|
|
- callback(members);
|
|
|
- });
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- // 通知房间所有成员
|
|
|
- function notifyRoomMembers(io, members, new_uid, inviter_uid, action) {
|
|
|
- var msg_data = {
|
|
|
- "_method_": "LiveConnect",
|
|
|
- "action": "4",
|
|
|
- "msgtype": "10",
|
|
|
- "room_members": members,
|
|
|
- "new_uid": new_uid,
|
|
|
- "inviter_uid": inviter_uid,
|
|
|
- "action_type": action
|
|
|
- };
|
|
|
-
|
|
|
- var data_obj = {
|
|
|
- "msg": [msg_data],
|
|
|
- "retcode": "000000",
|
|
|
- "retmsg": "OK"
|
|
|
- };
|
|
|
-
|
|
|
- // 通知房间内所有成员
|
|
|
- members.forEach(function(member_uid) {
|
|
|
- if(member_uid && member_uid != new_uid) {
|
|
|
- // 获取该成员的拉流地址
|
|
|
- clientRedis.hget('LiveConnect_pull', member_uid, function(error, pull_url) {
|
|
|
- var member_msg = Object.assign({}, msg_data);
|
|
|
- member_msg.pkuid = member_uid;
|
|
|
- member_msg.pkpull = pull_url || '';
|
|
|
-
|
|
|
- var member_data_obj = {
|
|
|
- "msg": [member_msg],
|
|
|
- "retcode": "000000",
|
|
|
- "retmsg": "OK"
|
|
|
- };
|
|
|
-
|
|
|
- process_msg(io, new_uid, JSON.stringify(member_data_obj));
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- // 通知该成员房间有新人加入
|
|
|
- process_msg(io, member_uid, JSON.stringify(data_obj));
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- // 扩展的结束连麦处理
|
|
|
- function endLiveConnectWithRoom(io, uid) {
|
|
|
- // 获取房间信息
|
|
|
- clientRedis.hget('LiveRoomMaster', uid, function(error, room_id) {
|
|
|
- if(error || !room_id) {
|
|
|
- // 没有房间信息,使用原有逻辑
|
|
|
- endLiveConnect(io, uid);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- // 获取房间成员
|
|
|
- clientRedis.hget('LiveRoom', room_id, function(error, members_str) {
|
|
|
- if(error || !members_str) {
|
|
|
- endLiveConnect(io, uid);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- var members = members_str.split(',');
|
|
|
-
|
|
|
- // 通知房间成员有人离开
|
|
|
- var leave_msg = {
|
|
|
- "_method_": "LiveConnect",
|
|
|
- "action": "5",
|
|
|
- "msgtype": "10",
|
|
|
- "leave_uid": uid,
|
|
|
- "room_members": members.filter(m => m != uid)
|
|
|
- };
|
|
|
-
|
|
|
- var leave_data_obj = {
|
|
|
- "msg": [leave_msg],
|
|
|
- "retcode": "000000",
|
|
|
- "retmsg": "OK"
|
|
|
- };
|
|
|
-
|
|
|
- members.forEach(function(member_uid) {
|
|
|
- if(member_uid != uid) {
|
|
|
- process_msg(io, member_uid, JSON.stringify(leave_data_obj));
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- // 调用原有的结束连麦逻辑
|
|
|
- endLiveConnect(io, uid);
|
|
|
- });
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
-function sendSystemMsg(socket,msg){
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"SystemNot",
|
|
|
- "action":"1",
|
|
|
- "ct":""+ msg,
|
|
|
- "msgtype":"4"
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
- socket.emit('broadcastingListen',[JSON.stringify(data_obj)]);
|
|
|
-
|
|
|
-}
|
|
|
-
|
|
|
-function evalJson(data){
|
|
|
- return eval("("+data+")");
|
|
|
-}
|
|
|
-
|
|
|
-function process_msg(io,roomnum,data){
|
|
|
- if(!chat_history[roomnum]){
|
|
|
- chat_history[roomnum]=[];
|
|
|
- }
|
|
|
- chat_history[roomnum].push(data);
|
|
|
- chat_interval[roomnum] || (chat_interval[roomnum]=setInterval(function(){
|
|
|
- if(chat_history[roomnum].length>0){
|
|
|
- send_msg(io,roomnum);
|
|
|
- }else{
|
|
|
- clearInterval(chat_interval[roomnum]);
|
|
|
- chat_interval[roomnum]=null;
|
|
|
- }
|
|
|
- },200));
|
|
|
-}
|
|
|
-
|
|
|
-function send_msg(io,roomnum){
|
|
|
- var data=chat_history[roomnum].splice(0,chat_history[roomnum].length);
|
|
|
- io.sockets.in(roomnum).emit("broadcastingListen", data);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-/* 主播连麦结束处理 */
|
|
|
-function endLiveConnect(io,uid){
|
|
|
-
|
|
|
- //console.log('结束连麦');
|
|
|
- //console.log(FormatNowDate());
|
|
|
- //console.log('uid--'+uid);
|
|
|
- clientRedis.hget('LiveConnect',uid,function(error,res){
|
|
|
- //console.log('res');
|
|
|
- if(error){
|
|
|
- return !1;
|
|
|
- }
|
|
|
- if(!res){
|
|
|
- return !1;
|
|
|
- }
|
|
|
- var pkuid=res;
|
|
|
- //console.log('pkuid---'+pkuid);
|
|
|
- /* 更新数据库 */
|
|
|
- var sign_data={uid:uid,pkuid:pkuid,type:0};
|
|
|
- var sign=setSign(sign_data);
|
|
|
- request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+uid + "&pkuid=" + pkuid+ "&type=0&sign=" +sign,function(error, response, body){
|
|
|
- if(error) return;
|
|
|
-
|
|
|
- var res = evalJson(body);
|
|
|
- if( response.statusCode == 200 && res.data.code == 0){
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"LiveConnect",
|
|
|
- "action":"5",
|
|
|
- "msgtype":"10",
|
|
|
- "uid":""+uid,
|
|
|
- "uname":""
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
-
|
|
|
- process_msg(io,uid,JSON.stringify(data_obj));
|
|
|
- process_msg(io,pkuid,JSON.stringify(data_obj));
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
-}
|
|
|
-
|
|
|
-/* PK结束处理 */
|
|
|
-function endLivePk(io,uid,type,addtime){
|
|
|
- // console.log('结束PK');
|
|
|
- //console.log('uid-'+uid);
|
|
|
- //console.log('addtime-'+addtime);
|
|
|
- //console.log('type-'+type);
|
|
|
- var sign_data={uid:uid,addtime:addtime,type:type};
|
|
|
- var sign=setSign(sign_data);
|
|
|
- request(config['WEBADDRESS']+"?service=Livepk.endPK&uid="+uid + "&addtime=" + addtime+ "&type=" + type+ "&sign=" +sign,function(error, response, body){
|
|
|
- if(error) return;
|
|
|
- // console.log('endPK');
|
|
|
- // console.log(body);
|
|
|
- var res = evalJson(body);
|
|
|
- if( response.statusCode == 200 && res.data.code == 0){
|
|
|
- var info=res.data.info[0];
|
|
|
- var data_obj={
|
|
|
- "msg":[
|
|
|
- {
|
|
|
- "_method_":"LivePK",
|
|
|
- "action":"9",
|
|
|
- "msgtype":"10",
|
|
|
- "win_uid":""+info['win_uid'],
|
|
|
- "uid":""+uid,
|
|
|
- "uname":""
|
|
|
- }
|
|
|
- ],
|
|
|
- "retcode":"000000",
|
|
|
- "retmsg":"OK"
|
|
|
- };
|
|
|
-
|
|
|
- process_msg(io,uid,JSON.stringify(data_obj));
|
|
|
- process_msg(io,info['pkuid'],JSON.stringify(data_obj));
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
-
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-//时间格式化
|
|
|
-function FormatNowDate(){
|
|
|
- var mDate = new Date();
|
|
|
- var Y = mDate.getFullYear();
|
|
|
- var M = mDate.getMonth()+1;
|
|
|
- var D = mDate.getDate();
|
|
|
- var H = mDate.getHours();
|
|
|
- var i = mDate.getMinutes();
|
|
|
- var s = mDate.getSeconds();
|
|
|
- return Y +'-' + M + '-' + D + ' ' + H + ':' + i + ':' + s;
|
|
|
-}
|
|
|
-
|
|
|
-/* sign加密 */
|
|
|
-function setSign(obj) {//排序的函数
|
|
|
- var str='';
|
|
|
- var newkey = Object.keys(obj).sort();
|
|
|
-//先用Object内置类的keys方法获取要排序对象的属性名,再利用Array原型上的sort方法对获取的属性名进行排序,newkey是一个数组
|
|
|
- var newObj = {};//创建一个新的对象,用于存放排好序的键值对
|
|
|
- for (var i = 0; i < newkey.length; i++) {//遍历newkey数组
|
|
|
- //newObj[newkey[i]] = obj[newkey[i]];//向新创建的对象中按照排好的顺序依次增加键值对
|
|
|
- str+=newkey[i]+'='+obj[newkey[i]]+'&';
|
|
|
- }
|
|
|
- str+=config['sign_key'];
|
|
|
-
|
|
|
- var sign=md5(str);
|
|
|
- return sign;
|
|
|
-}
|
|
|
+
|
|
|
+//引入http模块
|
|
|
+var socketio = require('socket.io'),
|
|
|
+ fs = require('fs'),
|
|
|
+ https = require('https'),
|
|
|
+ domain = require('domain'),
|
|
|
+ redis = require('redis'),
|
|
|
+ redisio = require('socket.io-redis'),
|
|
|
+ request = require('request'),
|
|
|
+ md5 = require('md5-node'),
|
|
|
+ config = require('./config.js');
|
|
|
+
|
|
|
+var d = domain.create();
|
|
|
+d.on("error", function(err) {
|
|
|
+// console.log(err);
|
|
|
+});
|
|
|
+
|
|
|
+//var numscount=0;// 在线人数统计
|
|
|
+var sockets = {};
|
|
|
+var chat_history={};
|
|
|
+var chat_interval={};
|
|
|
+/* 主播连麦关系 */
|
|
|
+var LiveConnect={};
|
|
|
+var LiveConnect_pull={};
|
|
|
+
|
|
|
+var options = {
|
|
|
+ key:fs.readFileSync('/www/server/panel/vhost/cert/yjzb.yunchao2u.com/privkey.key'),
|
|
|
+ cert:fs.readFileSync('/www/server/panel/vhost/cert/yjzb.yunchao2u.com/fullchain.pem')
|
|
|
+};
|
|
|
+
|
|
|
+// redis 链接
|
|
|
+var clientRedis = redis.createClient(config['REDISPORT'],config['REDISHOST']);
|
|
|
+clientRedis.auth(config['REDISPASS']);
|
|
|
+var server = https.createServer(options,function(req, res) {
|
|
|
+// var server = https.createServer(function(req, res) {
|
|
|
+ res.writeHead(200, {
|
|
|
+ 'Content-type': 'text/html;charset=utf-8'
|
|
|
+ });
|
|
|
+ //res.write("人数: " + numscount );
|
|
|
+ res.end();
|
|
|
+}).listen(config['socket_port'], function() {
|
|
|
+ ////console.log('服务开启19965');
|
|
|
+});
|
|
|
+
|
|
|
+var io = socketio.listen(server,{
|
|
|
+ pingTimeout: 60000,
|
|
|
+ pingInterval: 25000
|
|
|
+});
|
|
|
+/* var pub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] });
|
|
|
+ var sub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] });
|
|
|
+ io.adapter(redisio({ pubClient: pub, subClient: sub })); */
|
|
|
+//setInterval(function(){
|
|
|
+ //global.gc();
|
|
|
+ ////console.log('GC done')
|
|
|
+//}, 1000*30);
|
|
|
+
|
|
|
+io.on('connection', function(socket) {
|
|
|
+ //console.log('连接成功');
|
|
|
+ //numscount++;
|
|
|
+
|
|
|
+ var interval;
|
|
|
+
|
|
|
+ //进入房间
|
|
|
+ socket.on('conn', function(data) {
|
|
|
+
|
|
|
+ if(!data || !data.token){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+
|
|
|
+ userid=data.uid;
|
|
|
+ old_socket = sockets[userid];
|
|
|
+ if (old_socket && old_socket != socket) {
|
|
|
+
|
|
|
+ if(data.uid != data.roomnum && data.uid==old_socket.roomnum){
|
|
|
+ /* 进房间 但旧链接是 主播 */
|
|
|
+ var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}';
|
|
|
+ old_socket.emit('broadcastingListen',[data_str]);
|
|
|
+ }else if(data.uid== data.roomnum && data.stream==old_socket.stream){
|
|
|
+ /* 主播重连 */
|
|
|
+ old_socket.reusing = 1;
|
|
|
+ //console.log("重用");
|
|
|
+ }else if(data.uid== data.roomnum && data.stream!=old_socket.stream){
|
|
|
+ /* 主播多端开播 */
|
|
|
+ var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}';
|
|
|
+ old_socket.emit('broadcastingListen',[data_str]);
|
|
|
+ }
|
|
|
+ old_socket.disconnect()
|
|
|
+ }
|
|
|
+
|
|
|
+ clientRedis.get(data.token,function(error,res){
|
|
|
+ if(error){
|
|
|
+ return;
|
|
|
+ }else if(res==null){
|
|
|
+ //console.log("[获取token失败]"+data.uid);
|
|
|
+ }else{
|
|
|
+ if(res != null){
|
|
|
+
|
|
|
+ var userInfo = evalJson(res);
|
|
|
+ if(userInfo['id'] == data.uid ){
|
|
|
+ //console.log("[初始化验证成功]--"+data.uid+"---"+data.roomnum+'---'+data.stream);
|
|
|
+ //获取验证token
|
|
|
+ socket.token = data.token;
|
|
|
+ socket.roomnum = data.roomnum;
|
|
|
+ socket.stream = data.stream;
|
|
|
+ socket.nicename = userInfo['user_nickname'];
|
|
|
+ socket.avatar = userInfo['avatar'];
|
|
|
+ socket.sign = Number(userInfo['sign']);
|
|
|
+ socket.usertype = parseInt(userInfo['usertype']);
|
|
|
+ socket.uid = data.uid;
|
|
|
+ socket.reusing = 0;
|
|
|
+
|
|
|
+ socket.join(data.roomnum);
|
|
|
+ sockets[userid] = socket;
|
|
|
+ socket.emit('conn',['ok']);
|
|
|
+
|
|
|
+ if( socket.roomnum!=socket.uid && socket.uid >0 ){
|
|
|
+
|
|
|
+
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"SendMsg",
|
|
|
+ "action":"0",
|
|
|
+ "ct":{
|
|
|
+ "id":''+userInfo['id'],
|
|
|
+ "user_nickname":''+userInfo['user_nickname'],
|
|
|
+ "avatar":userInfo['avatar'],
|
|
|
+ "avatar_thumb":userInfo['avatar_thumb'],
|
|
|
+ "usertype":''+userInfo['usertype'],
|
|
|
+ "guard_type":''+userInfo['guard_type'],
|
|
|
+ "contribution":''+userInfo['contribution'],
|
|
|
+
|
|
|
+ },
|
|
|
+ "msgtype":"0"
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
+ if(socket.stream){
|
|
|
+ clientRedis.zadd('user_'+socket.stream,socket.sign,userInfo['id']);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ //sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容,账号会被封禁;安全部门会24小时巡查哦~");
|
|
|
+ var stemMgs='直播内容包含任何低俗、暴露和涉黄内容,账号会被封禁;安全部门会24小时巡查哦~';
|
|
|
+ if(userInfo['lang']=='en'){
|
|
|
+ stemMgs='If the live content contains any vulgar, explicit, or pornographic content, the account will be banned; The security department will conduct 24-hour inspections~';
|
|
|
+ }
|
|
|
+ sendSystemMsg(socket,stemMgs);
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ return;
|
|
|
+ }else{
|
|
|
+ socket.disconnect();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ socket.emit('conn',['no']);
|
|
|
+ });
|
|
|
+
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+ socket.on('broadcast',function(data){
|
|
|
+ ////console.log(data);
|
|
|
+ if(socket.token != undefined){
|
|
|
+ var dataObj = typeof data == 'object'?data:evalJson(data);
|
|
|
+
|
|
|
+ //console.log('==================='+data);
|
|
|
+ var msg = dataObj['msg'][0];
|
|
|
+ var token = dataObj['token'];
|
|
|
+ var method = msg['_method_'];
|
|
|
+ var action = msg['action'];
|
|
|
+ var data_str = typeof data == 'object'?JSON.stringify(data):data;
|
|
|
+ switch(method){
|
|
|
+ case 'SendMsg':{ //聊天
|
|
|
+
|
|
|
+ //sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容,账号会被封禁;安全部门会24小时巡查哦~");
|
|
|
+
|
|
|
+ clientRedis.hget( "super",socket.uid,function(error,res){
|
|
|
+ if(error) return;
|
|
|
+ if(res != null){
|
|
|
+ var data_str2={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"SystemNot",
|
|
|
+ "action":"1",
|
|
|
+ "ct":''+dataObj['msg'][0]['ct'],
|
|
|
+ "msgtype":"4"
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+
|
|
|
+
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_str2));
|
|
|
+ }else{
|
|
|
+ clientRedis.hget(socket.roomnum + "shutup",socket.uid,function(error,res){
|
|
|
+ if(error) return;
|
|
|
+ if(res != null){
|
|
|
+ var newData = dataObj;
|
|
|
+ newData['retcode'] = '409002';
|
|
|
+ socket.emit('broadcastingListen',[JSON.stringify(newData)]);
|
|
|
+ }else{
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ });
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'SendGift':{ //送礼物
|
|
|
+ var gifToken = dataObj['msg'][0]['ct'];
|
|
|
+ clientRedis.get(gifToken,function(error,res){
|
|
|
+ if(!error&&res != null){
|
|
|
+ var resObj = evalJson(res);
|
|
|
+ dataObj['msg'][0]['ct'] = resObj;
|
|
|
+
|
|
|
+ var ifpk='0',
|
|
|
+ pkuid1='0',
|
|
|
+ pkuid2='0',
|
|
|
+ pktotal1='0',
|
|
|
+ pktotal2='0';
|
|
|
+
|
|
|
+ //console.log('SendGift');
|
|
|
+ //console.log(resObj);
|
|
|
+ if(resObj['ispk']==1 ){
|
|
|
+ ifpk='1';
|
|
|
+ pkuid1=''+resObj['pkuid1'];
|
|
|
+ pkuid2=''+resObj['pkuid2'];
|
|
|
+ pktotal1=''+resObj['pktotal1'];
|
|
|
+ pktotal2=''+resObj['pktotal2'];
|
|
|
+ //console.log('pk');
|
|
|
+ }
|
|
|
+ dataObj['msg'][0]['ifpk']=ifpk;
|
|
|
+ dataObj['msg'][0]['pkuid1']=pkuid1;
|
|
|
+ dataObj['msg'][0]['pkuid2']=pkuid2;
|
|
|
+ dataObj['msg'][0]['pktotal1']=pktotal1;
|
|
|
+ dataObj['msg'][0]['pktotal2']=pktotal2;
|
|
|
+ dataObj['msg'][0]['roomnum']=socket.roomnum;
|
|
|
+
|
|
|
+
|
|
|
+ console.log('---------礼物信息--------------------'+[JSON.stringify(dataObj)]);
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ io.sockets.in(socket.roomnum).emit('broadcastingListen',[JSON.stringify(dataObj)]);
|
|
|
+ if(pkuid2>0){
|
|
|
+
|
|
|
+ io.sockets.in(pkuid2).emit('broadcastingListen',[JSON.stringify(dataObj)]);
|
|
|
+ }
|
|
|
+
|
|
|
+ clientRedis.del(gifToken);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'ConnectVideo' :{ //用户和主播连麦
|
|
|
+ //1:发起连麦;2;接受连麦;3:拒绝连麦;4:连麦成功通知;5.发起者断开连麦;6:主播断开连麦;7:主播正忙碌 8:主播无响应
|
|
|
+ if(action=='5' || action=='6'){
|
|
|
+ clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
|
|
|
+ if(error){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ if(!res){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ var res_j=JSON.parse(res);
|
|
|
+
|
|
|
+ if( socket.uid==res_j['uid'] || socket.uid==socket.roomnum ){
|
|
|
+ clientRedis.hdel('ShowVideo',socket.roomnum);
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }else if(action=='2'){
|
|
|
+ //console.log('主播同意连麦');
|
|
|
+ var touid=msg['touid'];
|
|
|
+ //console.log(touid);
|
|
|
+
|
|
|
+ request(config['WEBADDRESS']+"?service=Live.showVideo&uid="+socket.uid + "&token=" + socket.token+ "&touid="+touid+"&pull_url=''",function(error, response, body){
|
|
|
+ //console.log('showVideo');
|
|
|
+ //console.log(body);
|
|
|
+ });
|
|
|
+
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }else{
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 'light' :{ //点亮
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 'updateVotes' :{//更新映票[暂时不用]
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'CloseLive' :{//关闭直播
|
|
|
+ if(socket.usertype == 50 ){
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'KickUser' :{//踢人
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'ShutUpUser' :{//禁言
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'stopLive' :{//超管关播
|
|
|
+ clientRedis.hget( "super",socket.uid,function(error,res){
|
|
|
+ if(error) return;
|
|
|
+ if(res != null){
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'ResumeUser' :{//恢复发言
|
|
|
+ if(socket.usertype == 50 || socket.usertype == 40){
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'setAdmin' :{//设置/取消管理员
|
|
|
+ //console.log(data_str);
|
|
|
+ //console.log(socket.usertype);
|
|
|
+ if(socket.usertype == 50 ){
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'StartEndLive':{
|
|
|
+ if(socket.usertype == 50 ){
|
|
|
+ socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]);
|
|
|
+ }else{
|
|
|
+ clientRedis.get("LiveAuthority" + socket.uid,function(error,res){
|
|
|
+ if(error) return;
|
|
|
+ if(parseInt(res) == 5 ||parseInt(res) == 1 || parseInt(res) == 2){
|
|
|
+ socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]);
|
|
|
+ }
|
|
|
+ })
|
|
|
+ }
|
|
|
+ break;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ case 'BuyGuard':{//购买守护
|
|
|
+
|
|
|
+
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 'LiveConnect':{//主播和主播连麦
|
|
|
+ if(socket.roomnum != socket.uid){
|
|
|
+ //非主播不能操作
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ var pkuid=msg['pkuid'];
|
|
|
+ var pkpull=msg['pkpull'];
|
|
|
+
|
|
|
+ //1:发起连麦;2;接受连麦;3:拒绝连麦;4:连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应 9:主播繁忙(游戏)
|
|
|
+ if(action=='1'){
|
|
|
+ // console.log('发起连麦');
|
|
|
+ // console.log(FormatNowDate());
|
|
|
+ // console.log(socket.uid+'---'+pkuid);
|
|
|
+ // console.log(pkpull);
|
|
|
+ // console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
|
|
|
+ LiveConnect_pull[socket.uid]=pkpull;
|
|
|
+ clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
|
|
|
+ }
|
|
|
+ if(action=='2'){
|
|
|
+ // console.log('接受连麦');
|
|
|
+ // console.log(FormatNowDate());
|
|
|
+ // console.log(socket.uid+'---'+pkuid);
|
|
|
+ // console.log(pkpull);
|
|
|
+ // console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
|
|
|
+ LiveConnect_pull[socket.uid]=pkpull;
|
|
|
+ clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
|
|
|
+
|
|
|
+ /* 更新数据库 */
|
|
|
+ var sign_data={uid:socket.uid,pkuid:pkuid,type:1};
|
|
|
+ var sign=setSign(sign_data);
|
|
|
+ request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+socket.uid + "&pkuid=" + pkuid+ "&type=1&sign=" +sign,function(error, response, body){
|
|
|
+ // console.log('changeLive');
|
|
|
+ // console.log(body);
|
|
|
+ if(error) return;
|
|
|
+
|
|
|
+ // 获取房间所有成员并通知
|
|
|
+ getRoomMembers(socket.uid, function(members) {
|
|
|
+ if(members.length >0){
|
|
|
+ notifyRoomMembers(io, members, socket.uid, pkuid, 'join');
|
|
|
+ }else{
|
|
|
+ /* 发送连麦成功信息 */
|
|
|
+ /* 当前房间 */
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"LiveConnect",
|
|
|
+ "action":"4",
|
|
|
+ "msgtype":"10",
|
|
|
+ "pkuid":""+pkuid,
|
|
|
+ "pkpull":""+LiveConnect_pull[pkuid],
|
|
|
+ "uid":""+socket.uid,
|
|
|
+ "uname":""+socket.nicename
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ // console.log(data_obj);
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
+ /* 对方房间 */
|
|
|
+ var data_obj_pk={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"LiveConnect",
|
|
|
+ "action":"4",
|
|
|
+ "msgtype":"10",
|
|
|
+ "pkuid":""+socket.uid,
|
|
|
+ "pkpull":""+LiveConnect_pull[socket.uid],
|
|
|
+ "uid":""+socket.uid,
|
|
|
+ "uname":""+socket.nicename
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ // console.log(data_obj_pk);
|
|
|
+ process_msg(io,pkuid,JSON.stringify(data_obj_pk));
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+ });
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ }else if(action=='5'){ //主播和主播断开连麦
|
|
|
+ /* 清除连麦信息 */
|
|
|
+ //console.log('endLiveConnect--action--5');
|
|
|
+// endLiveConnect(io,socket.uid);
|
|
|
+ /* 清除连麦信息并处理房间 */
|
|
|
+ endLiveConnectWithRoom(io, socket.uid);
|
|
|
+ }else{
|
|
|
+ var socket_pkuid=sockets[pkuid];
|
|
|
+ if(socket_pkuid){
|
|
|
+ socket_pkuid.emit('broadcastingListen',[data_str]);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'LivePK':{//主播PK
|
|
|
+ console.log("----------------主播PK------------"+data_str);
|
|
|
+
|
|
|
+ if(socket.roomnum != socket.uid){
|
|
|
+ //非主播不能操作
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ var uid=msg['uid'];
|
|
|
+ var pkuid=msg['pkuid'];
|
|
|
+ //1:发起连麦;2;接受连麦;3:拒绝连麦;4:连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应; 9:PK结果
|
|
|
+ if(action=='1'){
|
|
|
+ console.log('发起PK');
|
|
|
+ console.log(FormatNowDate());
|
|
|
+ console.log(socket.uid+'---'+pkuid);
|
|
|
+ }
|
|
|
+ if(action=='2'){
|
|
|
+ /* 更新PK状态 */
|
|
|
+ console.log('LivePK');
|
|
|
+ console.log(socket.uid);
|
|
|
+ console.log(pkuid);
|
|
|
+ console.log('开始PK');
|
|
|
+ console.log(FormatNowDate());
|
|
|
+ console.log(socket.uid+'---'+pkuid);
|
|
|
+ var sign_data={uid:socket.uid,pkuid:pkuid};
|
|
|
+ var sign=setSign(sign_data);
|
|
|
+ request(config['WEBADDRESS']+"?service=Livepk.setPK&uid="+socket.uid + "&pkuid=" + pkuid+ "&sign=" +sign,function(error, response, body){
|
|
|
+ if(error) return;
|
|
|
+ // console.log('setPK');
|
|
|
+ // console.log(body);
|
|
|
+ var res = evalJson(body);
|
|
|
+ if( response.statusCode == 200 && res.data.code == 0){
|
|
|
+
|
|
|
+ var info = res.data.info[0];
|
|
|
+ // console.log('info');
|
|
|
+ // console.log(info);
|
|
|
+ /* 发送连麦成功信息 */
|
|
|
+ /* 当前房间 */
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"LivePK",
|
|
|
+ "action":"4",
|
|
|
+ "msgtype":"10",
|
|
|
+ "pkuid":""+pkuid,
|
|
|
+ "uid":""+socket.uid,
|
|
|
+ "uname":""+socket.nicename
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
+ /* 对方房间 */
|
|
|
+ var data_obj_pk={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"LivePK",
|
|
|
+ "action":"4",
|
|
|
+ "msgtype":"10",
|
|
|
+ "pkuid":""+socket.uid,
|
|
|
+ "uid":""+socket.uid,
|
|
|
+ "uname":""+socket.nicename
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ process_msg(io,pkuid,JSON.stringify(data_obj_pk));
|
|
|
+
|
|
|
+ setTimeout(function() {//定时发送结果
|
|
|
+ // console.log('计时器');
|
|
|
+ // console.log(FormatNowDate());
|
|
|
+ // console.log('uid---'+socket.uid);
|
|
|
+ endLivePk(io,socket.uid,0,info['addtime']);
|
|
|
+ }, 5*60*1000);
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+ }else if(action=='5'){
|
|
|
+ /* 清除PK信息 */
|
|
|
+ // console.log('endLivePk --action--5');
|
|
|
+ // console.log(FormatNowDate());
|
|
|
+ endLivePk(io,socket.uid,1,0);
|
|
|
+ }else{
|
|
|
+ var socket_pkuid=sockets[pkuid];
|
|
|
+ if(socket_pkuid){
|
|
|
+ socket_pkuid.emit('broadcastingListen',[data_str]);
|
|
|
+ }
|
|
|
+ //process_msg(io,pkuid,data_str);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ case 'goodsLiveShow' :{//商品在直播间展示/不展示
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 'SystemNot':{//系统通知
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ case 'requestFans':{ //暂时不用
|
|
|
+ request(config['WEBADDRESS']+"?service=Live.getZombie&stream=" + socket.stream+"&uid=" + socket.uid,function(error, response, body){
|
|
|
+ if(error) return;
|
|
|
+ var res = evalJson(body);
|
|
|
+ if( response.statusCode == 200 && res.data.code == 0){
|
|
|
+ var data_str2="{\"msg\":[{\"_method_\":\"requestFans\",\"action\":\"3\",\"ct\": "+ body + ",\"msgtype\":\"0\"}],\"retcode\":\"000000\",\"retmsg\":\"OK\"}";
|
|
|
+ process_msg(io,socket.roomnum,data_str2);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ case 'SystemWarning':{//警告通知
|
|
|
+ process_msg(io,socket.roomnum,data_str);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+
|
|
|
+ /*封禁通知*/
|
|
|
+ socket.on('LiveBanadmin',function(data){
|
|
|
+ if(data['token'] == config['TOKEN']){
|
|
|
+ var data_obj={
|
|
|
+ "retmsg":"ok",
|
|
|
+ "retcode":"000000",
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "msgtype":"1",
|
|
|
+ "_method_":"stopLive",
|
|
|
+ "action":"1",
|
|
|
+ "uid":"0",
|
|
|
+ "ct":''+ data['content'],
|
|
|
+ }
|
|
|
+ ]
|
|
|
+ };
|
|
|
+ process_msg(io,data['roomnum'],JSON.stringify(data_obj));
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ /*警告通知*/
|
|
|
+ socket.on('warningadmin',function(data){
|
|
|
+ if(data['token'] == config['TOKEN']){
|
|
|
+
|
|
|
+ var data_obj={
|
|
|
+ "retmsg":"ok",
|
|
|
+ "retcode":"000000",
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "msgtype":"1",
|
|
|
+ "_method_":"SystemWarning",
|
|
|
+ "action":"1",
|
|
|
+ "ct":''+ data['content'],
|
|
|
+ }
|
|
|
+ ]
|
|
|
+ };
|
|
|
+ process_msg(io,data['roomnum'],JSON.stringify(data_obj));
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ /*关播通知*/
|
|
|
+ socket.on('superadminaction',function(data){
|
|
|
+
|
|
|
+ //console.log(data['token']);
|
|
|
+ //console.log(config['TOKEN']);
|
|
|
+
|
|
|
+ if(data['token'] == config['TOKEN']){
|
|
|
+ var data_obj={
|
|
|
+ "retmsg":"ok",
|
|
|
+ "retcode":"000000",
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "msgtype":"1",
|
|
|
+ "_method_":"stopLive",
|
|
|
+ "action":"1",
|
|
|
+ "uid":"0",
|
|
|
+ "ct":''+ data['content'],
|
|
|
+ }
|
|
|
+ ]
|
|
|
+ };
|
|
|
+ process_msg(io,data['roomnum'],JSON.stringify(data_obj));
|
|
|
+
|
|
|
+
|
|
|
+ /* io.sockets.in(data['roomnum']).emit("broadcastingListen", ['stopplay']); */
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ /* 系统信息 */
|
|
|
+ socket.on('systemadmin',function(data){
|
|
|
+ if(data['token'] == config['TOKEN']){
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"SystemNot",
|
|
|
+ "action":"1",
|
|
|
+ "ct":''+ data.content,
|
|
|
+ "msgtype":"4"
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ io.emit('broadcastingListen',[JSON.stringify(data_obj)]);
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ //资源释放
|
|
|
+ socket.on('disconnect', function() {
|
|
|
+ /* numscount--;
|
|
|
+ if(numscount<0){
|
|
|
+ numscount=0;
|
|
|
+ } */
|
|
|
+
|
|
|
+ if(socket.roomnum ==null || socket.token==null || socket.uid <=0){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+
|
|
|
+ d.run(function() {
|
|
|
+
|
|
|
+ /* 用户连麦 */
|
|
|
+ clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
|
|
|
+ if(error){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ if(!res){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ var res_j=JSON.parse(res);
|
|
|
+
|
|
|
+ if( socket.uid == res_j['uid'] || socket.uid == socket.roomnum ){
|
|
|
+ clientRedis.hdel('ShowVideo',socket.roomnum);
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"ConnectVideo",
|
|
|
+ "action":"5",
|
|
|
+ "msgtype":"10",
|
|
|
+ "uid":""+socket.uid,
|
|
|
+ "uname":""+socket.nicename
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+
|
|
|
+ if(socket.roomnum==socket.uid){
|
|
|
+ //console.log("主播socket断开");
|
|
|
+ /* 主播 */
|
|
|
+ if(socket.reusing==0){
|
|
|
+ //console.log("请求关播接口");
|
|
|
+ //console.log(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream);
|
|
|
+ request(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream,function(error, response, body){
|
|
|
+ //console.log("error:"+error);
|
|
|
+ var data_obj={
|
|
|
+ "retmsg":"ok",
|
|
|
+ "retcode":"000000",
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "msgtype":"1",
|
|
|
+ "_method_":"StartEndLive",
|
|
|
+ "action":"18",
|
|
|
+ "ct":"直播关闭"
|
|
|
+ }
|
|
|
+ ]
|
|
|
+ };
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
+ // console.log('关播');
|
|
|
+ // console.log(FormatNowDate());
|
|
|
+ // console.log('uid---'+socket.uid);
|
|
|
+ });
|
|
|
+ endLiveConnect(io,socket.uid);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+ /* 观众 */
|
|
|
+ clientRedis.zrem('user_'+socket.stream,socket.uid,function(error,res){
|
|
|
+ if(error) return;
|
|
|
+ if(res){
|
|
|
+
|
|
|
+ //用于每日任务--用户观看直播时长统计
|
|
|
+ request(config['WEBADDRESS']+"?service=Live.signOutWatchLive&uid="+socket.uid + "&token=" + socket.token,function(error, response, body){});
|
|
|
+
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"disconnect",
|
|
|
+ "action":"1",
|
|
|
+ "ct":{
|
|
|
+ "id":''+socket.uid,
|
|
|
+ "user_nickname":''+socket.nicename,
|
|
|
+ "avatar":socket.avatar
|
|
|
+ },
|
|
|
+ "msgtype":"0",
|
|
|
+ "uid":''+socket.uid,
|
|
|
+ "uname":socket.nicename
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ //console.log(JSON.stringify(data_obj));
|
|
|
+ process_msg(io,socket.roomnum,JSON.stringify(data_obj));
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+ }
|
|
|
+ //console.log(socket.roomnum+"==="+socket.token+"===="+socket.uid+"======"+socket.stream);
|
|
|
+
|
|
|
+ socket.leave(socket.roomnum);
|
|
|
+ delete io.sockets.sockets[socket.id];
|
|
|
+ sockets[socket.uid] = null;
|
|
|
+ delete sockets[socket.uid];
|
|
|
+
|
|
|
+ });
|
|
|
+ });
|
|
|
+
|
|
|
+});
|
|
|
+// 获取房间成员
|
|
|
+function getRoomMembers(uid, callback) {
|
|
|
+ clientRedis.hget('LiveRoomMaster', uid, function(error, room_id) {
|
|
|
+ if(error || !room_id) {
|
|
|
+ callback([]);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ clientRedis.hget('LiveRoom', room_id, function(error, members_str) {
|
|
|
+ if(error || !members_str) {
|
|
|
+ callback([]);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ var members = members_str.split(',');
|
|
|
+ callback(members);
|
|
|
+ });
|
|
|
+ });
|
|
|
+}
|
|
|
+
|
|
|
+// 通知房间所有成员
|
|
|
+function notifyRoomMembers(io, members, new_uid, inviter_uid, action) {
|
|
|
+ var msg_data = {
|
|
|
+ "_method_": "LiveConnect",
|
|
|
+ "action": "4",
|
|
|
+ "msgtype": "10",
|
|
|
+ "room_members": members,
|
|
|
+ "new_uid": new_uid,
|
|
|
+ "inviter_uid": inviter_uid,
|
|
|
+ "action_type": action
|
|
|
+ };
|
|
|
+
|
|
|
+ var data_obj = {
|
|
|
+ "msg": [msg_data],
|
|
|
+ "retcode": "000000",
|
|
|
+ "retmsg": "OK"
|
|
|
+ };
|
|
|
+
|
|
|
+ // 通知房间内所有成员
|
|
|
+ members.forEach(function(member_uid) {
|
|
|
+ if(member_uid && member_uid != new_uid) {
|
|
|
+ // 获取该成员的拉流地址
|
|
|
+ clientRedis.hget('LiveConnect_pull', member_uid, function(error, pull_url) {
|
|
|
+ var member_msg = Object.assign({}, msg_data);
|
|
|
+ member_msg.pkuid = member_uid;
|
|
|
+ member_msg.pkpull = pull_url || '';
|
|
|
+
|
|
|
+ var member_data_obj = {
|
|
|
+ "msg": [member_msg],
|
|
|
+ "retcode": "000000",
|
|
|
+ "retmsg": "OK"
|
|
|
+ };
|
|
|
+
|
|
|
+ process_msg(io, new_uid, JSON.stringify(member_data_obj));
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ // 通知该成员房间有新人加入
|
|
|
+ process_msg(io, member_uid, JSON.stringify(data_obj));
|
|
|
+ });
|
|
|
+}
|
|
|
+
|
|
|
+// 扩展的结束连麦处理
|
|
|
+function endLiveConnectWithRoom(io, uid) {
|
|
|
+ // 获取房间信息
|
|
|
+ clientRedis.hget('LiveRoomMaster', uid, function(error, room_id) {
|
|
|
+ if(error || !room_id) {
|
|
|
+ // 没有房间信息,使用原有逻辑
|
|
|
+ endLiveConnect(io, uid);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取房间成员
|
|
|
+ clientRedis.hget('LiveRoom', room_id, function(error, members_str) {
|
|
|
+ if(error || !members_str) {
|
|
|
+ endLiveConnect(io, uid);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ var members = members_str.split(',');
|
|
|
+
|
|
|
+ // 通知房间成员有人离开
|
|
|
+ var leave_msg = {
|
|
|
+ "_method_": "LiveConnect",
|
|
|
+ "action": "5",
|
|
|
+ "msgtype": "10",
|
|
|
+ "leave_uid": uid,
|
|
|
+ "room_members": members.filter(m => m != uid)
|
|
|
+ };
|
|
|
+
|
|
|
+ var leave_data_obj = {
|
|
|
+ "msg": [leave_msg],
|
|
|
+ "retcode": "000000",
|
|
|
+ "retmsg": "OK"
|
|
|
+ };
|
|
|
+
|
|
|
+ members.forEach(function(member_uid) {
|
|
|
+ if(member_uid != uid) {
|
|
|
+ process_msg(io, member_uid, JSON.stringify(leave_data_obj));
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ // 调用原有的结束连麦逻辑
|
|
|
+ endLiveConnect(io, uid);
|
|
|
+ });
|
|
|
+ });
|
|
|
+}
|
|
|
+
|
|
|
+function sendSystemMsg(socket,msg){
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"SystemNot",
|
|
|
+ "action":"1",
|
|
|
+ "ct":""+ msg,
|
|
|
+ "msgtype":"4"
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+ socket.emit('broadcastingListen',[JSON.stringify(data_obj)]);
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+function evalJson(data){
|
|
|
+ return eval("("+data+")");
|
|
|
+}
|
|
|
+
|
|
|
+function process_msg(io,roomnum,data){
|
|
|
+ if(!chat_history[roomnum]){
|
|
|
+ chat_history[roomnum]=[];
|
|
|
+ }
|
|
|
+ chat_history[roomnum].push(data);
|
|
|
+ chat_interval[roomnum] || (chat_interval[roomnum]=setInterval(function(){
|
|
|
+ if(chat_history[roomnum].length>0){
|
|
|
+ send_msg(io,roomnum);
|
|
|
+ }else{
|
|
|
+ clearInterval(chat_interval[roomnum]);
|
|
|
+ chat_interval[roomnum]=null;
|
|
|
+ }
|
|
|
+ },200));
|
|
|
+}
|
|
|
+
|
|
|
+function send_msg(io,roomnum){
|
|
|
+ var data=chat_history[roomnum].splice(0,chat_history[roomnum].length);
|
|
|
+ io.sockets.in(roomnum).emit("broadcastingListen", data);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+/* 主播连麦结束处理 */
|
|
|
+function endLiveConnect(io,uid){
|
|
|
+
|
|
|
+ //console.log('结束连麦');
|
|
|
+ //console.log(FormatNowDate());
|
|
|
+ //console.log('uid--'+uid);
|
|
|
+ clientRedis.hget('LiveConnect',uid,function(error,res){
|
|
|
+ //console.log('res');
|
|
|
+ if(error){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ if(!res){
|
|
|
+ return !1;
|
|
|
+ }
|
|
|
+ var pkuid=res;
|
|
|
+ //console.log('pkuid---'+pkuid);
|
|
|
+ /* 更新数据库 */
|
|
|
+ var sign_data={uid:uid,pkuid:pkuid,type:0};
|
|
|
+ var sign=setSign(sign_data);
|
|
|
+ request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+uid + "&pkuid=" + pkuid+ "&type=0&sign=" +sign,function(error, response, body){
|
|
|
+ if(error) return;
|
|
|
+
|
|
|
+ var res = evalJson(body);
|
|
|
+ if( response.statusCode == 200 && res.data.code == 0){
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"LiveConnect",
|
|
|
+ "action":"5",
|
|
|
+ "msgtype":"10",
|
|
|
+ "uid":""+uid,
|
|
|
+ "uname":""
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+
|
|
|
+ process_msg(io,uid,JSON.stringify(data_obj));
|
|
|
+ process_msg(io,pkuid,JSON.stringify(data_obj));
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+/* PK结束处理 */
|
|
|
+function endLivePk(io,uid,type,addtime){
|
|
|
+ // console.log('结束PK');
|
|
|
+ //console.log('uid-'+uid);
|
|
|
+ //console.log('addtime-'+addtime);
|
|
|
+ //console.log('type-'+type);
|
|
|
+ var sign_data={uid:uid,addtime:addtime,type:type};
|
|
|
+ var sign=setSign(sign_data);
|
|
|
+ request(config['WEBADDRESS']+"?service=Livepk.endPK&uid="+uid + "&addtime=" + addtime+ "&type=" + type+ "&sign=" +sign,function(error, response, body){
|
|
|
+ if(error) return;
|
|
|
+ // console.log('endPK');
|
|
|
+ // console.log(body);
|
|
|
+ var res = evalJson(body);
|
|
|
+ if( response.statusCode == 200 && res.data.code == 0){
|
|
|
+ var info=res.data.info[0];
|
|
|
+ var data_obj={
|
|
|
+ "msg":[
|
|
|
+ {
|
|
|
+ "_method_":"LivePK",
|
|
|
+ "action":"9",
|
|
|
+ "msgtype":"10",
|
|
|
+ "win_uid":""+info['win_uid'],
|
|
|
+ "uid":""+uid,
|
|
|
+ "uname":""
|
|
|
+ }
|
|
|
+ ],
|
|
|
+ "retcode":"000000",
|
|
|
+ "retmsg":"OK"
|
|
|
+ };
|
|
|
+
|
|
|
+ process_msg(io,uid,JSON.stringify(data_obj));
|
|
|
+ process_msg(io,info['pkuid'],JSON.stringify(data_obj));
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+//时间格式化
|
|
|
+function FormatNowDate(){
|
|
|
+ var mDate = new Date();
|
|
|
+ var Y = mDate.getFullYear();
|
|
|
+ var M = mDate.getMonth()+1;
|
|
|
+ var D = mDate.getDate();
|
|
|
+ var H = mDate.getHours();
|
|
|
+ var i = mDate.getMinutes();
|
|
|
+ var s = mDate.getSeconds();
|
|
|
+ return Y +'-' + M + '-' + D + ' ' + H + ':' + i + ':' + s;
|
|
|
+}
|
|
|
+
|
|
|
+/* sign加密 */
|
|
|
+function setSign(obj) {//排序的函数
|
|
|
+ var str='';
|
|
|
+ var newkey = Object.keys(obj).sort();
|
|
|
+//先用Object内置类的keys方法获取要排序对象的属性名,再利用Array原型上的sort方法对获取的属性名进行排序,newkey是一个数组
|
|
|
+ var newObj = {};//创建一个新的对象,用于存放排好序的键值对
|
|
|
+ for (var i = 0; i < newkey.length; i++) {//遍历newkey数组
|
|
|
+ //newObj[newkey[i]] = obj[newkey[i]];//向新创建的对象中按照排好的顺序依次增加键值对
|
|
|
+ str+=newkey[i]+'='+obj[newkey[i]]+'&';
|
|
|
+ }
|
|
|
+ str+=config['sign_key'];
|
|
|
+
|
|
|
+ var sign=md5(str);
|
|
|
+ return sign;
|
|
|
+}
|