Qt中使用QWebSocket与Web进行通讯，实时语音通话

#include "QWebSocketManager.h" const int g_nWebSocektHeartTime = 3000; //心跳包时间 const int g_nWebSocketLostConnectTime = 10000; //掉线时间 QWebSocketManager::QWebSocketManager() { m_pAudioOutput = nullptr; m_pStreamOutput = nullptr; this->InitAudioOut(); //初始化音频输出 connect(this, &QWebSocketManager::Msg_Self_HeartCmd, this, &QWebSocketManager::MsgReceived_Self_HeartCmd); m_pWebClient = new QWebSocket; connect(m_pWebClient, &QWebSocket::connected, this, &QWebSocketManager::MsgRecievd_Server_Connected); connect(m_pWebClient, &QWebSocket::disconnected, this, &QWebSocketManager::MsgRecievd_Server_Disconnected); connect(m_pWebClient, &QWebSocket::textMessageReceived, this, &QWebSocketManager::MsgRecievd_Server_TextMessageReceived); connect(m_pWebClient, &QWebSocket::binaryMessageReceived, this, &QWebSocketManager::MsgRecievd_Server_BinaryMessageReceived); m_bExitThreadMonitor = true; //开启监听线程 m_bSendHeartCmd = false; //默认，不发送心跳包 m_MonitorThread = std::thread(&QWebSocketManager::ThreadMonitorHeartbeat, this, this); m_MonitorThread.detach(); //类创建则线程被开启 } QWebSocketManager::~QWebSocketManager() { this->DisconnectWebSocket(); m_bExitThreadMonitor = false; std::lock_guard<std::mutex> lck(m_dataMutex); //C11用法 delete m_pAudioOutput; m_pAudioOutput = nullptr; delete m_pWebClient; m_pWebClient = nullptr; } void QWebSocketManager::ConnectWebSocket(QString qsUrl) { m_pWebClient->open(QUrl(qsUrl)); m_dwReciveTime = GetTickCount(); m_bRunningAudio = false; } void QWebSocketManager::DisconnectWebSocket() { if (m_pWebClient->state() == QAbstractSocket::SocketState::ConnectingState) { m_pWebClient->close(); } std::lock_guard<std::mutex> lck(m_mutexPcm); //C11用法 m_bRunningAudio = false; if (m_pAudioOutput->state() == QAudio::ActiveState) { //当前语音正在播放过程中，此时需要强制停止 m_pAudioOutput->stop(); } } unsigned int QWebSocketManager::ThreadMonitorHeartbeat(void* pParam) { QWebSocketManager* pThis = reinterpret_cast<QWebSocketManager*>(pParam); std::lock_guard<std::mutex> lck(m_dataMutex); //C11用法 while (pThis->m_bExitThreadMonitor) { //差值 > 3秒且小于10秒，需要给Web服务端下发心跳包，检测是否断开连接 if (pThis->m_bSendHeartCmd == true) { DWORD dwCalc = GetTickCount() - pThis->m_dwReciveTime; //时间差 = 最新时间 - 模拟人上传数据时间 if (dwCalc < g_nWebSocektHeartTime) { //时间差 < 最小心跳包 } else if ((dwCalc > g_nWebSocektHeartTime) && (dwCalc < g_nWebSocketLostConnectTime)) { emit Msg_Self_HeartCmd(); } else if(dwCalc > g_nWebSocketLostConnectTime) { qDebug() << QStringLiteral("连接超时！"); } } Sleep(1000); //每间隔1秒判断一次 } return 0; } unsigned int QWebSocketManager::ThreadProcessingPCMData(void* pParam) { QWebSocketManager* pThis = reinterpret_cast<QWebSocketManager*>(pParam); while (pThis->m_bRunningAudio == true) { //只有满足一个完整包数据时，才需要处理 if (pThis->m_ArrayAudio.count() >= m_nPeriodSize) { if (m_pAudioOutput->bytesFree() < m_nPeriodSize) { Sleep(5); continue; //当前音频释放大小 < 固定大小时，不处理 } std::lock_guard<std::mutex> lck(m_mutexPcm); //C11用法 QByteArray array = pThis->m_ArrayAudio.mid(0, m_nPeriodSize); pThis->m_pStreamOutput->write(array); pThis->m_ArrayAudio.remove(0, m_nPeriodSize); qDebug() << QStringLiteral("处理一次完整的音频，此时剩余大小 = ") << pThis->m_ArrayAudio.count(); } else { Sleep(1000); } } return 0; } void QWebSocketManager::MsgReceived_Self_HeartCmd() { this->SendWebSocket_HeartCmd(); } void QWebSocketManager::MsgRecievd_Server_Connected() { qDebug() << QStringLiteral("服务器，连接！"); emit Msg_Send_WebSocket_ConnectState(true); m_bSendHeartCmd = true; //开启，心跳包线程，重置存储定时器的时间 } void QWebSocketManager::MsgRecievd_Server_Disconnected() { qDebug() << QStringLiteral("服务器，断开连接！"); emit Msg_Send_WebSocket_ConnectState(false); m_bSendHeartCmd = false; //关闭心跳包发送 } void QWebSocketManager::MsgRecievd_Server_TextMessageReceived(const QString &message) { qDebug() << QStringLiteral("MsgRecievd_Server_TextMessageReceived，内容：") << message; m_dwReciveTime = GetTickCount(); //更新接收时间 } void QWebSocketManager::MsgRecievd_Server_BinaryMessageReceived(const QByteArray &message) { //qDebug() << QStringLiteral("MsgRecievd_Server_BinaryMessageReceived，内容：") << message; m_dwReciveTime = GetTickCount(); //更新接收时间 { std::lock_guard<std::mutex> lck(m_mutexPcm); //C11用法 m_ArrayAudio.append(message); } if (m_bRunningAudio == false) { m_bRunningAudio = true; //开启数据处理线程 m_threadAudio = std::thread(&QWebSocketManager::ThreadProcessingPCMData, this, this); } } void QWebSocketManager::SendWebSocket_HeartCmd() { //qDebug() << QStringLiteral("发送一次心跳包！"); QString qsCmd = QStringLiteral("{\"type\":\"ping\"}"); m_pWebClient->sendTextMessage(qsCmd); } void QWebSocketManager::InitAudioOut() { QAudioFormat audio_out_format; //设置录音的格式 audio_out_format.setSampleRate(8000); //采样率 audio_out_format.setChannelCount(1); //通道数 audio_out_format.setSampleSize(16); audio_out_format.setCodec("audio/pcm"); //编码格式 audio_out_format.setByteOrder(QAudioFormat::LittleEndian); //样本是小端字节顺序 audio_out_format.setSampleType(QAudioFormat::SignedInt); //样本类型 QAudioDeviceInfo info(QAudioDeviceInfo::defaultOutputDevice()); m_pAudioOutput = new QAudioOutput(audio_out_format); m_pStreamOutput = m_pAudioOutput->start(); m_nPeriodSize = m_pAudioOutput->periodSize(); qDebug() << QStringLiteral("当前音频完整数据格式大小是：") << m_nPeriodSize; }