var h5player=(function(){
var h5playerFun = function(config){};
//初始化函数
h5playerFun.prototype.init = function(config) {
this.videoelement = $("#"+config.elementid)[0];
this.wsURL=config.wsurl;
this.ackID=config.ackid;
return this;
};
//开始函数
h5playerFun.prototype.start = function() {
this.sourceBuffer;
this.mimeCodec = 'video/mp4; codecs="avc1.42E01E, mp4a.40.2"';
this.ws;
this.dataArray=[];
this.mediaSource=new MediaSource();
this.videoelement.src=URL.createObjectURL(this.mediaSource);
this.mediaSource.addEventListener('sourceopen',_sourceOpen(this));
_fetchMedia(this);
};
//资源打开监听
var _sourceOpen = function(that){
setTimeout(function () {
that.sourceBuffer=that.mediaSource.addSourceBuffer(that.mimeCodec);
}, 0);
};
var _fetchMedia = function(that){
//创建websocket连接
that.ws=new WebSocket(that.wsURL);
//设置接收数据位二进制
that.ws.binaryType="arraybuffer";
//创建成功回调函数发送ackid给服务
that.ws.onopen=function(){
that.ws.send(that.ackID);
console.error("connected"+that.ackID);
};
//接收消息回调函数
that.ws.onmessage=function(e){
console.log(that.ackID);
//把接收的数据存入缓存区存满50000个字节再塞到节点播放
this.buffer = [];
this.buffer.push(e.data);
var data = this.buffer.shift();
var array = Array.prototype.slice.call(new Uint8Array(data));
that.dataArray=that.dataArray.concat(array);
if(that.dataArray.length>50000){
var arrayBuffer = new Uint8Array(that.dataArray).buffer;
that.dataArray=[];
_addsourec(arrayBuffer,that);
}
};
//ws关闭回调，关闭之后重新连接
that.ws.onclose=function(){
console.error("closed");
that.start();
};
//ws错误回调
that.ws.onerror=function(e){
console.log(e);
};
};
//把接收的数据存入塞到节点播放
var _addsourec = function(buf,that){
try{
that.sourceBuffer.addEventListener('updateend',function (){});
that.sourceBuffer.appendBuffer(buf);
}catch(err){
that.ws.close();
console.error(err);
console.error(that.ackID);
}
};
//返回构造函数
return h5playerFun;
})();
