qt搭建的服务器支持ssl

#include "mainwindow.h" #include "ui_mainwindow.h" #include<QMessageBox> #include"ssl_param_dialog.h" MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent) , ui(new Ui::MainWindow) { ui->setupUi(this); m_server = new QTcpServer(this); connect(m_server, &QTcpServer::newConnection, this, &MainWindow::slotNewConnection); ui->tableWidget->setSelectionBehavior(QAbstractItemView::SelectRows); } MainWindow::~MainWindow() { delete ui; for(int i=0;i<m_sslSocketlist.size();i++) { QSslSocket *socket=m_tcpSocketlist.at(i); socket->close(); } for(int i=0;i<m_tcpSocketlist.size();i++) { QTcpSocket *socket=m_tcpSocketlist.at(i); socket->close(); } m_server->close(); m_server->deleteLater(); } void MainWindow::on_pushButton_clicked() { QString ip=ui->lineEdit->text(); int port=ui->lineEdit_2->text().toInt(); QHostAddress addr(ip); bool ret=m_server->listen(addr,port); if(ret==false) emit msg_sig("监听失败"); else{ ui->pushButton->setText("正在监听..."); ui->pushButton->setEnabled(false); ui->pushButton_2->setEnabled(true); } } void MainWindow::slotNewConnection() { qDebug()<<"新客户端连接"; m_pTcpSocket = m_server->nextPendingConnection(); //获取socket if(ui->checkBox_3->isChecked()){ m_sslSocket=new QSslSocket(); connect(m_sslSocket,SIGNAL(encrypted()),this,SLOT(encrypted_slot())); connect(m_sslSocket,SIGNAL(disconnected()),this,SLOT(disconnect_encrypted_slot())); connect(m_sslSocket, SIGNAL(readyRead()), this, SLOT(ssl_readyRead())); if (m_sslSocket->setSocketDescriptor(m_pTcpSocket->socketDescriptor())) { // 设置 SSL 配置，例如证书、私钥等 m_sslSocket->setLocalCertificate(m_server_cert); m_sslSocket->setPrivateKey(m_server_key); // 开启SSL加密 m_sslSocket->startServerEncryption(); } } else{ m_tcpSocketlist.append(m_pTcpSocket); slotClientConnected(); connect(m_pTcpSocket, &QTcpSocket::connected, this, &MainWindow::slotClientConnected); connect(m_pTcpSocket, &QTcpSocket::disconnected, this, &MainWindow::slotClientDisconnected); connect(m_pTcpSocket, &QTcpSocket::stateChanged, this, &MainWindow::slotSocketStateChange); connect(m_pTcpSocket, &QTcpSocket::readyRead, this, &MainWindow::slotSocketReadyRead); } } void MainWindow::on_pushButton_2_clicked() { if(m_server->isListening()) m_server->close(); ui->pushButton->setText("监听"); ui->pushButton->setEnabled(true); ui->pushButton_2->setEnabled(false); while (ui->tableWidget->rowCount()>0) { ui->tableWidget->removeRow(0); } for(int i=0;i<m_tcpSocketlist.size();i++) { QTcpSocket *socket=m_tcpSocketlist.at(i); socket->close(); } QList<QTcpSocket*>().swap(m_tcpSocketlist);//清空 for(int i=0;i<m_sslSocketlist.size();i++) { QSslSocket *socket=m_sslSocketlist.at(i); socket->close(); } QList<QSslSocket*>().swap(m_sslSocketlist);//清空 } void MainWindow::show_msg_slot(QString msg) { QMessageBox::information(this,"提示",msg); } void MainWindow::slotClientConnected() { qDebug()<<"上线"; int table_row_cnt=ui->tableWidget->rowCount(); ui->tableWidget->insertRow(table_row_cnt); ui->tableWidget->setItem(table_row_cnt,0,new QTableWidgetItem("ip:"+m_pTcpSocket->peerAddress().toString()+"port:"+QString::number(m_pTcpSocket->peerPort()))); ui->tableWidget->setItem(table_row_cnt,1,new QTableWidgetItem("在线")); m_map["ip:"+m_pTcpSocket->peerAddress().toString()+"port:"+QString::number(m_pTcpSocket->peerPort())]=m_pTcpSocket; ui->tableWidget->setCurrentCell(table_row_cnt,0); } void MainWindow::slotClientDisconnected() { QTcpSocket* socket = qobject_cast<QTcpSocket*>(sender()); qDebug()<<"下线"; // qDebug()<<"ip:"+socket->peerAddress().toString()+"port:"+QString::number(socket->peerPort()); update_tablewidget("ip:"+socket->peerAddress().toString()+"port:"+QString::number(socket->peerPort())); } void MainWindow::update_tablewidget(QString msg) { for(int i=0;i<ui->tableWidget->rowCount();i++){ QTableWidgetItem *item = ui->tableWidget->item(i, 0); if (item) { if(item->text()==msg){ QTableWidgetItem *item1 = ui->tableWidget->item(i, 1); item1->setText("离线"); } } } } void MainWindow::slotSocketStateChange(QAbstractSocket::SocketState socketState) { // socket状态变化时 switch (socketState) { case QAbstractSocket::UnconnectedState: ui->statusbar->showMessage("socket状态：UnconnectedSate"); break; case QAbstractSocket::HostLookupState: ui->statusbar->showMessage("socket状态：HostLookupState"); break; case QAbstractSocket::ConnectingState: ui->statusbar->showMessage("socket状态：ConnectingState"); break; case QAbstractSocket::ConnectedState: ui->statusbar->showMessage("socket状态：ConnectedState"); break; case QAbstractSocket::BoundState: ui->statusbar->showMessage("socket状态：BoundState"); break; case QAbstractSocket::ClosingState: ui->statusbar->showMessage("socket状态：ClosingState"); break; case QAbstractSocket::ListeningState: ui->statusbar->showMessage("socket状态：ListeningState"); break; } } void MainWindow::slotSocketReadyRead() { // //读取缓冲区行文本 // while (m_pTcpSocket->canReadLine()) { // ui->textEdit->append("[in]: " + m_pTcpSocket->readLine()); // } QTcpSocket* socket = qobject_cast<QTcpSocket*>(sender()); QString msg=""; if(ui->checkBox->isChecked()){ msg=QString("[客户端:%1-%2]%3").arg(socket->peerAddress().toString()).arg(QString::number(socket->peerPort())).arg(QString((socket->readAll().toHex()))); } else{ msg=QString("[客户端:%1-%2]%3").arg(socket->peerAddress().toString()).arg(QString::number(socket->peerPort())).arg(QString::fromUtf8( socket->readAll())); } qDebug()<<msg; ui->textEdit->append(msg); } void MainWindow::on_pushButton_3_clicked() { ui->textEdit->setText(""); ui->textEdit_2->setText(""); } int asc2hex(char *str,char *&dist){ if(str!=nullptr && strlen(str)>0) { dist=(char *)malloc(strlen(str)); memset(dist,0,strlen(str)); int j=0; for(int i=0;i<strlen(str);i++) { int sum=0; sum+=(str[i]-'0')*16; sum+=str[++i]-'0'; dist[j++]=sum; } return strlen(str)/2; } return 0; } void MainWindow::on_pushButton_4_clicked() { try{ int row=ui->tableWidget->currentRow(); int column=ui->tableWidget->currentColumn(); if(ui->tableWidget->item(row,0)!=nullptr){ qDebug()<<ui->tableWidget->item(row,0)->text(); if(ui->textEdit_2->toPlainText().length()>0) { if(ui->checkBox_2->isChecked()){ char *res=nullptr; int len=asc2hex(( char *)ui->textEdit_2->toPlainText().toStdString().c_str(),res); if(ui->checkBox_3->isChecked()){ QSslSocket *socket=m_ssl_map[ui->tableWidget->item(row,column)->text()]; socket->write(res,len); } else{ QTcpSocket *socket=m_map[ui->tableWidget->item(row,column)->text()]; socket->write(res,len); } free(res);