课程设计基于QT和C++开发的直播管理系统源码(含客户端+服务端).zip

#include "LiveOpeWidget.h" #include "ui_LiveOpeWidget.h" #include <QMessageBox> #include "Protocol.h" #include "Login.h" #include <QTime> #include <QCameraInfo> #include <QBuffer> #include <QImageReader> #include <QMouseEvent> #include <QKeyEvent> #include <QGuiApplication> #include <QScreen> #include <QMovie> #include "ReceMsgHandle.h" LiveOpeWidget::LiveOpeWidget(QWidget *parent) : QWidget(parent), ui(new Ui::LiveOpeWidget), cvIsopen(false) { ui->setupUi(this); startPoint = QPoint(0,0); this->sender = new QUdpSocket(this); this->giftComboInit(); QAudioFormat format; format.setSampleRate(8000); format.setChannelCount(1); format.setSampleSize(16); format.setCodec("audio/pcm"); format.setSampleType(QAudioFormat::SignedInt); format.setByteOrder(QAudioFormat::LittleEndian); //音频采集对象初始化 this->voiceInput = new QAudioInput(format); //音频输出对象初始化 this->voiceOutput = new QAudioOutput(format); this->voiceOutDevice = this->voiceOutput->start(); this->receiver = new QUdpSocket(this); connect(this->receiver,SIGNAL(readyRead()),this,SLOT(readyReadSlot())); this->voiceReceiver = new QUdpSocket(this); connect(this->voiceReceiver,SIGNAL(readyRead()),this,SLOT(voiceReadSlot())); this->voiceSender = new QUdpSocket(this); //视频采集对象初始化 QCameraInfo info = QCameraInfo::defaultCamera(); this->cv = new QCamera(info, this); this->vs = new VideoSurface(this); this->cv->setViewfinder(vs); connect(vs,SIGNAL(frameChanged(QVideoFrame)), this,SLOT(videoFrameChangedSlot(QVideoFrame))); //定时刷新成员列表 this->cycFlushMemberList = new QTimer(this); connect(this->cycFlushMemberList,SIGNAL(timeout()), this,SLOT(on_pbFlushMemberlist_clicked())); //定时发送屏幕画面 this->cycSendMyScreen = new QTimer(this); connect(this->cycSendMyScreen,SIGNAL(timeout()), this,SLOT(displayDesktop())); //事件过滤器安装 ui->lb_ShowVideo->installEventFilter(this); ui->lineMsgLE->installEventFilter(this); } void LiveOpeWidget::closeEvent(QCloseEvent *event) { Q_UNUSED(event); on_pbExitRoom_clicked(); } //事件过滤器：视频显示标签全屏切换显示功能 bool LiveOpeWidget::eventFilter(QObject *ob, QEvent *ev) { if(ob == ui->lb_ShowVideo){ if(ev->type() == QEvent::MouseButtonDblClick){ QMouseEvent* mouse = static_cast<QMouseEvent*>(ev); if(mouse->button() == Qt::LeftButton){ //鼠标左键双击进入全屏 ui->lb_ShowVideo->setWindowFlags(Qt::Dialog); ui->lb_ShowVideo->showFullScreen(); return true; }else if(mouse->button() == Qt::RightButton){ //右键双击退出全屏 ui->lb_ShowVideo->setWindowFlags(Qt::SubWindow); ui->lb_ShowVideo->showNormal(); return true; }else{ // return QWidget::eventFilter(ob,ev); } } }else if(ob == ui->lineMsgLE){ if(ev->type() == QEvent::KeyPress){ QKeyEvent* key = static_cast<QKeyEvent*>(ev); if(key->key() == Qt::Key_Return){ this->on_pbSendMsg_clicked(); return true; } }else{ // return QWidget::eventFilter(ob,ev); } } return QWidget::eventFilter(ob,ev); } LiveOpeWidget *LiveOpeWidget::instance = nullptr; LiveOpeWidget *LiveOpeWidget::getInstance() { if(nullptr == instance){ instance = new LiveOpeWidget; } return instance; } LiveOpeWidget::~LiveOpeWidget() { delete this->voiceInput; delete this->voiceOutput; delete this->voiceInDevice; delete this->voiceOutDevice; delete ui; } void LiveOpeWidget::setSenderGroupAddr(const QHostAddress &rhsAddr, quint16 videoPort, quint16 voicePort) { this->senderGroupAddr = rhsAddr; this->senderGroupPort = videoPort; this->senderGroupvoicePort = voicePort; } void LiveOpeWidget::setReceiverGroupAddr(const QHostAddress &rhsAddr, quint16 videoPort,quint16 voicePort) { this->receiverGroupAddr = rhsAddr; this->receiverGroupPort = videoPort; this->receiverGroupvoicePort = voicePort; //视频组播地址端口绑定 if(this->receiver->state() == QAbstractSocket::BoundState){ this->receiver->leaveMulticastGroup(receiverGroupAddr); this->receiver->close(); } this->receiver->bind(QHostAddress::AnyIPv4,this->receiverGroupPort, QUdpSocket::ShareAddress|QUdpSocket::ReuseAddressHint); this->receiver->joinMulticastGroup(this->receiverGroupAddr); //音频组播地址端口绑定 if(this->voiceReceiver->state() == QAbstractSocket::BoundState){ this->voiceReceiver->leaveMulticastGroup(receiverGroupAddr); this->voiceReceiver->close(); } this->voiceReceiver->bind(QHostAddress::AnyIPv4,this->receiverGroupvoicePort, QUdpSocket::ShareAddress|QUdpSocket::ReuseAddressHint); this->voiceReceiver->joinMulticastGroup(this->receiverGroupAddr); } void LiveOpeWidget::FlushMemberLisg(const PDU &package) { ui->RoomMemberListLW->clear(); QString roomName = "房主:" + m_strRoomName; ui->RoomMemberListLW->addItem(roomName); int i = 0; for(; i < package.getObjectSize(); i++){ QString key = JSON_KEY_MEMBERNAME + QString::number(i); ui->RoomMemberListLW->addItem(package[key].toString()); } } void LiveOpeWidget::FlushMsgTE(const PDU &package) { if(this->m_strRoomName != package[JSON_KEY_ROOMNAME].toString()){ return ; } QString sender = package[JSON_KEY_NAME].toString(); QString role; if(sender == package[JSON_KEY_ROOMNAME].toString()){ //判断是否是房主 role = "-房主-"; }else{ role = "-观众-"; } QString time = QTime::currentTime().toString(); sender += role + " " + time + ":"; QTextCharFormat formatsender; formatsender.setForeground(QBrush(QColor(Qt::blue))); formatsender.setFont(QFont("Consolas",6)); ui->showMsgTE->setCurrentCharFormat(formatsender); ui->showMsgTE->append(sender); QTextCharFormat formatMsg; formatMsg.setFont(QFont("Consolas",12)); formatMsg.setForeground(QBrush(QColor(Qt::black))); ui->showMsgTE->setCurrentCharFormat(formatMsg); ui->showMsgTE->append(package[JSON_KEY_CHATMSG].toString()); this->displayDanmu(package[JSON_KEY_CHATMSG].toString()); } void LiveOpeWidget::displayDanmu(const QString &text) { QFont familystyle = ui->fontComboBox->currentFont(); int size = ui->sizeCB->currentText().toInt(); familystyle.setPointSize(size); QString color = "color:" + ui->colorCB->currentText() + ";"; QLabel* danmu = new QLabel(text,this); danmu->setFont(familystyle); danmu->setStyleSheet(color); danmu->adjustSize(); danmu->show(); int y = startPoint.y(); y+=20; if(y >= this->rect().height()-20){ y = 0; } startPoint.setY(y); startPoint.setX(this->rect().width()); startPoint.setX(ui->lb_ShowVideo->rect().width()); LabelMoveThread* mt = new LabelMoveThread(danmu,startPoint,this); this->danmuThreadVector.push_back(mt); connect(mt,SIGNAL(moveLabel(const QPoint&,QLabel*)), this,SLOT(moveLabel(const QPoint&,QLabel*))); connect(mt,SIGNAL(moveComplete(QLabel*)), this,SLOT(moveComplete(QLabel*))); mt->start(); } void LiveOpeWidget::displayGift(const QString& filename) { QLabel* gift = new QLabel(this); QImage image(filename); QPixmap pix = QPixmap