快速开始

import asyncio
import wave

import srtc


async def main(token: str):
    files: dict[str, wave.Wave_write] = {}
    fmt = srtc.AudioFormat(sample_rate=16000, channels=1)      # 收到的 PCM 格式，默认就是 16k 单声道

    async with await srtc.Channel.join(token, auto_subscribe_audio=True, audio_format=fmt) as ch:
        print(f"已加入 {ch.info.channel}，我是 {ch.me.uid}")

        async for frame in ch.audio_frames():               # 所有已订阅的远端音频，逐帧到达
            wf = files.get(frame.uid)
            if wf is None:
                wf = files[frame.uid] = wave.open(f"{frame.uid}.wav", "wb")
                wf.setnchannels(fmt.channels)
                wf.setsampwidth(2)                          # S16LE
                wf.setframerate(fmt.sample_rate)
            wf.writeframes(frame.pcm)


asyncio.run(main("<你的服务端签发的 token>"))

import asyncio

import numpy as np

import srtc


async def main(token: str):
    async with await srtc.Channel.join(token) as ch:
        # 发布一路音频，write() 接收 24k 单声道 PCM（任意采样率都行，SDK 内部会重采样）
        tts = await ch.publish_audio(desc="tts", audio_format=srtc.AudioFormat(24000, 1))

        # 这里用 3 秒 440Hz 正弦波代替 TTS 输出
        t = np.arange(24000 * 3) / 24000
        pcm = (np.sin(2 * np.pi * 440 * t) * 8000).astype(np.int16)

        await tts.write(pcm)              # 一次写入任意长度，SDK 按实时节奏每 20ms 发一帧
        await tts.wait_for_playout()      # 等全部发完再离开


asyncio.run(main("<你的服务端签发的 token>"))

class Printer(srtc.ChannelHandler):
    def on_user_join(self, user: srtc.UserInfo):
        print("加入:", user.uid, user.name)

    def on_user_leave(self, uid: str):
        print("离开:", uid)

    async def on_disconnected(self, reason: srtc.DisconnectReason, error):
        print("已断开:", reason.name, error or "")


ch = await srtc.Channel.join(token, handler=Printer())