HTML5录音实践总结(Preact)

const mediaStream = await window.navigator.mediaDevices.getUserMedia({    audio: {		// sampleRate: 44100, // 采样率 不生效需要手动重采样        channelCount: 1, // 声道        // echoCancellation: true,        // noiseSuppression: true, // 降噪 实测效果不错    },})const audioContext = new window.AudioContext()const inputSampleRate = audioContext.sampleRateconst mediaNode = audioContext.createMediaStreamSource(mediaStream)if (!audioContext.createScriptProcessor) {	audioContext.createScriptProcessor = audioContext.createJavaScriptNode}// 创建一个jsNodeconst jsNode = audioContext.createScriptProcessor(4096, 1, 1)jsNode.connect(audioContext.destination)jsNode.onaudioprocess = (e) => {    // e.inputBuffer.getChannelData(0) (left)    // 双通道通过e.inputBuffer.getChannelData(1)获取 (right)}mediaNode.connect(jsNode)

start=>start: 开始getUserMedia=>operation: 获取MediaStreamaudioContext=>operation: 创建AudioContextscriptNode=>operation: 创建scriptNode并关联AudioContextonaudioprocess=>operation: 设置onaudioprocess并处理数据end=>end: 结束start->getUserMedia->audioContext->scriptNode->onaudioprocess->end

jsNode.disconnect()mediaNode.disconnect()jsNode.onaudioprocess = null

const leftDataList = [];const rightDataList = [];function onAudioProcess(event) {  // 一帧的音频PCM数据  let audioBuffer = event.inputBuffer;  leftDataList.push(audioBuffer.getChannelData(0).slice(0));  rightDataList.push(audioBuffer.getChannelData(1).slice(0));}// 交叉合并左右声道的数据function interleaveLeftAndRight(left, right) {  let totalLength = left.length + right.length;  let data = new Float32Array(totalLength);  for (let i = 0; i < left.length; i++) {    let k = i * 2;    data[k] = left[i];    data[k + 1] = right[i];  }  return data;}

const float32 = new Float32Array(1)const int16 = Int16Array.from(	float32.map(x => (x > 0 ? x * 0x7fff : x * 0x8000)),)

import { encode } from 'base64-arraybuffer'const float32 = new Float32Array(1)const int16 = Int16Array.from(	float32.map(x => (x > 0 ? x * 0x7fff : x * 0x8000)),)console.log(encode(int16.buffer))

# 单通道 采样率:16000 Int16ffplay -f s16le -ar 16k -ac 1 test.pcm# 双通道 采样率:48000 Float32ffplay -f f32le -ar 48000 -ac 2 test.pcm

const mediaStream = await window.navigator.mediaDevices.getUserMedia({    audio: {    	// sampleRate: 44100, // 采样率 设置不生效        channelCount: 1, // 声道        // echoCancellation: true, // 减低回音        // noiseSuppression: true, // 降噪, 实测效果不错    },})

import { resample } from 'wave-resampler'const inputSampleRate =  44100const outputSampleRate = 16000const resampledBuffers = resample(    // 需要onAudioProcess每一帧的buffer合并后的数组	mergeArray(audioBuffers),	inputSampleRate,	outputSampleRate,)

import { Mp3Encoder } from 'lamejs'let mp3bufconst mp3Data = []const sampleBlockSize = 576 * 10 // 工作缓存区, 576的倍数const mp3Encoder = new Mp3Encoder(1, outputSampleRate, kbps)const samples = float32ToInt16(  audioBuffers,  inputSampleRate,  outputSampleRate,)let remaining = samples.lengthfor (let i = 0; remaining >= 0; i += sampleBlockSize) {  const left = samples.subarray(i, i + sampleBlockSize)  mp3buf = mp3Encoder.encodeBuffer(left)  mp3Data.push(new Int8Array(mp3buf))  remaining -= sampleBlockSize}mp3Data.push(new Int8Array(mp3Encoder.flush()))console.log(mp3Data)// 工具函数function float32ToInt16(audioBuffers, inputSampleRate, outputSampleRate) {  const float32 = resample(    // 需要onAudioProcess每一帧的buffer合并后的数组    mergeArray(audioBuffers),    inputSampleRate,    outputSampleRate,  )  const int16 = Int16Array.from(    float32.map(x => (x > 0 ? x * 0x7fff : x * 0x8000)),  )  return int16}

> ls -alh-rwxrwxrwx 1 root root  95K  4月 22 12:45 12s.mp3*-rwxrwxrwx 1 root root 1.1M  4月 22 12:44 12s.wav*-rwxrwxrwx 1 root root 235K  4月 22 12:41 30s.mp3*-rwxrwxrwx 1 root root 2.6M  4月 22 12:40 30s.wav*-rwxrwxrwx 1 root root  63K  4月 22 12:49 8s.mp3*-rwxrwxrwx 1 root root 689K  4月 22 12:48 8s.wav*

function mergeArray(list) {  const length = list.length * list[0].length  const data = new Float32Array(length)  let offset = 0  for (let i = 0; i < list.length; i++) {    data.set(list[i], offset)    offset += list[i].length  }  return data}function writeUTFBytes(view, offset, string) {  var lng = string.length  for (let i = 0; i < lng; i++) {    view.setUint8(offset + i, string.charCodeAt(i))  }}function createWavBuffer(audioData, sampleRate = 44100, channels = 1) {  const WAV_HEAD_SIZE = 44  const buffer = new ArrayBuffer(audioData.length * 2 + WAV_HEAD_SIZE)  // 需要用一个view来操控buffer  const view = new DataView(buffer)  // 写入wav头部信息  // RIFF chunk descriptor/identifier  writeUTFBytes(view, 0, 'RIFF')  // RIFF chunk length  view.setUint32(4, 44 + audioData.length * 2, true)  // RIFF type  writeUTFBytes(view, 8, 'WAVE')  // format chunk identifier  // FMT sub-chunk  writeUTFBytes(view, 12, 'fmt')  // format chunk length  view.setUint32(16, 16, true)  // sample format (raw)  view.setUint16(20, 1, true)  // stereo (2 channels)  view.setUint16(22, channels, true)  // sample rate  view.setUint32(24, sampleRate, true)  // byte rate (sample rate * block align)  view.setUint32(28, sampleRate * 2, true)  // block align (channel count * bytes per sample)  view.setUint16(32, channels * 2, true)  // bits per sample  view.setUint16(34, 16, true)  // data sub-chunk  // data chunk identifier  writeUTFBytes(view, 36, 'data')  // data chunk length  view.setUint32(40, audioData.length * 2, true)  // 写入PCM数据  let index = 44  const volume = 1  const { length } = audioData  for (let i = 0; i < length; i++) {    view.setInt16(index, audioData[i] * (0x7fff * volume), true)    index += 2  }  return buffer}// 需要onAudioProcess每一帧的buffer合并后的数组createWavBuffer(mergeArray(audioBuffers))

function shortTimeEnergy(audioData) {  let sum = 0  const energy = []  const { length } = audioData  for (let i = 0; i < length; i++) {    sum += audioData[i] ** 2    if ((i + 1) % 256 === 0) {      energy.push(sum)      sum = 0    } else if (i === length - 1) {      energy.push(sum)    }  }  return energy}

const NoiseVoiceWatershedWave = 2.3const energy = shortTimeEnergy(e.inputBuffer.getChannelData(0).slice(0))const avg = energy.reduce((a, b) => a + b) / energy.lengthconst nextState = Math.max(...energy) / avg > NoiseVoiceWatershedWave ? 'voice' : 'noise'

export default (config, env, helpers) => {    config.module.rules.push({        test: //.worker/.js$/,        use: { loader: 'worker-loader', options: { inline: true } },      })}

self.addEventListener('message', event => {  console.log(event.data)  // 转MP3/转Base64/转WAV等等  const output = ''  self.postMessage(output)}

async function toMP3(audioBuffers, inputSampleRate, outputSampleRate = 16000) {  const { default: Worker } = await import('./recorder.worker')  const worker = new Worker()  // 简单使用, 项目可以在recorder实例化的时候创建worker实例, 有并法需求可多个实例  return new Promise(resolve => {    worker.postMessage({      audioBuffers: audioBuffers,      inputSampleRate: inputSampleRate,      outputSampleRate: outputSampleRate,      type: 'mp3',    })    worker.onmessage = event => resolve(event.data)  })}

> ls -alh-rwxrwxrwx 1 root root  95K  4月 22 12:45 12s.mp3*-rwxrwxrwx 1 root root 1.1M  4月 22 12:44 12s.wav*-rwxrwxrwx 1 root root 235K  4月 22 12:41 30s.mp3*-rwxrwxrwx 1 root root 2.6M  4月 22 12:40 30s.wav*-rwxrwxrwx 1 root root  63K  4月 22 12:49 8s.mp3*-rwxrwxrwx 1 root root 689K  4月 22 12:48 8s.wav*

const indexedDB =  window.indexedDB ||  window.webkitIndexedDB ||  window.mozIndexedDB ||  window.OIndexedDB ||  window.msIndexedDBconst IDBTransaction =  window.IDBTransaction ||  window.webkitIDBTransaction ||  window.OIDBTransaction ||  window.msIDBTransactionconst readWriteMode =  typeof IDBTransaction.READ_WRITE === 'undefined'    ? 'readwrite'    : IDBTransaction.READ_WRITEconst dbVersion = 1const storeDefault = 'mp3'let dbLinkfunction initDB(store) {  return new Promise((resolve, reject) => {    if (dbLink) resolve(dbLink)    // Create/open database    const request = indexedDB.open('audio', dbVersion)    request.onsuccess = event => {      const db = request.result      db.onerror = event => {        reject(event)      }      if (db.version === dbVersion) resolve(db)    }    request.onerror = event => {      reject(event)    }    // For future use. Currently only in latest Firefox versions    request.onupgradeneeded = event => {      dbLink = event.target.result      const { transaction } = event.target      if (!dbLink.objectStoreNames.contains(store)) {        dbLink.createObjectStore(store)      }      transaction.oncomplete = event => {        // Now store is available to be populated        resolve(dbLink)      }    }  })}export const writeIDB = async (name, blob, store = storeDefault) => {  const db = await initDB(store)  const transaction = db.transaction([store], readWriteMode)  const objStore = transaction.objectStore(store)  return new Promise((resolve, reject) => {    const request = objStore.put(blob, name)    request.onsuccess = event => resolve(event)    request.onerror = event => reject(event)    transaction.commit && transaction.commit()  })}export const readIDB = async (name, store = storeDefault) => {  const db = await initDB(store)  const transaction = db.transaction([store], readWriteMode)  const objStore = transaction.objectStore(store)  return new Promise((resolve, reject) => {    const request = objStore.get(name)    request.onsuccess = event => resolve(event.target.result)    request.onerror = event => reject(event)    transaction.commit && transaction.commit()  })}export const clearIDB = async (store = storeDefault) => {  const db = await initDB(store)  const transaction = db.transaction([store], readWriteMode)  const objStore = transaction.objectStore(store)  return new Promise((resolve, reject) => {    const request = objStore.clear()    request.onsuccess = event => resolve(event)    request.onerror = event => reject(event)    transaction.commit && transaction.commit()  })}

webView.setWebChromeClient(new WebChromeClient(){	@TargetApi(Build.VERSION_CODES.LOLLIPOP)	@Override	public void onPermissionRequest(final PermissionRequest request) {		request.grant(request.getResources());	}});