李勇

1.修改监课推流获取频道的规则,先查找空闲的频道

@@ -58,7 +58,7 @@ export default class MessageEntrance extends Emiter { @@ -58,7 +58,7 @@ export default class MessageEntrance extends Emiter {
58 constructor() { 58 constructor() {
59 super(); 59 super();
60 //sdk 信息 60 //sdk 信息
61 - GlobalConfig.sdkVersion = "v1.79.6.20170822"; 61 + GlobalConfig.sdkVersion = "v1.80.1.20170823";
62 loger.warn("sdkVersion:" + GlobalConfig.sdkVersion); 62 loger.warn("sdkVersion:" + GlobalConfig.sdkVersion);
63 63
64 //设置 64 //设置
@@ -141,14 +141,23 @@ class MediaModule { @@ -141,14 +141,23 @@ class MediaModule {
141 //监课获取推流地址 141 //监课获取推流地址
142 getMediaPublishPathForInVisible(_param) { 142 getMediaPublishPathForInVisible(_param) {
143 let mediaLen = Object.keys(MediaModule.allMediaChannelsList).length; 143 let mediaLen = Object.keys(MediaModule.allMediaChannelsList).length;
144 - let freeChannel = (this.MEDIA_OBJ_TABLE_ID - 20 - mediaLen) || GlobalConfig.nodeId; 144 + let freeChannel =0;
  145 +
  146 + //先从现有的空闲列表中获取频道号
  147 + for(let i in MediaModule.allMediaChannelsList){
  148 + let channelItem=MediaModule.allMediaChannelsList[i];
  149 + if(channelItem&&channelItem.status==ApeConsts.CHANNEL_STATUS_RELEASED&&channelItem.userRole==ApeConsts.invisible){
  150 + freeChannel=channelItem.channelId;
  151 + break;
  152 + }
  153 + }
  154 + //如果没有取到空闲的,就创建一个新的频道
  155 + freeChannel =freeChannel|| (this.MEDIA_OBJ_TABLE_ID - 20 - mediaLen);
  156 +
145 loger.log('监课获取推流地址->' + freeChannel + " mediaLen:" + mediaLen); 157 loger.log('监课获取推流地址->' + freeChannel + " mediaLen:" + mediaLen);
146 //默认方式推流 158 //默认方式推流
147 let pubType = "live"; 159 let pubType = "live";
148 ////flash推流 160 ////flash推流
149 - //if(_param&&_param.type=="flash"){  
150 - // pubType ="flash";  
151 - //}  
152 161
153 //端口,有端口就显示 ":xxx",没有端口就是"" 162 //端口,有端口就显示 ":xxx",没有端口就是""
154 let port = (GlobalConfig.MS_PUBLISH_PORT == "" || GlobalConfig.MS_PUBLISH_PORT == null) ? "" : ":" + GlobalConfig.MS_PUBLISH_PORT; 163 let port = (GlobalConfig.MS_PUBLISH_PORT == "" || GlobalConfig.MS_PUBLISH_PORT == null) ? "" : ":" + GlobalConfig.MS_PUBLISH_PORT;