播放音效

src/core/audio/audio.ts

@@ -0,0 +1,89 @@
+import { EmitableEvent, EventEmitter } from '../common/eventEmitter';
+
+const ac = new AudioContext();
+
+interface BaseNode {
+    node: AudioNode;
+    channel?: number;
+}
+
+interface AudioPlayerEvent extends EmitableEvent {
+    play: (node: AudioBufferSourceNode) => void;
+    update: (audio: AudioBuffer) => void;
+    end: (node: AudioBufferSourceNode) => void;
+}
+
+export class AudioPlayer extends EventEmitter<AudioPlayerEvent> {
+    static ac: AudioContext = ac;
+    static index: number = 0;
+
+    /** 音频的索引，这样的话可以复用来提高性能表现 */
+    index: number = AudioPlayer.index++;
+
+    data: ArrayBuffer;
+    buffer: AudioBuffer | null = null;
+    source?: AudioBufferSourceNode;
+
+    baseNode: BaseNode[] = [];
+
+    constructor(data: ArrayBuffer) {
+        super();
+        this.data = data;
+        this.update(data);
+    }
+
+    /**
+     * 更新音频数据
+     * @param data 音频的ArrayBuffer数据
+     */
+    async update(data: ArrayBuffer) {
+        this.data = data;
+        this.buffer = await ac.decodeAudioData(data);
+        this.emit('update', this.buffer);
+    }
+
+    /**
+     * 获取音频源数据节点
+     */
+    getSource() {
+        this.source ??= ac.createBufferSource();
+        this.source.buffer = this.buffer;
+
+        return this.source;
+    }
+
+    /**
+     * 播放音频
+     */
+    play(when?: number, offset?: number, duration?: number) {
+        if (!this.source) return;
+        this.ready();
+        this.source?.start(when, offset, duration);
+
+        const source = this.source;
+        this.source?.addEventListener('ended', ev => {
+            this.emit('end', source);
+        });
+        this.emit('play', source);
+
+        delete this.source;
+        return source;
+    }
+
+    /**
+     * 准备音频资源连接
+     */
+    ready() {
+        const source = this.getSource();
+        this.baseNode.forEach(v => {
+            source.connect(v.node, 0, v.channel);
+        });
+    }
+
+    /**
+     * 获取音频输出destination
+     */
+    getDestination() {
+        return ac.destination;
+    }
+}

src/core/audio/sound.ts

@@ -1,7 +1,137 @@
-export class SoundEffect {}
+import { has } from '../../plugin/utils';
+import { AudioPlayer } from './audio';
+
+export class SoundEffect extends AudioPlayer {
+    static playIndex = 0;
+
+    private playing: Record<string, AudioBufferSourceNode> = {};
+    private _stopingAll: boolean = false;
+
+    constructor(data: ArrayBuffer, stereo: boolean = false) {
+        super(data);
+
+        this.on('end', node => {
+            if (this._stopingAll) return;
+            const entry = Object.entries(this.playing);
+            const index = entry.find(v => node === v[1])?.[0];
+            if (!index) return;
+            delete this.playing[index];
+        });
+        this.initAudio(stereo);
+    }
+
+    /**
+     * 设置音频路由线路
+     * @param stereo 是否启用立体声
+     */
+    protected initAudio(stereo: boolean = false) {}
+
+    /**
+     * 播放音频
+     * @returns 音频的唯一id
+     */
+    playSE() {
+        const node = this.play();
+        if (!node) return;
+        const index = SoundEffect.playIndex++;
+        this.playing[index] = node;
+        return index;
+    }
+
+    /**
+     * 停止所有音频
+     */
+    stopAll() {
+        this._stopingAll = true;
+        Object.values(this.playing).forEach(v => {
+            v.stop();
+        });
+        this.playing = {};
+        this._stopingAll = false;
+    }
+
+    /**
+     * 根据唯一id停止音频
+     * @param index 音频唯一id
+     */
+    stopByIndex(index: number) {
+        this.playing[index]?.stop();
+        delete this.playing[index];
+    }
+}
 
 class SoundController {
-    add(uri: string, data: ArrayBuffer) {}
+    list: Record<string, SoundEffect> = {};
+
+    private seIndex: Record<number, SoundEffect> = {};
+
+    /**
+     * 添加一个新的音频
+     * @param uri 音频的uri
+     * @param data 音频的ArrayBuffer信息，会被解析为AudioBuffer
+     */
+    add(uri: string, data: ArrayBuffer) {
+        const se = new SoundEffect(data);
+        if (this.list[uri]) {
+            console.warn(`Repeated sound effect: ${uri}.`);
+        }
+        return (this.list[uri] = se);
+    }
+
+    /**
+     * 移除一个音频
+     * @param uri 要移除的音频的uri
+     */
+    remove(uri: string) {
+        delete this.list[uri];
+    }
+
+    /**
+     * 播放音频
+     * @param sound 音效的名称
+     * @returns 本次播放的音效的唯一标识符，如果音效不存在返回-1
+     */
+    play(sound: SoundIds): number {
+        const se = this.get(sound);
+        const index = se.playSE();
+        if (!has(index)) return -1;
+        this.seIndex[index] = se;
+
+        return index;
+    }
+
+    /**
+     * 停止一个音效的播放
+     * @param id 音效的唯一标识符
+     */
+    stop(id: number) {
+        const se = this.seIndex[id];
+        se.stopByIndex(id);
+    }
+
+    /**
+     * 停止一个名称的所有音效的播放
+     * @param id 音效名称
+     */
+    stopById(id: SoundIds) {
+        const se = this.get(id);
+        se.stopAll();
+    }
+
+    /**
+     * 停止所有音效的播放
+     */
+    stopAll() {
+        Object.values(this.list).forEach(v => v.stopAll());
+    }
+
+    /**
+     * 获取一个音效实例
+     * @param sound 音效名称
+     */
+    get(sound: SoundIds) {
+        return this.list[`sounds.${sound}`];
+    }
 }
 
 declare global {