JS 多线程

var realTimeWorker = new Worker('js/worker-realtime.js');
realTimeWorker.postMessage({ cmd: 'finish' });
w.terminate();

(function () {
  'use strict';
importScripts('lame.min.js');
var mp3Encoder, maxSamples = 1152, samplesMono, lame, config, dataBuffer;

var ws;

var clearBuffer = function () ;
var appendToBuffer = function (mp3Buf) {

dataBuffer.push(new Int8Array(mp3Buf));

};
var init = function (prefConfig) {

config = prefConfig || {};

lame = new lamejs();

mp3Encoder = new lame.Mp3Encoder(1,  config.sampleRate, config.bitRate);

clearBuffer();

self.postMessage({

cmd: 'init'

});

};
var floatTo16BitPCM = function floatTo16BitPCM(input, output) {

for (var i = 0; i < input.length; i++) {

var s = Math.max(-1, Math.min(1, input[i]));

output[i] = (s < 0 ? s * 0x8000 : s * 0x7FFF);

}

};
var convertBuffer = function (arrayBuffer) {

var data = new Float32Array(arrayBuffer);

var out = new Int16Array(arrayBuffer.length);

floatTo16BitPCM(data, out)

return out;

};
var encode = function (arrayBuffer) {

samplesMono = convertBuffer(arrayBuffer);

var remaining = samplesMono.length;
  for (var i = 0; remaining &gt;= 0; i += maxSamples) {
      var left = samplesMono.subarray(i, i + maxSamples);
      var mp3buf = mp3Encoder.encodeBuffer(left);
	if(mp3buf.length &gt; 0)
	{
		var mp3Data = [];
		mp3Data.push(mp3buf);
		let blob = new Blob(mp3Data, {type: 'audio/mp3'});
		ws.send(blob);
	}
      appendToBuffer(mp3buf);
      remaining -= maxSamples;
  }

};
var finish = function () {

appendToBuffer(mp3Encoder.flush());

self.postMessage({

cmd: 'end',

buf: dataBuffer

});

clearBuffer();

};

var wsinit = 0;

self.onmessage = function (e) {

switch (e.data.cmd) {

case 'init':

init(e.data.config);

break;

case 'encode':

if(wsinit == 0)

{

// var url="http://localhost:8090/vmp/dvDevice/getAudioUrl?id=34020000001320000002@34020000001320000002&format=flv&transporttype=udp";

// var request= new XMLHttpRequest();

// request.open("POST",url,false);

// request.setRequestHeader('Access-Control-Allow-Headers','');

// request.setRequestHeader("Access-Control-Allow-Origin",'');

//

// request.send(null);

// var obj = JSON.parse(request.responseText);

// var port = obj["TransportPort"];

// var pushUrl = "ws://127.0.0.1:12345/cgmedia/websocket/pushaudiostream?id=34020000001320000002@34020000001320000002&transportport=";

// pushUrl += port;

// pushUrl += "&format=mp3";

var pushUrl = "ws://127.0.0.1:12345/cgmedia/28181/getaudio?id=34020000001320000002@34020000001320000002&format=flv&transportport=20086&transporttype=udp"

ws = new WebSocket(pushUrl);

ws.binaryType = 'arraybuffer';

ws.onmessage = function(evt) {

console.log('Receive Message');

};

ws.onopen = function() {

console.log('连接成功');

};

ws.onclose = function() {

console.log('连接关闭');

};	

ws.onerror = function(){

console.log('连接错误');

};

wsinit = 1;

}

encode(e.data.buf);

break;

case 'finish':

finish();

break;

}

};
})();