Qt实现基于G.729A（G729A）的语音聊天

#include "widget.h" #include "ui_widget.h" #include <QDebug> const int BUFFER_SIZE = 2048; Widget::Widget(QWidget *parent) : QWidget(parent), ui(new Ui::Widget) { ui->setupUi(this); //设置采样格式 QAudioFormat audioFormat; //设置采样率 audioFormat.setSampleRate(8000); //设置通道数 audioFormat.setChannelCount(1); //设置采样大小，一般为8位或16位 audioFormat.setSampleSize(16); //设置编码方式 audioFormat.setCodec("audio/pcm"); //设置字节序 audioFormat.setByteOrder(QAudioFormat::LittleEndian); //设置样本数据类型 audioFormat.setSampleType(QAudioFormat::UnSignedInt); //获取设备信息 QAudioDeviceInfo info = QAudioDeviceInfo::defaultInputDevice(); if (!info.isFormatSupported(audioFormat)) { qDebug()<<"default format not supported try to use nearest"; audioFormat = info.nearestFormat(audioFormat); } info = QAudioDeviceInfo::defaultOutputDevice(); if (!info.isFormatSupported(audioFormat)) { qDebug()<<"default format not supported try to use nearest"; audioFormat = info.nearestFormat(audioFormat); } audioInput = new QAudioInput(audioFormat, this); //将麦克风的音频数据传输到输入设备 streamIn = audioInput->start(); //当输入设备检测到数据时，调用槽函数slogReadData connect(streamIn, SIGNAL(readyRead()), SLOT(slogReadData())); audioOutput = new QAudioOutput(audioFormat, this); //将音频数据传输到输出设备，再由输出设备写入到扬声器 streamOut = audioOutput->start(); //创建UDP线程 CUdpThread *udpThread=new CUdpThread(); udpThreadFather=new QThread(); udpThread->moveToThread(udpThreadFather); connect(udpThreadFather,SIGNAL(started()),udpThread,SLOT(run())); //启动线程 udpThreadFather->start(); connect(this,SIGNAL(signalSendData(const QByteArray &)),udpThread,SLOT(slotSendData(const QByteArray &))); connect(udpThread,SIGNAL(signalSendData(const QByteArray &)),this,SLOT(slotSendData(const QByteArray &))); } Widget::~Widget() { delete ui; } void Widget::slogReadData() { short srcAudio[L_FRAME]={0}; unsigned char dstAudio[L_FRAME_COMPRESSED]={'\0'}; if (!audioInput) { qDebug() << "AudioInput Error"; return; } QByteArray dataBuffer(BUFFER_SIZE,0); qint64 len1 = audioInput->bytesReady(); if (len1 > BUFFER_SIZE) { qDebug()<<"BUFFER_SIZE too small"; return; } qint64 len2 = streamIn->read(dataBuffer.data(), len1); tempBuffer.append(dataBuffer.data(),len2); for(int i=0;i<tempBuffer.length()/(L_FRAME*2);i++) { //char转short memcpy(srcAudio,tempBuffer.data()+i*L_FRAME*2,L_FRAME*2); //编码 cg729Encoder.encode(srcAudio, dstAudio); QByteArray frame; //reinterpret_cast用于强制转换，这里将unsigned char *转换为const char *。 frame.append(reinterpret_cast<const char*>(dstAudio),L_FRAME_COMPRESSED); signalSendData(frame); } tempBuffer.clear(); } void Widget::slotSendData(const QByteArray &byte_array) { for(int i=0;i<byte_array.length()/L_FRAME_COMPRESSED;i++) { unsigned char srcAudio[L_FRAME_COMPRESSED]={'\0'}; short dstAudio[L_FRAME]={0}; memcpy(srcAudio,(unsigned char*)byte_array.data()+i * L_FRAME_COMPRESSED,L_FRAME_COMPRESSED); //G729解码 cg729Decoder.decode(srcAudio,dstAudio,0); //short转char tempframe.append((char *)dstAudio,L_FRAME * 2); if(audioOutput&&audioOutput->state()!=QAudio::StoppedState&& audioOutput->state()!=QAudio::SuspendedState) { int chunks = audioOutput->bytesFree()/audioOutput->periodSize(); while (chunks) { if (tempframe.length() >= audioOutput->periodSize()) { //写入到扬声器 streamOut->write(tempframe.data(),audioOutput->periodSize()); tempframe = tempframe.mid(audioOutput->periodSize()); } else { //写入到扬声器 streamOut->write(tempframe); tempframe.clear(); break; } --chunks; } } } } void Widget::on_pushButton_clicked() { if (audioInput->state() == QAudio::SuspendedState) { audioInput->resume(); ui->pushButton->setText(QStringLiteral("暂停")); } else if (audioInput->state() == QAudio::ActiveState) { audioInput->suspend(); ui->pushButton->setText(QStringLiteral("开始")); } else if (audioInput->state() == QAudio::StoppedState) { audioInput->resume(); ui->pushButton->setText(QStringLiteral("暂停")); } else if (audioInput->state() == QAudio::IdleState) { //To Do } } void Widget::on_pushButtonSetIp_clicked() { CUdpThread::IpAddress=ui->lineEdit->text(); }