js實現mp3錄音通過websocket實時傳送+簡易波形圖效果
阿新 • • 發佈：2020-06-16
波形圖：https://www.jb51.net/article/188545.htm
廢話：想不到我的第一篇部落格是關於前端，作為一名後端的小菜，前端方面肯定還有很多不足之處，如果文章有任何問題歡迎指正。感謝大家。好了！廢話不多說下面講一下需求。
需求：公司要求實現web端的錄音並通過websocket實時上傳至java後臺，而且能通過vlc實時播放，簡單一點講就是我用網頁在那一邊講話，一個大喇叭就能實時把我的話播出去，這樣是不是通俗易懂呀，而且呢公司要求用mp3格式。當然啦！為了知道自己在講話需要一個波形圖，這裡主要實現前半部分功能，後半部分臣妾也做不到呀！後半部分的vlc播放呢如果大家想知道，可以留言，屆時可以給大家指條明路
前端實現：
引入：
<script type="text/javascript" src="/js/recorder/recordmp3.js"></script>
這個跟大佬的js有點不一樣，我在裡面加了一點東西，而且在這個js裡面引入了兩個另外的js，lame.min.js和worker-realtime.js，這倆在大佬的程式碼裡有
頁面：
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312"/>
<title>測試</title>
</head>
<body>
<button id="intercomBegin">開始對講</button>
<button id="intercomEnd">關閉對講</button>
<canvas id="casvased" style="width: 400px;height: 100px"></canvas>
</body>
<script type="text/javascript" src="/js/jquery-3.3.1.js"></script>
<script type="text/javascript" src="/js/recorder/recordmp3.js"></script>
<script type="text/javascript">
var begin = document.getElementById('intercomBegin');
var end = document.getElementById('intercomEnd');
var canvas = document.getElementById("casvased");
var canvasCtx = canvas.getContext("2d");
var ws = null; //實現WebSocket
var recorder;
/*
* WebSocket
*/
function useWebSocket() {
ws = new WebSocket("ws://127.0.0.1:8089/send/voice");
ws.binaryType = 'arraybuffer'; //傳輸的是 ArrayBuffer 型別的資料
ws.onopen = function () {
console.log('握手成功');
if (ws.readyState == 1) { //ws進入連線狀態，則每隔500毫秒傳送一包資料
recorder.start();
}
};
ws.onmessage = function (msg) {
console.info(msg)
}
ws.onerror = function (err) {
console.info(err)
}
}
/*
* 開始對講
*/
begin.onclick = function () {
recorder = new MP3Recorder({
debug: true,funOk: function () {
console.log('點選錄製，開始錄音！ ');
},funCancel: function (msg) {
console.log(msg);
recorder = null;
}
});
}
/*
* 關閉對講
*/
end.onclick = function () {
if (ws) {
ws.close();
recorder.stop();
console.log('關閉對講以及WebSocket');
}
}
var sendData = function() { //對以獲取的資料進行處理(分包)
var reader = new FileReader();
reader.onload = e => {
var outbuffer = e.target.result;
var arr = new Int8Array(outbuffer);
if (arr.length > 0) {
var tmparr = new Int8Array(1024);
var j = 0;
for (var i = 0; i < arr.byteLength; i++) {
tmparr[j++] = arr[i];
if (((i + 1) % 1024) == 0) {
ws.send(tmparr);
if (arr.byteLength - i - 1 >= 1024) {
tmparr = new Int8Array(1024);
} else {
tmparr = new Int8Array(arr.byteLength - i - 1);
}
j = 0;
}
if ((i + 1 == arr.byteLength) && ((i + 1) % 1024) != 0) {
ws.send(tmparr);
}
}
}
};
recorder.getMp3Blob(function (blob) {
reader.readAsArrayBuffer(blob);//這裡拿到mp3格式的音訊流寫入到reader中
})
}; </script> </html>
recordmp3.js
(function (exports) {
var MP3Recorder = function (config) {
var recorder = this;
config = config || {};
config.sampleRate = config.sampleRate || 44100;
config.bitRate = config.bitRate || 128;
navigator.getUserMedia = navigator.getUserMedia ||
navigator.webkitGetUserMedia ||
navigator.mozGetUserMedia ||
navigator.msGetUserMedia;
if (navigator.getUserMedia) {
navigator.getUserMedia({
audio: true
},function (stream) {
var context = new AudioContext(),microphone = context.createMediaStreamSource(stream),processor = context.createScriptProcessor(16384,1,1),//bufferSize大小，輸入channel數，輸出channel數
mp3ReceiveSuccess,currentErrorCallback;
var height = 100;
var width = 400;
const analyser = context.createAnalyser()
analyser.fftSize = 1024
//連線到音訊源
microphone.connect(analyser);
analyser.connect(context.destination);
const bufferLength = analyser.frequencyBinCount // 返回的是 analyser的fftsize的一半
const dataArray = new Uint8Array(bufferLength);
function draw() {
canvasCtx.clearRect(0,width,height); //清除畫布
analyser.getByteFrequencyData(dataArray); // 將當前頻率資料複製到傳入其中的Uint8Array
const requestAnimFrame = window.requestAnimationFrame(draw) || window.webkitRequestAnimationFrame(draw);
canvasCtx.fillStyle = '#000130';
canvasCtx.fillRect(0,height);
let barWidth = (width / bufferLength) * 2;
let barHeight;
let x = 0;
let c = 2
for (let i = 0; i < bufferLength; i++) {
barHeight = c+(dataArray[i]/400)*height;
canvasCtx.fillStyle = 'rgb(0,255,30)';
canvasCtx.fillRect(x,height / 2 - barHeight / 2,barWidth,barHeight);
x += barWidth + 1;
}
}
draw();
useWebSocket();
config.sampleRate = context.sampleRate;
processor.onaudioprocess = function (event) {
//邊錄音邊轉換
var array = event.inputBuffer.getChannelData(0);
realTimeWorker.postMessage({cmd: 'encode',buf: array});
sendData();
};
var realTimeWorker = new Worker('/js/recorder/worker-realtime.js');
realTimeWorker.onmessage = function (e) {
switch (e.data.cmd) {
case 'init':
log('初始化成功');
if (config.funOk) {
config.funOk();
}
break;
case 'end':
log('MP3大小：',e.data.buf.length);
if (mp3ReceiveSuccess) {
mp3ReceiveSuccess(new Blob(e.data.buf,{type: 'audio/mp3'}));
}
break;
case 'error':
log('錯誤資訊：' + e.data.error);
if (currentErrorCallback) {
currentErrorCallback(e.data.error);
}
break;
default:
log('未知資訊：',e.data);
}
};
recorder.getMp3Blob = function (onSuccess,onError) {
currentErrorCallback = onError;
mp3ReceiveSuccess = onSuccess;
realTimeWorker.postMessage({cmd: 'finish'});
};
recorder.start = function () {
if (processor && microphone) {
microphone.connect(processor);
processor.connect(context.destination);
log('開始錄音');
}
}
recorder.stop = function () {
if (processor && microphone) {
microphone.disconnect();
processor.disconnect();
log('錄音結束');
}
}
realTimeWorker.postMessage({
cmd: 'init',config: {
sampleRate: config.sampleRate,bitRate: config.bitRate
}
});
},function (error) {
var msg;
switch (error.code || error.name) {
case 'PERMISSION_DENIED':
case 'PermissionDeniedError':
msg = '使用者拒絕訪問麥客風';
break;
case 'NOT_SUPPORTED_ERROR':
case 'NotSupportedError':
msg = '瀏覽器不支援麥客風';
break;
case 'MANDATORY_UNSATISFIED_ERROR':
case 'MandatoryUnsatisfiedError':
msg = '找不到麥客風裝置';
break;
default:
msg = '無法開啟麥克風，異常資訊:' + (error.code || error.name);
break;
}
if (config.funCancel) {
config.funCancel(msg);
}
});
} else {
if (config.funCancel) {
config.funCancel('當前瀏覽器不支援錄音功能');
}
}
function log(str) {
if (config.debug) {
console.log(str);
}
}
}
exports.MP3Recorder = MP3Recorder;
})(window);後端websocket：
這裡實現的是儲存為mp3檔案
package com.jetosend.common.socket;
import com.jetosend.common.utils.Utils;
import org.springframework.stereotype.Component;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.*;
import java.nio.ByteBuffer;
import java.util.Hashtable;
import java.util.Map;
@ServerEndpoint("/send/{key}")
@Component
public class ServerSocket {
private static final Map<String,Session> connections = new Hashtable<>();
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
/***
* @Description:開啟連線
* @Param: [id,儲存對方平臺的資源編碼
* session]
* @Return: void
* @Author: Liting
* @Date: 2019-10-10 09:22
*/
@OnOpen
public void onOpen(@PathParam("key") String id,Session session) {
System.out.println(id + "連上了");
connections.put(id,session);
}
/**
* 接收訊息
*/
@OnMessage
public void onMessage(@PathParam("key") String id,InputStream inputStream) {
System.out.println("來自" + id);
try {
int rc = 0;
byte[] buff = new byte[100];
while ((rc = inputStream.read(buff,100)) > 0) {
byteArrayOutputStream.write(buff,rc);
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 異常處理
*
* @param throwable
*/
@OnError
public void onError(Throwable throwable) {
throwable.printStackTrace();
//TODO 日誌列印異常
}
/**
* 關閉連線
*/
@OnClose
public void onClose(@PathParam("key") String id) {
System.out.println(id + "斷開");
BufferedOutputStream bos = null;
FileOutputStream fos = null;
File file = null;
try {
file = new File("D:\\testtest.mp3");
//輸出流
fos = new FileOutputStream(file);
//緩衝流
bos = new BufferedOutputStream(fos);
//將位元組陣列寫出
bos.write(byteArrayOutputStream.toByteArray());
} catch (Exception e) {
e.printStackTrace();
} finally {
if (bos != null) {
try {
bos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (fos != null) {
try {
fos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
connections.remove(id);
}實現效果：
總結
到此這篇關於js實現mp3錄音通過websocket實時傳送+簡易波形圖效果的文章就介紹到這了,更多相關js實現mp3錄音內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！