通过udp实现两台电脑之间进行通话功能

#include "mainwindow.h" #include "ui_mainwindow.h" MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent), ui(new Ui::MainWindow) { ui->setupUi(this); muCoDecInit(); //获取输入音频设备名称 QList<QString> deviceListIn; QList<QAudioDeviceInfo> audioDeviceListIn = QAudioDeviceInfo::availableDevices(QAudio::AudioInput); for(QAudioDeviceInfo devInfo: audioDeviceListIn){ if(devInfo.isNull()){ qWarning()<<"device null"; continue; } QString strName = devInfo.deviceName(); if (strName[0] == 65533){ qWarning()<<"invalid device"; continue; } //避免回同名的音频设备 if(!deviceListIn.contains(strName)){ deviceListIn.append(strName); } } qInfo()<<"audio input device: size="<<deviceListIn.size()<<", list="<<deviceListIn; //QAudioDeviceInfo infoIn = audioDeviceListIn.at(2); QAudioDeviceInfo infoIn =QAudioDeviceInfo::defaultInputDevice(); //获取输出音频设备名称 QList<QString> deviceListOut; QList<QAudioDeviceInfo> audioDeviceListOut = QAudioDeviceInfo::availableDevices(QAudio::AudioOutput); for(QAudioDeviceInfo devInfo: audioDeviceListOut) { if (devInfo.isNull()){ qWarning()<<"device null"; continue; } QString strName = devInfo.deviceName(); if (strName[0] == 65533){ qWarning()<<"invalid device"; continue; } //避免回同名的音频设备 if(!deviceListOut.contains(strName)){ deviceListOut.append(strName); } } qInfo()<<"audio output device: size="<<deviceListOut.size()<<", list="<<deviceListOut; //QAudioDeviceInfo infoOut = audioDeviceListIn.at(0); QAudioDeviceInfo infoOut =QAudioDeviceInfo::defaultOutputDevice(); QAudioFormat format; format.setSampleRate(8000); format.setChannelCount(1); format.setSampleSize(16); format.setCodec("audio/pcm"); format.setByteOrder(QAudioFormat::LittleEndian); format.setSampleType(QAudioFormat::SignedInt); udpsocketreceive = new QUdpSocket(this); udpsocketreceive->bind(QHostAddress::AnyIPv4, 10004); connect(udpsocketreceive, SIGNAL(readyRead()), this, SLOT(readReadSlotReceive())); output = new QAudioOutput(infoOut, format, this); output->setVolume(1.0); outputDevice = output->start(); udpSocketsend = new QUdpSocket(this); input = new QAudioInput(infoIn, format, this); input->setVolume(1.0); inputDevice =input->start(); // input开始读入输入的音频信号，写入QIODevice，这里是inputDevice connect(inputDevice, SIGNAL(readyRead()), this, SLOT(onReadyReadSend())); //发送音频给ACP } int MainWindow:: findfirstbit(uint32_t bit,uint32_t data) { for(int i=0;i<32;i++){ if(i != 0) data<<=1 ; if(bit==((data&0x80000000)>>31)) { return i; } } } void MainWindow:: muCoDecInit(void) { uint32_t uiPCM = 0; uint32_t uiMu = 0; uint32_t uiData = 0; uint32_t uiSign = 0; uint32_t uiLmbd = 0; uint16_t uiQuant = 0; int16_t sTmp = 0; uint32_t uiAbs = 0; uint32_t uiSeg = 0; uint32_t uiOut = 0; //uint8_t s_aucInt2Mu[uiPCM]; //uint16_t s_ausMu2Int[uiMu]; for(uiPCM=0u; uiPCM<PCM_NUM; ++uiPCM) { sTmp = (int16_t)uiPCM; uiAbs = 132u; uiAbs += (((uint32_t)abs((int32_t)sTmp) >> 2) << 2); uiLmbd = findfirstbit(1u, uiAbs); uiSeg = (24u - findfirstbit(1u, uiAbs)) << 4; // 32bit lmbd閺屻儲澹�1u閸︹暠iabs娑擃厾娈戞担宥囩枂閿涘奔绮犳妯圭秴瀵拷婵锟藉倽绻戦崶鐐扮秴閺佸府绱濋張顏呯叀閸掓媽绻戦崶锟�32.閵嗗倶锟藉倶锟斤拷 uiQuant = (uiAbs >> (25u + 2u - uiLmbd)) & 0x0Fu; uiOut = uiSeg + uiQuant; if(uiAbs > 32767u) { uiOut = 0x7Fu; } if(sTmp < 0) { s_aucInt2Mu[uiPCM] = ((uint8_t)uiOut) ^ 0x7Fu; } else { s_aucInt2Mu[uiPCM] = ((uint8_t)uiOut) ^ 0xFFu; } } for(uiMu=0u; uiMu<MULAW_NUM; ++uiMu) { uiData = (uiMu ^ 0xFFu); uiSign = ((uiData<<24u)>>31u); // 32bit uiQuant = 132u; uiQuant+=((uiData<<28u)>>25u); uiQuant<<=((uiData<<25u)>>29u); if(1u == uiSign) { s_ausMu2Int[uiMu] = (uint16_t)(132u - uiQuant); } else { s_ausMu2Int[uiMu] = (uint16_t)(uiQuant - 132u); } } for (int i=0;i<20;i++) { //qDebug()<<"["<<i<<"]"<<"s_aucInt2Mu"<<s_aucInt2Mu[i]<<"s_ausMu2Int"<<s_ausMu2Int[i]<<endl; } } void MainWindow:: mulaw2intVec(uint8_t input[], int16_t output[], int32_t len) { int32_t idx = 0; for (idx = 0; idx<len; ++idx) { output[idx] =static_cast<int16_t>(s_ausMu2Int[input[idx]]) ; } } void MainWindow:: int2mulawVec(int16_t input[], uint8_t output[], int32_t len) { int32_t idx = 0; uint16_t temp; for (idx = 0; idx<len; ++idx) { temp =static_cast<uint16_t>(input[idx]); output[idx] = s_aucInt2Mu[temp]; } } void MainWindow::onReadyReadSend() { memset(&buff, 0, sizeof(buff)); //读取音频vpsend inputDevice->read(reinterpret_cast<char*>(buff) , sizeof(buff)); for (int i = 0; i<320; i++) { int16_t result =static_cast<int16_t>((buff[i * 2 + 1] << 8) + (buff[i * 2])) ; int2mlawinput[i] = result; } int2mulawVec(int2mlawinput, int2mlawoutput, 320); for (int i = 0; i<320; i++) { data[i] = int2mlawoutput[i]; } QHostAddress destaddr; destaddr.setAddress("192.168.1.120"); udpSocketsend->writeDatagram(reinterpret_cast<const char *>(data), sizeof(data), destaddr, 10005); } MainWindow::~MainWindow() { udpSocketsend->abort(); udpsocketreceive->abort(); delete udpSocketsend; delete udpsocketreceive; delete ui; } void MainWindow::readReadSlotReceive() { while (udpsocketreceive->hasPendingDatagrams()) { QHostAddress senderip; quint16 senderport; memset(&data, 0, sizeof(data)); udpsocketreceive->readDatagram(reinterpret_cast<char *>(data) , sizeof(data), &senderip, &senderport); mulaw2intVec(data, mlaw2intoutput, 320); for (int i = 0; i<320; i++) { short audiodata = mlaw2intoutput[i]; buff[i * 2 + 1] = static_cast<uint8_t>((audiodata & 0xff00) >> 8); buff[i * 2] = static_cast<uint8_t>(audiodata & 0x00ff); } qDebug() << "read ip" << senderip; qDebug() << "read port" << senderport; outputDevice->write(reinterpret_cast<char*>(buff), sizeof (buff)); //qDebug()<<"data"<<(char*)vp.data; } }