decoder.js 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. var isFinish = false;
  2. var decodeCount = 0;
  3. var h264Queue = [];
  4. var isFirst = true;
  5. var ret = ''
  6. var parameters = GetRequest();
  7. var videoWidth = parameters['width'];
  8. var videoHeight = parameters['height'];
  9. self.Module = {
  10. onRuntimeInitialized: function () {
  11. ret = Module._openDecoder(videoWidth, videoHeight);
  12. if (!ret) {
  13. isFinish = true;
  14. }
  15. }
  16. };
  17. self.importScripts("ffmpeghelper.js");
  18. self.addEventListener('message', function (e) {
  19. h264Queue.push(e.data);
  20. }, false);
  21. function PrintfLog(str) {
  22. var curTime = new Date().getTime();
  23. var objData = {
  24. cmd: 0,
  25. data: str,
  26. time: curTime
  27. };
  28. self.postMessage(objData);
  29. }
  30. setInterval(
  31. function () {
  32. if (h264Queue.length > 0 && isFinish) {
  33. if (isFirst) {
  34. PrintfLog("当前队列大小 :" + h264Queue.length);
  35. isFirst = false;
  36. }
  37. if (h264Queue.length > 10 && isFinish) {
  38. PrintfLog("解不过来 " + h264Queue.length);
  39. return;
  40. }
  41. decodeH264(h264Queue.shift());
  42. }
  43. }, 1);
  44. function decodeH264(data) {
  45. var size = videoWidth * videoHeight *3;
  46. var retPtr = Module._malloc(size); //接收的数据
  47. var inputPtr = Module._malloc(data.length); //输入数据
  48. for (var i = 0; i < data.length; i++) {
  49. Module.HEAPU8[(inputPtr) + i] = data[i]; //转换为堆数据
  50. }
  51. var time = new Date().getTime();
  52. var ret = Module._feedData(inputPtr, data.length, retPtr);
  53. if (ret >= 0) {
  54. if (decodeCount > 50) {
  55. var curCost = new Date().getTime() - time;
  56. PrintfLog("解码耗时 " + curCost + " ms");
  57. decodeCount = 0;
  58. }
  59. decodeCount++;
  60. }
  61. var yuvData = new Uint8Array(size);
  62. for (var i = 0; i < yuvData.length; i++) {
  63. yuvData[i] = Module.HEAPU8[(retPtr) + i];
  64. }
  65. var curTime = new Date().getTime();
  66. var objData = {
  67. cmd: 1,
  68. data: yuvData,
  69. time: curTime
  70. };
  71. self.postMessage(objData);
  72. Module._free(inputPtr);
  73. Module._free(retPtr);
  74. }
  75. function closeDecoder() {
  76. Module._destroyDecoder();
  77. }
  78. // 获取url中"?"符后的字串
  79. function GetRequest() {
  80. var url = location.search;
  81. var obj = new Object();
  82. if (url.indexOf("?") != -1) {
  83. var str = url.substring(1);
  84. strs = str.split("&");
  85. for (var i = 0; i < strs.length; i++) {
  86. obj[strs[i].split("=")[0]] = (strs[i].split("=")[1]);
  87. }
  88. }
  89. return obj;
  90. }